Workflow_客制化BusinessEvent进行消息传递（案例）

 1 --Create table
 2 create table BXJ_BES_EVENT_DEMO
 3 (
 4   DEMO_ID                 NUMBER,
 5   MESSAGE_NAME            VARCHAR2(100),
 6   MESSAGE_KEY             VARCHAR2(100),
 7   MESSAGE_CONTENTS        CLOB,
 8   PARAMETER_VALUE1        VARCHAR2(4000),
 9   PARAMETER_VALUE2        VARCHAR2(4000),
10   EVENT_DATE              DATE  
11 );
12 
13 --Create Sequence
14 CREATE SEQUENCE BXJ_BES_DEMO_S;

 1 --Create Package Header
 2 CREATE OR REPLACE PACKAGE apps.bxj_bes_event_demo_pkg AUTHID CURRENT_USER AS
 3   FUNCTION process_an_event(p_sub_guid IN RAW,
 4                             p_event    IN OUT NOCOPY wf_event_t)
 5     RETURN VARCHAR2;
 6 END;
 7 
 8 --Create Package Body
 9 CREATE OR REPLACE PACKAGE BODY apps.bxj_bes_event_demo_pkg AS
10   FUNCTION process_an_event(p_sub_guid IN RAW,
11                             p_event    IN OUT NOCOPY wf_event_t)
12     RETURN VARCHAR2 IS
13     l_demo_rec bxj_bes_event_demo%ROWTYPE;
14   BEGIN  
15     SELECT bxj_bes_demo_s.NEXTVAL INTO l_demo_rec.demo_id FROM dual;  
16     --get evevent itself
17     l_demo_rec.message_name := p_event.geteventname;
18     l_demo_rec.event_date   := p_event.getsenddate;  
19     --we can use this key to transfer message only
20     l_demo_rec.message_key := p_event.geteventkey;  
21     --optional, get xml data
22     l_demo_rec.message_contents := p_event.geteventdata; 
23     --optional, get parameter
24     l_demo_rec.parameter_value1 := p_event.getvalueforparameter(‘Parameter1‘);
25     l_demo_rec.parameter_value2 := p_event.getvalueforparameter(‘Parameter2‘);  
26     --do anything here
27     INSERT INTO bxj_bes_event_demo VALUES l_demo_rec;
28     RETURN ‘SUCCESS‘;
29   EXCEPTION
30     WHEN OTHERS THEN
31       RETURN ‘ERROR‘;
32   END;
33 END;