1

我有一个 Oracle AQ(定义如下)

BEGIN
        dbms_aqadm.create_queue_table(queue_table => 'MY_QUEUE',multiple_consumers => FALSE,queue_payload_type => 'MY_OBJECT');
        dbms_aqadm.create_queue(queue_name  => 'MY_QUEUE',queue_table => 'MY_QUEUE');
        dbms_aqadm.start_queue(queue_name => 'MY_QUEUE');
END;

另外,我有两个不同的 Java 进程在监听这个队列。尽管我的队列是使用multiple_consumers=false属性创建的,但我有时观察到两个 Java 进程都使用了相同的消息。此外,我在每个流程中的 JMS 消费者都在CLIENT_ACKNOWLEDGE模式下工作。

oracle AQ 中是否有任何错误?还是我错过了什么?

4

0 回答 0