oracle-aq

    0热度

    1回答

    我有一个使用Oracle AQ处理信息的应用程序。消息是基于数据库中的记录创建的。应用程序加载要处理的消息并将其安排在内存中供以后使用。应用程序是群集的,因为我有三个问题: 假设消息中有一个变量(值不是常量)。基于此,如果有一个节点处理带有所述变量的消息,则只有该节点应该处理具有相同变量值的消息。 启动群集节点时,应该加载所有准备好要处理的记录(消息),但不应加载已加载并处理且尚未处理(已计划)的

    1热度

    1回答

    我必须使用什么命令来停止或启动Oracle AQ队列? 我需要停止队列以执行维护和分析,并且稍后在分析完成后启动队列。

    2热度

    1回答

    我希望删除一个Oracle AQ队列和与之关联的表。 执行此操作所需的命令是什么?

    1热度

    1回答

    您好我有一个模式的预言队列即AQS 样本队列 BEGIN DBMS_AQADM.CREATE_QUEUE( Queue_name => 'AQS.MOb_MSG', Queue_table => 'AQS.MOb_QT', Queue_type => 0, Max_retries => 5, Retry_delay => 0,

    0热度

    2回答

    我的项目使用hibernate连接到数据库,从JBoss上的连接池获取连接。我想用队列中的发布/消耗替换一些读/写表。我内置使用OracleAQ工作的例子,但是,我连接到数据库使用: AQjmsFactory.getQueueConnectionFactory其次createQueueConnection, 然后使用createQueueSession得到(JMS)QueueSession上,我可

    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热度

    1回答

    oracle.AQ和oracle.jdbc.aq(https://docs.oracle.com/cd/E11882_01/appdev.112/e13995/oracle/jdbc/aq/package-summary.html,https://docs.oracle.com/cd/E16338_01/appdev.112/e13995/overview-summary.html)和有什么不一样

    0热度

    1回答

    我从Oracle AQ队列使用JMS连接器在接收骡消息,但消息类型为oracle.jms.AQjmsAdtMessage。如何访问骡流中的有效载荷。

    2热度

    1回答

    我有Jboss eap 6.3和Hornetq队列的应用程序工作。我必须将队列从hornetq改为OracleAQ。是否有任何准备好的资源适配器连接它,或者我必须自己写一个新的?我会很乐意提供任何提示,我该如何实现这一点。提前致谢。

    2热度

    2回答

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