DBA Data[Home] [Help]

APPS.ECX_OUT_WF_QH dependencies on ECXMSG

Line 15: x_ecxmsg system.ecxmsg;

11: x_msgid RAW(16);
12: x_clob clob;
13: no_messages exception;
14: pragma exception_init (no_messages, -25228);
15: x_ecxmsg system.ecxmsg;
16: x_sys_guid RAW(16);
17: x_sys_name VARCHAR2(30);
18: x_from_agt wf_agent_t := wf_agent_t(null,null);
19: x_to_agt wf_agent_t := wf_agent_t(null,null);

Line 58: payload => x_ecxmsg,

54: (
55: queue_name => x_queue_name,
56: dequeue_options => x_dequeue_options,
57: message_properties => x_message_properties,
58: payload => x_ecxmsg,
59: msgid => x_msgid
60: );
61:
62: ecx_out_wf_qh.navigation := dbms_aq.next_message;

Line 66: p_event.event_key := x_ecxmsg.document_number;

62: ecx_out_wf_qh.navigation := dbms_aq.next_message;
63:
64: p_event.priority := 1;
65: p_event.event_name := 'oracle.apps.ecx.inbound.message.receive';
66: p_event.event_key := x_ecxmsg.document_number;
67: p_event.from_agent := x_from_agt ;
68: p_event.to_agent := x_to_agt ;
69: p_event.error_subscription := null;
70: p_event.error_message := null;

Line 79: p_event.AddParameterToList('TRANSACTION_TYPE', x_ecxmsg.transaction_type);

75: 'setting message props');
76: end if;
77:
78: --p_event.AddParameterToList('ECX_MSGID', x_msgid);
79: p_event.AddParameterToList('TRANSACTION_TYPE', x_ecxmsg.transaction_type);
80: p_event.AddParameterToList('TRANSACTION_SUBTYPE', x_ecxmsg.transaction_subtype);
81: p_event.AddParameterToList('MESSAGE_STANDARD', x_ecxmsg.message_standard);
82: p_event.AddParameterToList('MESSAGE_TYPE', x_ecxmsg.message_type);
83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);

Line 80: p_event.AddParameterToList('TRANSACTION_SUBTYPE', x_ecxmsg.transaction_subtype);

76: end if;
77:
78: --p_event.AddParameterToList('ECX_MSGID', x_msgid);
79: p_event.AddParameterToList('TRANSACTION_TYPE', x_ecxmsg.transaction_type);
80: p_event.AddParameterToList('TRANSACTION_SUBTYPE', x_ecxmsg.transaction_subtype);
81: p_event.AddParameterToList('MESSAGE_STANDARD', x_ecxmsg.message_standard);
82: p_event.AddParameterToList('MESSAGE_TYPE', x_ecxmsg.message_type);
83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);
84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);

Line 81: p_event.AddParameterToList('MESSAGE_STANDARD', x_ecxmsg.message_standard);

77:
78: --p_event.AddParameterToList('ECX_MSGID', x_msgid);
79: p_event.AddParameterToList('TRANSACTION_TYPE', x_ecxmsg.transaction_type);
80: p_event.AddParameterToList('TRANSACTION_SUBTYPE', x_ecxmsg.transaction_subtype);
81: p_event.AddParameterToList('MESSAGE_STANDARD', x_ecxmsg.message_standard);
82: p_event.AddParameterToList('MESSAGE_TYPE', x_ecxmsg.message_type);
83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);
84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);
85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);

Line 82: p_event.AddParameterToList('MESSAGE_TYPE', x_ecxmsg.message_type);

78: --p_event.AddParameterToList('ECX_MSGID', x_msgid);
79: p_event.AddParameterToList('TRANSACTION_TYPE', x_ecxmsg.transaction_type);
80: p_event.AddParameterToList('TRANSACTION_SUBTYPE', x_ecxmsg.transaction_subtype);
81: p_event.AddParameterToList('MESSAGE_STANDARD', x_ecxmsg.message_standard);
82: p_event.AddParameterToList('MESSAGE_TYPE', x_ecxmsg.message_type);
83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);
84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);
85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);
86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);

