54
54
payload => message,
55
55
msgid => msg_id
56
56
);
57
+ commit ;
57
58
end;
58
59
/
59
60
```
@@ -340,11 +341,11 @@ begin
340
341
341
342
message_properties .delay := 7 * 24 * 60 * 60 ; -- Delay for 7 days
342
343
dbms_aq .enqueue (
343
- queue_name => ' my_queue' ,
344
- enqueue_options => enqueue_options,
345
- message_properties => message_properties,
346
- payload => message,
347
- msgid => message_handle
344
+ queue_name => ' my_queue' ,
345
+ enqueue_options => enqueue_options,
346
+ message_properties => message_properties,
347
+ payload => message,
348
+ msgid => message_handle
348
349
);
349
350
commit ;
350
351
end;
@@ -369,11 +370,11 @@ begin
369
370
370
371
message_properties .priority := 1 ; -- A lower number indicates higher priority
371
372
dbms_aq .enqueue (
372
- queue_name => ' my_queue' ,
373
- enqueue_options => enqueue_options,
374
- message_properties => message_properties,
375
- payload => message,
376
- msgid => message_handle
373
+ queue_name => ' my_queue' ,
374
+ enqueue_options => enqueue_options,
375
+ message_properties => message_properties,
376
+ payload => message,
377
+ msgid => message_handle
377
378
);
378
379
commit ;
379
380
end;
@@ -416,11 +417,11 @@ begin
416
417
417
418
-- Enqueue the message
418
419
dbms_aq .enqueue (
419
- queue_name => ' json_queue' ,
420
- enqueue_options => enqueue_options,
421
- message_properties => message_properties,
422
- payload => message,
423
- msgid => msg_id
420
+ queue_name => ' json_queue' ,
421
+ enqueue_options => enqueue_options,
422
+ message_properties => message_properties,
423
+ payload => message,
424
+ msgid => msg_id
424
425
);
425
426
commit ;
426
427
exception
0 commit comments