问题标签 [oracle-aq]

我知道调用 connection.dequeue(queueNam, arg, arg) 会监听一个队列。有没有办法检查队列是否为空，或者查看队列中的对象数量？

我知道这gv$aq是一个系统范围的视图，其中包含数据库中所有队列中处于不同状态的消息数量。

我的问题是：由于gv$aq与任何给定的数据相比，它将包含更多的数据queue_table，因此查询此视图以获取特定信息（消息数量等）将比直接查询自身queue_table花费更多的时间。queue_table为什么我们应该更好地查询gv$aq而不是队列表本身，有什么具体原因吗？

谢谢！

关于 Spring 中 OracleAQ 的以下配置

这里的问题是，尽管我们没有订阅 LUKAS34（但我们有其他 - LUKAS）以上配置导致来自 AQ_TS_MY_TEST 的所有消息都被读取。

我希望如果我定义subscription="LUKAS"此订阅的所有消息都会被读取，否则不会被读取。

上面的配置有什么问题？

此外，我在表中看到：

有许多条目，例如“TSUB_1_*”，在我看来，spring 配置“创建”新的消费者，并且配置中的名称“LUKAS”被跳过。

好的...我修改了一些春季课程（这不是解决方案，但它显示了问题出在哪里...）。我们来看看私有方法... org.springframework.jms.listener.DefaultMessageListenerContainer#initResourcesIfNecessary

如果我在这里更改（在此方法中，消费者名称从随机生成（我想是由 spring 随机生成）更改为我的固定名称“LUKAS”，一切都按我的预期工作 - 我的听众只读取那些在 PL/SQL 端定义的消息消费者“卢卡斯”。

所以问题是我是否可以在 spring jms:listener configuration consumer name 中以某种方式设置？

我正在使用以下配置来处理带有 adt 有效负载的 OracleAQ ...

问题是，在出队之后，我得到了具有 INTEGER 的字段的 java 端 null 值和其他字段的非 null 值。

在队列表中，这些值作为非空值存在。

可能是什么原因。我预计映射不好，但我看不出有什么问题。这些字段映射为 Types.INTEGER。

你知道可能是什么原因吗？

是否可以在春季定义的 jms 容器中创建多个侦听器（针对不同的主题）？

假设以下配置...

和

jmsContainer 中是否可以有多个 messageListener*？

如果是...这样做是好的模式还是使用尽可能多的容器作为您需要的侦听器更好？

我遵循了 spring 文档并设置了一个 Spring JMS 侦听器。然而，即使我向队列中添加了一条消息，我的代码也没有检测到这一点。我的弹簧配置如下：

我的Java如下：

我的自定义监听器：

还有我的 OracleAqFactoryBean：

[编辑：上述设置现已成功运行]

我将 Grails JMS 插件安装到我的应用程序中，但没有收到任何消息。我的配置如下：

在资源.groovy

在 config.groovy

在我的 Grails 服务中：

在 Datasource.groovy 中

我们在标准 Java 应用程序中使用标准 Spring 配置连接到工作队列，但是如果在 Grails 应用程序中导入该 Spring 配置，则该配置不起作用，这就是我们尝试使用 jms 插件的原因。

有人有使用 JMeter 和 Oracle AQ 的经验吗？我正在尝试使用 JMS Publisher 将消息发布到 Oracle AQ 队列，但我拥有的唯一信息来自绑定文件。

我正在使用带有 java JMS API 的高级队列 (AQ) 的 oracle 数据库 [11.2]。我当前的 oracle 设置是默认设置，没有额外的调整参数。高层架构：

数据库将消息排入持久队列（按优先级排序）

Java JMS 消费者是具有 3 个并发线程的出列消息。

一切都很好！和快乐的场景，只要队列中的消息@10K。一旦队列中的消息增加一倍或三倍，出队性能就会显着下降！！！。

我按照以下链接 http://docs.oracle.com/cd/B28359_01/server.111/b28420/perform.htm

关于 IO 和 AQ 的性能调整有什么建议吗？

AQ$_MESSAGES_EXCEPTION首先我知道有这个问题：How to clear a queue in Oracle AQ但它没有答案。

我在 Oracle AQ 的异常队列中有很多消息（500k）（我不知道过期消息被移动到另一个队列，所以我没有为这些消息创建消费者）。我现在需要的是能够快速删除这些消息。我读过通过删除清除队列表不是一个好主意，因为它可能导致不一致的状态。所以我整理了以下程序，但它每秒只能清除大约 50 条消息

/

考虑到它在数据库机器上运行，它似乎真的很慢。对于 500k 条消息，此过程大约需要三个小时。我可以用更有效的方式来做吗？

编辑：

我从这里的链接尝试了 dequeue_array：http ://www.oracle-developer.net/display.php?id=319 但我无法创建表，所以我试图创建一个数组来“存储”结果。这是我所拥有的：

我收到此错误：

我认为问题出在消息数组中，但我不知道该怎么做才能使其工作。另外，根据 oracle 文档（http://docs.oracle.com/cd/B19306_01/appdev.102/b14258/d_aq.htm#i1000850），应该还有另一个参数：

但是这个参数的解释是“目前没有实现”。这是什么意思？可以不放吗？它应该设置为null吗？这真的很令人困惑，谷歌在这里没有帮助:(