Home » SQL & PL/SQL » SQL & PL/SQL » Oracle Queues (10.2)
Oracle Queues [message #381249] Fri, 16 January 2009 00:38 Go to next message
psrinuind
Messages: 4
Registered: September 2008
Junior Member

Hi All,

We have a scenario that one process writes messages(records) into Oracle queues and other process read that messages from the queue and do some business processing.

Is there anyway to limit the number of records per message that is being written into the Queue?

Regards,
psrinuind
Re: Oracle Queues [message #381261 is a reply to message #381249] Fri, 16 January 2009 00:53 Go to previous messageGo to next message
Frank
Messages: 7880
Registered: March 2000
Senior Member
YOU have the program that is writing the messages, so you have control over when to write a message!
Re: Oracle Queues [message #381281 is a reply to message #381261] Fri, 16 January 2009 02:26 Go to previous messageGo to next message
psrinuind
Messages: 4
Registered: September 2008
Junior Member
Thanks for the reply Frank,

We have control but let us say queue message has 1000 records, and my commit is 100rec. If I got error after commiting 100rec, what about 900recs because I have deQueued, I can not en-Queue because another process or subscrib on this queue. And also I can not only read from the queue because my process supporing parllel process, there is a chance to read same message by two processes.
Re: Oracle Queues [message #381314 is a reply to message #381281] Fri, 16 January 2009 05:23 Go to previous message
Frank
Messages: 7880
Registered: March 2000
Senior Member
I fail to see what your commit-size has to do with the number of records in the message.
After all, you would typically get the message as a whole and store the contents somewhere in a PL/SQL variable.
This variable will not change due to you committing.
So, please show us with some code (or snippets of code) what you mean.
Previous Topic: How can i get recent commit scn?
Next Topic: CAST VARRAY TO CURSOR
Goto Forum:
  


Current Time: Sat Dec 10 05:12:15 CST 2016

Total time taken to generate the page: 0.08146 seconds