Line 83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);

79: p_event.AddParameterToList('TRANSACTION_TYPE', x_ecxmsg.transaction_type);
80: p_event.AddParameterToList('TRANSACTION_SUBTYPE', x_ecxmsg.transaction_subtype);
81: p_event.AddParameterToList('MESSAGE_STANDARD', x_ecxmsg.message_standard);
82: p_event.AddParameterToList('MESSAGE_TYPE', x_ecxmsg.message_type);
83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);
84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);
85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);
86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);
87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);

Line 84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);

80: p_event.AddParameterToList('TRANSACTION_SUBTYPE', x_ecxmsg.transaction_subtype);
81: p_event.AddParameterToList('MESSAGE_STANDARD', x_ecxmsg.message_standard);
82: p_event.AddParameterToList('MESSAGE_TYPE', x_ecxmsg.message_type);
83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);
84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);
85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);
86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);
87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);
88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);

Line 85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);

81: p_event.AddParameterToList('MESSAGE_STANDARD', x_ecxmsg.message_standard);
82: p_event.AddParameterToList('MESSAGE_TYPE', x_ecxmsg.message_type);
83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);
84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);
85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);
86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);
87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);
88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);
89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);

Line 86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);

82: p_event.AddParameterToList('MESSAGE_TYPE', x_ecxmsg.message_type);
83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);
84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);
85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);
86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);
87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);
88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);
89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);
90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);

Line 87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);

83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);
84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);
85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);
86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);
87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);
88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);
89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);
90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);
91: p_event.AddParameterToList('ATTRIBUTE2', x_ecxmsg.attribute2);

Line 88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);

84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);
85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);
86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);
87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);
88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);
89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);
90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);
91: p_event.AddParameterToList('ATTRIBUTE2', x_ecxmsg.attribute2);
92: p_event.AddParameterToList('ATTRIBUTE3', x_ecxmsg.attribute3);

Line 89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);

85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);
86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);
87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);
88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);
89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);
90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);
91: p_event.AddParameterToList('ATTRIBUTE2', x_ecxmsg.attribute2);
92: p_event.AddParameterToList('ATTRIBUTE3', x_ecxmsg.attribute3);
93: p_event.AddParameterToList('ATTRIBUTE4', x_ecxmsg.attribute4);

Line 90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);

86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);
87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);
88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);
89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);
90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);
91: p_event.AddParameterToList('ATTRIBUTE2', x_ecxmsg.attribute2);
92: p_event.AddParameterToList('ATTRIBUTE3', x_ecxmsg.attribute3);
93: p_event.AddParameterToList('ATTRIBUTE4', x_ecxmsg.attribute4);
94: p_event.AddParameterToList('ATTRIBUTE5', x_ecxmsg.attribute5);

Line 91: p_event.AddParameterToList('ATTRIBUTE2', x_ecxmsg.attribute2);

87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);
88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);
89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);
90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);
91: p_event.AddParameterToList('ATTRIBUTE2', x_ecxmsg.attribute2);
92: p_event.AddParameterToList('ATTRIBUTE3', x_ecxmsg.attribute3);
93: p_event.AddParameterToList('ATTRIBUTE4', x_ecxmsg.attribute4);
94: p_event.AddParameterToList('ATTRIBUTE5', x_ecxmsg.attribute5);
95:

Line 92: p_event.AddParameterToList('ATTRIBUTE3', x_ecxmsg.attribute3);

88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);
89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);
90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);
91: p_event.AddParameterToList('ATTRIBUTE2', x_ecxmsg.attribute2);
92: p_event.AddParameterToList('ATTRIBUTE3', x_ecxmsg.attribute3);
93: p_event.AddParameterToList('ATTRIBUTE4', x_ecxmsg.attribute4);
94: p_event.AddParameterToList('ATTRIBUTE5', x_ecxmsg.attribute5);
95:
96: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then

Line 93: p_event.AddParameterToList('ATTRIBUTE4', x_ecxmsg.attribute4);

