Why can't I remove the than us?

Hello world.
I used the advanced queue to achieve a spread of message from a database to a different db and it spread the message successly.
But there are a few problems when I want to remove from the queue.
DB version: 10.2.0.4.0
OS: Linux

source:
-create a type for queues
CREATE the AQ type. Message_typ as object)
topic VARCHAR2 (30),
text VARCHAR2 (80));
-create queues
DECLARE
sys.AQ$ _agent of the Subscriber;
BEGIN
-create a queue table
DBMS_AQADM. CREATE_QUEUE_TABLE (queue_table = > 'aq.que_shenshou_tab',)
multiple_consumers = > TRUE,
queue_payload_type = > ' AQ. Message_typ');

-create a queue and start
DBMS_AQADM. CREATE_QUEUE (queue_name = > 'aq.que_shenshou_send',)
queue_table = > 'aq.que_shenshou_tab');
DBMS_AQADM. START_QUEUE (queue_name = > 'aq.que_shenshou_send');

-Add subscribers to the queue
Subscriber: sys.aq = $_agent ('sender', '[email protected]', NULL);
DBMS_AQADM. ADD_SUBSCRIBER (queue_name = > 'que_shenshou_send',)
Subscriber = > Subscriber);

-create calendar spread
DBMS_AQADM. SCHEDULE_PROPAGATION (queue_name = > 'que_shenshou_send',)
destination = > 'busi.lk');

END;
enqueue - the message
DECLARE
enqueue_options DBMS_AQ.enqueue_options_t;
message_properties DBMS_AQ.message_properties_t;
recipients DBMS_AQ.aq$ _recipient_list_t;
message_handle RAW (16);
message aq.message_typ;
number of seq_number;
BEGIN
because loop me in 1.10
Select seq_shenshou.nextval in the double seq_number;
message: = message_typ ("tree:" | ") seq_number,
"This message is waiting for the queue subscribers.");

DBMS_AQ. ENQUEUE (queue_name = > 'que_shenshou_send',)
enqueue_options = > enqueue_options,
message_properties = > message_properties,
payload = > message,.
msgid = > message_handle);

COMMIT;
DBMS_LOCK. Sleep (1);
end loop;
END;

THE REMOTE CONTROL:
CREATE the AQ type. Message_typ as object)
topic VARCHAR2 (30),
text VARCHAR2 (80));
Start
DBMS_AQADM. () CREATE_QUEUE_TABLE
queue_table = > "aq.que_shenshou"
queue_payload_type = > ' AQ. Message_typ',.
multiple_consumers = > TRUE);
end;

Start
DBMS_AQADM. () CREATE_QUEUE
queue_name = > "aq.que_shenshou_rec"
queue_table = > 'aq.que_shenshou');
end;

Start
DBMS_AQADM. () START_QUEUE
queue_name = > 'aq.que_shenshou_rec');
end;

Start
() dbms_aqadm.add_subscriber
queue_name = > "aq.que_shenshou_rec"
Subscriber = > sys.aq$ _agent ('ability to use', null, null)
);
end;

I checked the table of the queue on the remote db and ensure that messages have been propagrated successely.
then I run the codes as follows:
DECLARE
dequeue_options DBMS_AQ.dequeue_options_t;
message_properties DBMS_AQ.message_properties_t;
message_handle RAW (16);
message aq.message_typ;
BEGIN
dequeue_options. Navigation: = DBMS_AQ. FIRST_MESSAGE;
dequeue_options.consumer_name: = 'possibility to USE. "
DBMS_AQ. DEQUEUE (queue_name = > ' AQ.) QUE_SHENSHOU_REC',.
dequeue_options = > dequeue_options,
message_properties = > message_properties,
payload = > message,.
msgid = > message_handle);
DBMS_OUTPUT. Put_line (' subject: ' | message.subject);
DBMS_OUTPUT. Put_line (' text: ' | message.text);
COMMIT;
END;
But I found this code would go along and not finished.
Please tell me is it a mistake I made and what is the right way to remove it from the queue in this situation?
Thank you!

Hello

Subscriber: sys.aq = $_agent ('sender', '[email protected]', NULL);

should be

Subscriber: sys.aq = $_agent ("ability to use ', '[email protected]', NULL");

With your code enqueue the message is communicated to subscribers by default. In its current form the message will be propagated to the target queue and made available to the sender of the consumer.

So, if you change your code dequeue for

dequeue_options.consumer_name: = 'SENDER ';

It will consume the message that has been propagated.

Thank you
Peter

Tags: Database

Similar Questions

Maybe you are looking for

  • Can you recommend an external case for hard drive of my iMac?

    My old A1312 27 "iMac died, but I think the hard drive is good. I want to take it out and use it as an external drive. I don't know what the case of to put in, there is an amazing range of options. Any help would be greatly appreciated. Thank you.

  • Intel RST does not

    Pavilion dv5t-2100 CTO Windows 7 64 bit.  Apparently the fix requires correct download software/driver for chipset intel.  Problem is how to identify the chipset.  Intel does not provide any utility for the chipset for W7 64-bit ID!  Catch 22?  What

  • corrupted Windows mail store error message, cannot delete messages

    Windows Mail has been send me errors when I first open it and now will not let me delete some messages... It is said that he is recovering from... then a box pops up saying that the message store was damaged by an external application to Windows Mail

  • I had 3 BSOD relate to the windows kernel.

    Original title: BSOD (s) I had three BSOD on this installation of current w7 and all three of them are different.  According to bluescreenviewer, they relate to the windows kernel and a few others. (1) ntoskrnl.exe + 6f880 (03/09/2013) (2) fltmgr.sys

  • IOM works on jrockit - jdk1.6.0_45 - R28.2.7 - 4.1.0 - ssl_error_no_cypher_overlap

    HelloWe have IOM works on jrockit - jdk1.6.0_45 - R28.2.7 - 4.1.0when trying to connect to http://Server:14000 / identity -it works wellWhen you try to connect tos-http: //server:14001/identitywith the latest version of FirefoxWe get error"no common