27: p_correlation varchar2,
28: p_message CLOB ) as
29:
30: l_message_obj SYSTEM.JTF_MSG_OBJ := SYSTEM.JTF_MSG_OBJ( empty_clob() );
31: l_enqueue_options dbms_aq.enqueue_options_t;
32: l_message_properties dbms_aq.message_properties_t;
33: l_bo_Qname varchar2(55) := 'JTF_DEF_QUEUE';
34: l_msg_id RAW(16);
35: l_schema varchar2(30);
28: p_message CLOB ) as
29:
30: l_message_obj SYSTEM.JTF_MSG_OBJ := SYSTEM.JTF_MSG_OBJ( empty_clob() );
31: l_enqueue_options dbms_aq.enqueue_options_t;
32: l_message_properties dbms_aq.message_properties_t;
33: l_bo_Qname varchar2(55) := 'JTF_DEF_QUEUE';
34: l_msg_id RAW(16);
35: l_schema varchar2(30);
36:
68: l_bo_Qname := l_schema||'.'||l_bo_Qname;
69: l_message_obj.message := p_message;
70: l_message_properties.correlation := p_correlation;
71:
72: dbms_aq.enqueue( queue_name => l_bo_Qname ,
73: enqueue_options => l_enqueue_options ,
74: message_properties => l_message_properties ,
75: payload => l_message_obj ,
76: msgid => l_msg_id );