89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);
90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);
91: p_event.AddParameterToList('ATTRIBUTE2', x_ecxmsg.attribute2);
92: p_event.AddParameterToList('ATTRIBUTE3', x_ecxmsg.attribute3);
93: p_event.AddParameterToList('ATTRIBUTE4', x_ecxmsg.attribute4);
94: p_event.AddParameterToList('ATTRIBUTE5', x_ecxmsg.attribute5);
95:
96: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
97: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,

Line 94: p_event.AddParameterToList('ATTRIBUTE5', x_ecxmsg.attribute5);

90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);
91: p_event.AddParameterToList('ATTRIBUTE2', x_ecxmsg.attribute2);
92: p_event.AddParameterToList('ATTRIBUTE3', x_ecxmsg.attribute3);
93: p_event.AddParameterToList('ATTRIBUTE4', x_ecxmsg.attribute4);
94: p_event.AddParameterToList('ATTRIBUTE5', x_ecxmsg.attribute5);
95:
96: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
97: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
98: 'setting payload');

Line 100: p_event.setEventData(x_ecxmsg.payload);

96: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
97: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
98: 'setting payload');
99: end if;
100: p_event.setEventData(x_ecxmsg.payload);
101:
102: exception
103: when no_messages then
104: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then

Line 122: system.ecxmsg object and returns these to the caller procedure

118:
119:
120: /**
121: This procedure traverses through all the parameters in wf_event_t object, constructs the
122: system.ecxmsg object and returns these to the caller procedure
123: **/
124: procedure create_ecxmsg(p_event in wf_event_t,
125: x_ecxmsg in out NOCOPY SYSTEM.ecxmsg
126: )

