1
Download Oracle Streams Advanced Queuing User's Guide and Reference
Transcript
Creating a QueueReceiver for Oracle Object Type Messages CustomDatum support will be deprecated in a future release. Use ORADataFactory payload factories instead. Note: Example 13–15 Creating a QueueBrowser for AdtMessages, Locking Messages /* Create a browser for a Queue with AdtMessage messagess of type EMPLOYEE* in lock mode/ QueueSession jms_session QueueBrowser browser; Queue test_queue; browser = ((AQjmsSession)jms_session).createBrowser(test_queue, null, Employee.getFactory(), true); Creating a QueueReceiver for Standard JMS Type Messages public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue, java.lang.String messageSelector) throws JMSException This method creates a QueueReceiver for queues of standard JMS type messages. It has the following parameters: Parameter Description queue Queue to access messageSelector Only messages with properties matching the messageSelector expression are delivered See Also: "MessageSelector" on page 11-17 Example 13–16 Creating a QueueReceiver Without a Selector /* Create a receiver without a selector */ QueueSession jms_session QueueReceiver receiver; Queue queue; receiver = jms_session.createReceiver(queue); Example 13–17 Creating a QueueReceiver With a Specified Selector /* Create a receiver for queues with a specified selector */ QueueSession jms_session; QueueReceiver receiver; Queue queue; /* create Receiver to receive messages with correlationID starting with EXP */ browser = jms_session.createReceiver(queue, "JMSCorrelationID LIKE 'EXP%'"); Creating a QueueReceiver for Oracle Object Type Messages public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue, java.lang.String messageSelector, java.lang.Object payload_factory) throws JMSException Oracle JMS Point-to-Point 13-9
