sachin-handiekar

declare 
  queue_options DBMS_AQ.DEQUEUE_OPTIONS_T;
  message_properties DBMS_AQ.MESSAGE_PROPERTIES_T;
  message_id RAW(2000);
  my_message SYS.AQ$_JMS_TEXT_MESSAGE;
  msg_text varchar2(32767);
begin
  DBMS_AQ.DEQUEUE(
    queue_name => 'my_queue',
    dequeue_options => queue_options,

sachin-handiekar

/* 
* 10137    The Trip 
*/

#include <iostream> 

using namespace std;
int main()
{
    int no_of_trips;

sachin-handiekar

/* * Operator 4 : Bitwise Operators. */ 
#include "iostream" 
#define PRINT(int) printf("%d\n",int) 

using namespace std;

int main()
{
    int x,y,z;
    x = 03, y = 02, z= 01;

sachin-handiekar

/* * Operator 3 : Logic and Increment Operators. */ 
#include "iostream" 
#define PRINT(int) printf("%d\n",int)

using namespace std;

int main()
{
    int x,y,z;
    x = 2;

sachin-handiekar

import org.xml.sax.InputSource;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;

import javax.xml.transform.OutputKeys;
import javax.xml.transform.Source;
import javax.xml.transform.Transformer;
import javax.xml.transform.sax.SAXSource;
import javax.xml.transform.sax.SAXTransformerFactory;

sachin-handiekar

BEGIN
  DBMS_AQADM.CREATE_QUEUE_TABLE( Queue_table => 'QT_SAMPLE', Queue_payload_type => 'SYS.XMLTYPE', Sort_list => 'ENQ_TIME', COMMENT => 'A sample queue table');
END;

sachin-handiekar

BEGIN
  DBMS_AQADM.CREATE_QUEUE( Queue_name => 'Q_SAMPLE', Queue_table => 'QT_SAMPLE', Queue_type => 0, Max_retries => 5, Retry_delay => 10);
END;

sachin-handiekar

package com.sachinhandiekar.oracle.aq;

import javax.jms.ConnectionFactory;
import javax.sql.DataSource;

public class OracleAQQueueConnectionFactory {

	private DataSource dataSource;

	public ConnectionFactory createConnectionFactory() throws Exception {

sachin-handiekar

package com.sachinhandiekar.oracle.aq;

import org.springframework.beans.factory.FactoryBean;
import oracle.jms.AQjmsSession;

import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.Session;

sachin-handiekar

package com.sachinhandiekar.oracle.aq;

import javax.jms.Message;
import javax.jms.MessageListener;

import org.springframework.transaction.annotation.Transactional;

import oracle.jms.AQjmsAdtMessage;
import oracle.xdb.XMLType;