Line 124: procedure create_ecxmsg(p_event in wf_event_t,

120: /**
121: This procedure traverses through all the parameters in wf_event_t object, constructs the
122: system.ecxmsg object and returns these to the caller procedure
123: **/
124: procedure create_ecxmsg(p_event in wf_event_t,
125: x_ecxmsg in out NOCOPY SYSTEM.ecxmsg
126: )
127: is
128:

Line 125: x_ecxmsg in out NOCOPY SYSTEM.ecxmsg

121: This procedure traverses through all the parameters in wf_event_t object, constructs the
122: system.ecxmsg object and returns these to the caller procedure
123: **/
124: procedure create_ecxmsg(p_event in wf_event_t,
125: x_ecxmsg in out NOCOPY SYSTEM.ecxmsg
126: )
127: is
128:
129: i_param_list wf_parameter_list_t;

Line 138: l_module := 'ecx.plsql.ecx_out_wf_qh.enqueue.create_ecxmsg';

134: l_module varchar2(2000);
135:
136: begin
137:
138: l_module := 'ecx.plsql.ecx_out_wf_qh.enqueue.create_ecxmsg';
139: -- loop through the parameter list and construct x_ecxmsg object
140: i_param_list := p_event.getParameterList();
141: if (i_param_list is null) then
142: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then

Line 139: -- loop through the parameter list and construct x_ecxmsg object

135:
136: begin
137:
138: l_module := 'ecx.plsql.ecx_out_wf_qh.enqueue.create_ecxmsg';
139: -- loop through the parameter list and construct x_ecxmsg object
140: i_param_list := p_event.getParameterList();
141: if (i_param_list is null) then
142: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
143: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,

Line 152: x_ecxmsg := SYSTEM.ecxmsg(null, null, null, null, null, null, null, null, null,

148: ecx_out_wf_qh.retmsg :='ECX_PARAM_LIST_NOT_NULL';
149: ecx_out_wf_qh.retcode := 2;
150: raise queue_handler_exit;
151: else
152: x_ecxmsg := SYSTEM.ecxmsg(null, null, null, null, null, null, null, null, null,
153: null, null, null, null, null, null, null, null, null);
154: for i in i_param_list.first..i_param_list.last loop
155: i_param_name := i_param_list(i).GetName;
156: i_param_value := i_param_list(i).GetValue;

Line 159: x_ecxmsg.message_type := i_param_value;

155: i_param_name := i_param_list(i).GetName;
156: i_param_value := i_param_list(i).GetValue;
157:
158: if i_param_name = 'MESSAGE_TYPE' then
159: x_ecxmsg.message_type := i_param_value;
160:
161: elsif i_param_name = 'MESSAGE_STANDARD' then
162: x_ecxmsg.message_standard := i_param_value;
163:

Line 162: x_ecxmsg.message_standard := i_param_value;

158: if i_param_name = 'MESSAGE_TYPE' then
159: x_ecxmsg.message_type := i_param_value;
160:
161: elsif i_param_name = 'MESSAGE_STANDARD' then
162: x_ecxmsg.message_standard := i_param_value;
163:
164: elsif i_param_name = 'TRANSACTION_TYPE' then
165: x_ecxmsg.transaction_type := i_param_value;
166:

Line 165: x_ecxmsg.transaction_type := i_param_value;

161: elsif i_param_name = 'MESSAGE_STANDARD' then
162: x_ecxmsg.message_standard := i_param_value;
163:
164: elsif i_param_name = 'TRANSACTION_TYPE' then
165: x_ecxmsg.transaction_type := i_param_value;
166:
167: elsif i_param_name = 'TRANSACTION_SUBTYPE' then
168: x_ecxmsg.transaction_subtype := i_param_value;
169:

Line 168: x_ecxmsg.transaction_subtype := i_param_value;

164: elsif i_param_name = 'TRANSACTION_TYPE' then
165: x_ecxmsg.transaction_type := i_param_value;
166:
167: elsif i_param_name = 'TRANSACTION_SUBTYPE' then
168: x_ecxmsg.transaction_subtype := i_param_value;
169:
170: elsif i_param_name = 'DOCUMENT_NUMBER' then
171: x_ecxmsg.document_number := i_param_value;
172:

Line 171: x_ecxmsg.document_number := i_param_value;

167: elsif i_param_name = 'TRANSACTION_SUBTYPE' then
168: x_ecxmsg.transaction_subtype := i_param_value;
169:
170: elsif i_param_name = 'DOCUMENT_NUMBER' then
171: x_ecxmsg.document_number := i_param_value;
172:
173: elsif i_param_name = 'PARTY_TYPE' then
174: x_ecxmsg.party_type := i_param_value;
175:

Line 174: x_ecxmsg.party_type := i_param_value;

170: elsif i_param_name = 'DOCUMENT_NUMBER' then
171: x_ecxmsg.document_number := i_param_value;
172:
173: elsif i_param_name = 'PARTY_TYPE' then
174: x_ecxmsg.party_type := i_param_value;
175:
176: elsif i_param_name = 'PARTYID' then
177: x_ecxmsg.partyid := i_param_value;
178:

Line 177: x_ecxmsg.partyid := i_param_value;

173: elsif i_param_name = 'PARTY_TYPE' then
174: x_ecxmsg.party_type := i_param_value;
175:
176: elsif i_param_name = 'PARTYID' then
177: x_ecxmsg.partyid := i_param_value;
178:
179: elsif i_param_name = 'PARTY_SITE_ID' then
180: x_ecxmsg.party_site_id := i_param_value;
181:

Line 180: x_ecxmsg.party_site_id := i_param_value;

176: elsif i_param_name = 'PARTYID' then
177: x_ecxmsg.partyid := i_param_value;
178:
179: elsif i_param_name = 'PARTY_SITE_ID' then
180: x_ecxmsg.party_site_id := i_param_value;
181:
182: elsif i_param_name = 'PROTOCOL_TYPE' then
183: x_ecxmsg.protocol_type := i_param_value;
184:

Line 183: x_ecxmsg.protocol_type := i_param_value;

179: elsif i_param_name = 'PARTY_SITE_ID' then
180: x_ecxmsg.party_site_id := i_param_value;
181:
182: elsif i_param_name = 'PROTOCOL_TYPE' then
183: x_ecxmsg.protocol_type := i_param_value;
184:
185: elsif i_param_name = 'PROTOCOL_ADDRESS' then
186: x_ecxmsg.protocol_address := i_param_value;
187:

Line 186: x_ecxmsg.protocol_address := i_param_value;

182: elsif i_param_name = 'PROTOCOL_TYPE' then
183: x_ecxmsg.protocol_type := i_param_value;
184:
185: elsif i_param_name = 'PROTOCOL_ADDRESS' then
186: x_ecxmsg.protocol_address := i_param_value;
187:
188: elsif i_param_name = 'USERNAME' then
189: x_ecxmsg.username := i_param_value;
190:

Line 189: x_ecxmsg.username := i_param_value;

185: elsif i_param_name = 'PROTOCOL_ADDRESS' then
186: x_ecxmsg.protocol_address := i_param_value;
187:
188: elsif i_param_name = 'USERNAME' then
189: x_ecxmsg.username := i_param_value;
190:
191: elsif i_param_name = 'PASSWORD' then
192: x_ecxmsg.password := i_param_value;
193:

Line 192: x_ecxmsg.password := i_param_value;

188: elsif i_param_name = 'USERNAME' then
189: x_ecxmsg.username := i_param_value;
190:
191: elsif i_param_name = 'PASSWORD' then
192: x_ecxmsg.password := i_param_value;
193:
194: elsif i_param_name = 'ATTRIBUTE1' then
195: x_ecxmsg.attribute1 := i_param_value;
196:

Line 195: x_ecxmsg.attribute1 := i_param_value;

191: elsif i_param_name = 'PASSWORD' then
192: x_ecxmsg.password := i_param_value;
193:
194: elsif i_param_name = 'ATTRIBUTE1' then
195: x_ecxmsg.attribute1 := i_param_value;
196:
197: elsif i_param_name = 'ATTRIBUTE2' then
198: x_ecxmsg.attribute2 := i_param_value;
199:

Line 198: x_ecxmsg.attribute2 := i_param_value;

194: elsif i_param_name = 'ATTRIBUTE1' then
195: x_ecxmsg.attribute1 := i_param_value;
196:
197: elsif i_param_name = 'ATTRIBUTE2' then
198: x_ecxmsg.attribute2 := i_param_value;
199:
200: elsif i_param_name = 'ATTRIBUTE3' then
201: x_ecxmsg.attribute3 := i_param_value;
202:

Line 201: x_ecxmsg.attribute3 := i_param_value;

197: elsif i_param_name = 'ATTRIBUTE2' then
198: x_ecxmsg.attribute2 := i_param_value;
199:
200: elsif i_param_name = 'ATTRIBUTE3' then
201: x_ecxmsg.attribute3 := i_param_value;
202:
203: elsif i_param_name = 'ATTRIBUTE4' then
204: x_ecxmsg.attribute4 := i_param_value;
205:

Line 204: x_ecxmsg.attribute4 := i_param_value;

200: elsif i_param_name = 'ATTRIBUTE3' then
201: x_ecxmsg.attribute3 := i_param_value;
202:
203: elsif i_param_name = 'ATTRIBUTE4' then
204: x_ecxmsg.attribute4 := i_param_value;
205:
206: elsif i_param_name = 'ATTRIBUTE5' then
207: x_ecxmsg.attribute5 := i_param_value;
208: end if;

Line 207: x_ecxmsg.attribute5 := i_param_value;

203: elsif i_param_name = 'ATTRIBUTE4' then
204: x_ecxmsg.attribute4 := i_param_value;
205:
206: elsif i_param_name = 'ATTRIBUTE5' then
207: x_ecxmsg.attribute5 := i_param_value;
208: end if;
209: end loop;
210: end if;
211:

Line 216: x_ecxmsg.payload := p_event.getEventData();

212: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
213: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
214: 'setting payload');
215: end if;
216: x_ecxmsg.payload := p_event.getEventData();
217:
218: exception
219: when queue_handler_exit then
220: raise queue_handler_exit;

Line 225: end create_ecxmsg;

221: when others then
222: ecx_out_wf_qh.retmsg := SQLERRM;
223: ecx_out_wf_qh.retcode := 2;
224: raise queue_handler_exit;
225: end create_ecxmsg;
226:
227:
228: /**
229: This procedure enqueues the message on ecx_outqueue and returns the msgid of this message

Line 234: x_ecxmsg in out NOCOPY SYSTEM.ecxmsg,

230: **/
231: procedure enqueue_msg(
232: x_out_queue in varchar2,
233: i_protocol_type in out NOCOPY varchar2,
234: x_ecxmsg in out NOCOPY SYSTEM.ecxmsg,
235: x_msgid out NOCOPY raw
236: )
237: is
238: x_enqueue_options dbms_aq.enqueue_options_t;

Line 264: l_in_clob := x_ecxmsg.payload;

260: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
261: 'Correlation id: '|| x_message_properties.correlation);
262: end if;
263:
264: l_in_clob := x_ecxmsg.payload;
265: ecx_eng_utils.convertEncryCodeClob(l_in_clob, l_out_clob);
266: x_ecxmsg.payload := l_out_clob;
267:
268: DBMS_AQ.ENQUEUE

