advanced-queuing

    0热度

    1回答

    我们有一个Oracle 12c AQ,其UDT有效内容包含一个XMLType属性。我们可以创建一个通知程序,当XMLType属性匹配某些条件时触发? 我还没有看到这个在线任何例子。 edit => 只有在负载的xml部分符合某些条件的情况下才会收到有关新消息的通知。例如: DECLARE subscriber sys.aq$_agent; begin subscriber := sys

    0热度

    2回答

    我们开始使用oracle AQ和spring-jms,它工作正常。但是,当1000〜去的消息,虽然我的队列BUS_BILLING_RECEIVE_QT有110000个选择我下面写道: select /*+ INDEX(TAB AQ$_BUS_BILLING_RECEIVE_QT_I) */ tab.rowid, tab.msgid, tab.corrid, tab.priority, tab.de

    1热度

    1回答

    我们试图在.NET 4.7中使用Oracle AQ为我们的应用程序构建排队系统。 基本上,我们的问题是我们想要将包含其他指令的上层事务中的出队过程包装起来,并且能够在执行queue.Dequeue()指令后“手动”提交或回滚。 到目前为止,这仅适用于入列: using (var tr = con.BeginTransaction()) { try { enqMsg

    7热度

    2回答

    我学习的春天引导和JMS例子,是的,我在这头 由于我们与甲骨文合作,而新的,我想迁移从ActiveMQ到Oracle高级队列的Spring Boot & JMS示例。不过,我真的很少发现这方面的信息。 据我所知,我需要替换下面的代码为Oracle版本,但我没有设法找出如何。 @Bean public JmsListenerContainerFactory<?> myFactory(Connect

    0热度

    2回答

    我已经找到了如何使用AQ(Streams?)包创建Oracle数据库。我还在Oracle中创建了一些队列(手工)。 (使用PL/SQL和SQL)。 但是,我很难与Spring建立正确的连接。 下工作(使用oracle.AQ Java包): private final String aqUrl = "jdbc:oracle:thin:@localhost:1521:orcl"; private f

    0热度

    2回答

    我试图从Oracle队列中出队消息,并且无法设置dequeue_options。我试图将ENQ_TIME大于输入值(时间戳)的消息出列。 我设法将参数或通过msgid或enq_tid退出邮件。 我用 dequeue_options.deq_condition := 'tab.enq_tid = ''' || i_enq_tid || '''' 这就是工作。 当我尝试与enq_time做同样的处

    2热度

    1回答

    我将最初为Oracle Application Server编写的旧Java应用程序迁移到Oracle融合中间件中的WebLogic 10.3.6。该应用程序使用Oracle Advanced Queue/JMS功能。 AQ已经配置在数据库中。现在,应用程序在运行的WebLogic当我到达AQ代码,我看到这个错误: java.lang.UnsupportedOperationException:

    1热度

    1回答

    似乎需要一些帮助。我试图根据下面的脚本基于对象类型构建一些队列表; ... GRANT EXECUTE ON dbms_aq TO sch_utl / GRANT EXECUTE ON dbms_aqadm TO sch_utl / GRANT aq_administrator_role TO sch_utl / BEGIN DBMS_AQADM.GRANT_SYSTEM_PRI

    2热度

    2回答

    我需要通过MDB将Oracle高级队列(ADQ)中的消息出队。 MDB部署在Weblogic 11上。我可以为ADQ定义一个外部服务器(official oracle doc)。 的qustion是: 会发生什么如果有效载荷不是JMS类型 例如 queue_payload_type=>'sys.aq$_jms_text_message' 但是是一种自定义类型? Weblogic如何重新映射它?

    2热度

    2回答

    我们拥有基于Oracle AQ的消息传递系统 - 它运行良好,入队和出队没有任何问题。 现在我们得到了一个请求,在启动之前和运行时添加一些完整性检查,例如“检查提供的db用户是否真的存在队列”和“定期检查队列中的消息数量”。 后者似乎相当容易解决,查找queuetable,计数的消息数,但第一个怪异的我。 通过文档和DatabaseMetaData可用的方法,我没有看到一种方法来实际检查这一点,而