advanced-queuing

Integrating Perl and Oracle Advanced Queuing

Is there any way to listen to an Oracle AQ using a Perl process as the listener. ...

Oracle Advanced Queuing - Queue Propagation

EDIT: It seems to be something with having the two queues in the same schema. I’m trying to experiment with queue propagation but I’m not seeing records in the destination queue. But that could easily be because I don’t have all the pieces in place. Does anyone have a test case they could post? I’ll include what I tried below. I found ...

An example for using DBMS_AQ.POST and explanation of its utility

The DBMS_AQ package has a method called POST. The documentation says, This procedure posts to a list of anonymous subscriptions, allowing all clients who are registered for the subscriptions to get notifications of persistent messages. This feature is not supported with buffered messages. and This call provides a be...

What is the difference between Oracle Streams and Change Data Capture?

There are several similar Oracle tecnologies - Oracle Streams, Oracle Change Data Capture and Database Change Notification. Do you know what is difference between those? Are they related or Oracle Advanced Queueing? ...

Can you dequeue over a DBLink?

I'm trying to dequeue from a queue on another server. I can't use propagation to get it to the server that needs the data. If I put a dblink in the name of the queue in the dequeue options I get an error. Error at line 9 ORA-25200: invalid value prim_queues.prim_trade_q@prim_dbln, QUEUE_NAME should be [SCHEMA.]NAME ORA-06512: at "SYS....

Display contents of Oracle AQ SYS.AQ$_JMS_TEXT_MESSAGE

I have an application that uses JMS op top of Oracle advanced queuing. I would like to do a query on the queue table that shows the content of the message (which in my case is XML). So when I do a 'select user_data from [queue_table]' I get 'AQ SYS.AQ$_JMS_TEXT_MESSAGE' as a response. Is there a function so that the contents of this me...

PL/SQL function in Oracle cannot see DBMS_AQ

I have problem with Oracle 9.2 and JMS. I created PL/SQL routine to send XML text (from file or CLOB) to queue, but this routine do not compile. My code looks like (filling message omitted): create or replace procedure jms_test(msg varchar2) is id pls_integer; message sys.aq$_jms_stream_message; ...

Oracle: problem with constructing JMS message

After some struggle with Oracle Advanced Queuing and dbms_aq package I encountered another issue. I copied code from Oracle tutorials but when I compile this code: create or replace procedure jms_test(msg varchar2) is id pls_integer; message sys.aq$_jms_stream_message; enqueue_options dbms_aq.en...

Lookup structure for handling future events (time based)

Hi, I am looking for an efficient data structure, that'll allow me to cue events ... that is, i will be having an app, where at any time in execution, it is possible, that an event will be raised for a future point in execution ... something like: t=20: in 420 seconds, A occurs t=25: in 13 seconds, B occurs t=27: in 735 seconds, C occ...

Oracle AQ dequeue order

A trigger in an Oracle 10g generates upsert and delete messages for a subset of rows in a regular table. These messages consist out of two fields: A unique row id. A non-unique id. When consuming these message I want to impose an order on the deque process that respects the following constraints: Messages must be dequeued in insert...

Oracle AQ Java interface and custom message types

I am using the Oracle Java interface for AQ and want to dequeue messages. These messages consist out of two fields: A unique row id. A non-unique id. I successfully decoded messages using a single RAW payload like this: AQDequeueOption option = new AQDequeueOption(); option.setDequeueMode(AQDequeueOption.DEQUEUE_REMOVE); AQMessage ...

JBoss 5 EJB3 MDB & Oracle AQ?

Has anyone had any success getting MDBs to work with Oracle AQ? Using oracleaq.rar I was able to receive some messages from Oracle AQ, but it wasn't reliable and the authors urge not use it. ...

OC4J server DB persistence - queue message getting retrieved multiple times

Hello, Thanks for trying to help ... We are using oc4j server 10.1.3 and oracle 10g database and using database persistence for the the MDB (EJB 3.0) in the application we have 3 application servers and connected through the load balancer in the production enviornment As we are using database persistence the messages are sending ...

Does SQL Server have a feature similar to Oracle Streams Advanced Queuing?

Oracle Streams AQ (Advanced Queuing) provides highly scalable database-backed queuing functionality. Does an equivalent feature exist in SQL Server (any version)? Note: I do not mean simply using a table as a queue, but a specific vendor-provided enhancement to the database platform. ...

Selective dequeue of unrelated messages in Oracle Advanced Queueing

This question refers to the dequeueing of messages in Oracle Streams Advanced Queueing. I need to ensure that the messages which are related to each other are processed sequentially. For example, assume the queue is seeded with the four messages that have a business-related field called transaction reference (txn_ref) and two of the ...