Line 266: x_ecxmsg.payload := l_out_clob;

262: end if;
263:
264: l_in_clob := x_ecxmsg.payload;
265: ecx_eng_utils.convertEncryCodeClob(l_in_clob, l_out_clob);
266: x_ecxmsg.payload := l_out_clob;
267:
268: DBMS_AQ.ENQUEUE
269: (
270: queue_name => x_out_queue,

Line 273: payload => x_ecxmsg,

269: (
270: queue_name => x_out_queue,
271: enqueue_options => x_enqueue_options,
272: message_properties => x_message_properties,
273: payload => x_ecxmsg,
274: msgid => x_msgid
275: );
276:
277: -- assign the encrpyted clob back to x_ecxmsg so it will insert the

Line 277: -- assign the encrpyted clob back to x_ecxmsg so it will insert the

273: payload => x_ecxmsg,
274: msgid => x_msgid
275: );
276:
277: -- assign the encrpyted clob back to x_ecxmsg so it will insert the
278: -- encrpyted clob to ecx_doclogs later.
279: x_ecxmsg.payload := l_in_clob;
280:
281: if dbms_lob.istemporary(l_out_clob) = 1 then

Line 279: x_ecxmsg.payload := l_in_clob;

275: );
276:
277: -- assign the encrpyted clob back to x_ecxmsg so it will insert the
278: -- encrpyted clob to ecx_doclogs later.
279: x_ecxmsg.payload := l_in_clob;
280:
281: if dbms_lob.istemporary(l_out_clob) = 1 then
282: dbms_lob.freetemporary(l_out_clob);
283: end if;

