0

我有一个连接到 Oracle AQ 多消费者队列的客户端应用程序。我想使用 OracleAQQueue.Listen 来监听队列中的新消息。 API 文档显示 Listen 方法可用于多消费者队列。我的监听队列代码如下所示。 

string consumerName = "APPINST1";            
using (OracleConnection con = new OracleConnection(connectionString))
{
    con.Open();

    OracleAQQueue queue = new OracleAQQueue("MY_Q");
    queue.MessageType = OracleAQMessageType.Udt;
    queue.UdtTypeName = "MY_Q_MSG";
    queue.DequeueOptions.DeliveryMode = OracleAQMessageDeliveryMode.Persistent;
    queue.Connection = con;

    Console.WriteLine("Listening for messages...");
    queue.Listen(new string[] { consumerName });
}

我遇到的问题是在我调用 queue.Listen() 的代码行上，我得到了 Oracle 异常：

ORA-25295: Subscriber is not allowed to dequeue buffered messages

谷歌搜索有关此特定错误的建议并没有太大帮助。我已经多次将我的订阅者删除并重新添加到队列中，但均无济于事。我的猜测是在调用 Listen 之前我没有正确设置某些属性，但我无法弄清楚问题所在。

有任何想法吗？

4

1 回答 1

0

我在 Streams Advanced Queuing User's Guide 的第 10 章 - Oracle Streams AQ Operations Using PL/SQL中遇到了以下注释：

Note: Listening to multiconsumer queues is not supported in the Java API.

虽然我在任何地方都找不到明确说明，但我猜同样的规则也适用于 ODP.NET API。

于 2016-09-07T13:45:49.207 回答