Line 317: x_ecxmsg SYSTEM.ecxmsg;

313: x_to_system_name varchar2(30);
314: x_out_queue varchar2(80);
315: x_to_queue varchar2(80);
316: x_msgid RAW(16);
317: x_ecxmsg SYSTEM.ecxmsg;
318: l_module varchar2(2000);
319:
320: cursor c1
321: is

Line 353: create_ecxmsg (p_event, x_ecxmsg);

349: where agt.name = x_out_agent_name
350: and sys.name = x_out_system_name
351: and sys.guid = agt.system_guid;
352:
353: create_ecxmsg (p_event, x_ecxmsg);
354:
355: -- enqueue the message
356: ecx_out_wf_qh.enqueue_msg(
357: x_out_queue => x_out_queue,

Line 358: i_protocol_type => x_ecxmsg.protocol_type,

354:
355: -- enqueue the message
356: ecx_out_wf_qh.enqueue_msg(
357: x_out_queue => x_out_queue,
358: i_protocol_type => x_ecxmsg.protocol_type,
359: x_ecxmsg => x_ecxmsg,
360: x_msgid => x_msgid
361: );
362:

Line 359: x_ecxmsg => x_ecxmsg,

355: -- enqueue the message
356: ecx_out_wf_qh.enqueue_msg(
357: x_out_queue => x_out_queue,
358: i_protocol_type => x_ecxmsg.protocol_type,
359: x_ecxmsg => x_ecxmsg,
360: x_msgid => x_msgid
361: );
362:
363: -- set msgid