Package javax.jms

Examples of javax.jms.QueueConnection


    }
    LuceneWorkSerializer serializer = indexManager.getSerializer();
    byte[] data = serializer.toSerializedModel( filteredQueue );
    QueueSender sender;
    QueueSession session;
    QueueConnection connection;
    try {
      connection = processor.getJMSConnection();
      //TODO make transacted parameterized
      session = connection.createQueueSession( false, QueueSession.AUTO_ACKNOWLEDGE );
      ObjectMessage message = session.createObjectMessage();
      message.setObject( data );
      message.setStringProperty( Environment.INDEX_NAME_JMS_PROPERTY, indexName );

      sender = session.createSender( processor.getJmsQueue() );
View Full Code Here


     *
     */
    @Test
    public void createQueueConnection()
    {
        QueueConnection queueConnection = null;
        Session session = null;
        System.out.println("Building our own db connection");
        try {
            DataSource ds = AQUtil.getSQLDataSource(server, instance, port, driver, user, password);
            QueueConnectionFactory queueFactory = AQjmsFactory.getQueueConnectionFactory(ds);
            queueConnection = queueFactory.createQueueConnection();
            assertNotNull(queueConnection);
            session = (AQjmsSession) queueConnection.createQueueSession(false,
                    Session.AUTO_ACKNOWLEDGE);
            assertNotNull(session);
        } catch (Throwable e) {
            e.printStackTrace();
            assertTrue(false);
        } finally {
            if (session!=null) {
                try { session.close();
                } catch (Exception e) {}
            }
            if (queueConnection!=null) {
                try { queueConnection.close();
                } catch (Exception e) {}
            }
        }
    }
View Full Code Here

     */
    @Test
    public void findGivenQueue()
    {
        boolean foundQueue=false;
        QueueConnection queueConnection = null;
        Session session = null;
        System.out.println("Building our own db connection");
        try {
            DataSource ds = AQUtil.getSQLDataSource(server, instance, port, driver, user, password);
            QueueConnectionFactory queueFactory = AQjmsFactory.getQueueConnectionFactory(ds);
            queueConnection = queueFactory.createQueueConnection();
            assertNotNull(queueConnection);
            session = (AQjmsSession) queueConnection.createQueueSession(false,
                    Session.AUTO_ACKNOWLEDGE);
            assertNotNull(session);
           
            List<DestinationInfo> list = AQUtil.getDestinationInfoList(ds, schema);
            // for each queue
            Iterator<DestinationInfo> iter = list.iterator();
            while (iter.hasNext()) {
                DestinationInfo di = iter.next();
                System.out.println("Found Destination: " + di.getQueueName());
                // register normal queue
                if (di.getQueueName().equalsIgnoreCase(qName)) {
                    System.out.println("Matched up given Queue: " + qName + " with " + di.getQueueName());
                    foundQueue=true;
                }
            }
            assertTrue(foundQueue);
           
        } catch (Throwable e) {
            e.printStackTrace();
            assertTrue(false);
        } finally {
            if (session!=null) {
                try { session.close();
                } catch (Exception e) {}
            }
            if (queueConnection!=null) {
                try { queueConnection.close();
                } catch (Exception e) {}
            }
        }
    }
View Full Code Here

    /**
     * Sends a message to the specified Q in Oracle and receives the same message.
     */
    public void drainQueue()
    {
        QueueConnection connection = null;
        QueueSession session = null;
        MessageConsumer messageConsumer = null;
        try {
            Hashtable<String,String> env = new Hashtable<String, String>();
            env.put(AQInitialContextFactory.DB_SERVER, server);
            env.put(AQInitialContextFactory.DB_INSTANCE, instance);
            env.put(AQInitialContextFactory.DB_PORT, portStr);
            env.put(AQInitialContextFactory.DB_USER, user);
            env.put(AQInitialContextFactory.DB_PASSWD, password);
            env.put(AQInitialContextFactory.DB_SCHEMA, schema);
            env.put(AQInitialContextFactory.DB_DRIVER, driver);
           
            MockContextFactory.setAsInitial();
            AQInitialContextFactory factory = new AQInitialContextFactory();
            Context context = factory.getInitialContext(env);
            QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory)
                context.lookup(AQInitialContextFactory.QUEUE_CONNECTION_FACTORY);
            connection = queueConnectionFactory.createQueueConnection();
            session = connection.createQueueSession(false,
            QueueSession.AUTO_ACKNOWLEDGE);
            Queue queue = (Queue) context.lookup(qName);
            messageConsumer = session.createReceiver(queue);
            connection.start();
            TextMessage receiveMessage = session.createTextMessage(MESSAGE_CONTENT);
            while (receiveMessage!=null) {
                receiveMessage = (TextMessage) messageConsumer.receive(10);
                if (receiveMessage!=null) System.out.println("Drain:" + receiveMessage.getText());
            }  
        } catch (Exception e) {
            e.printStackTrace();
            assertTrue(false);
        } finally {
            if (messageConsumer!=null) {
                try messageConsumer.close();
                } catch (Exception e) {}
            }
            if (session!=null) {
                try { session.close();
                } catch (Exception e) {}
            }
            if (connection!=null) {
                try { connection.close();
                } catch (Exception e) {}
            }
        }
    }
View Full Code Here

     */
    @Test
    public void sendAndReceiveMessage()
    {
        drainQueue();
        QueueConnection connection = null;
        QueueSession session = null;
        MessageProducer messageProducer = null;
        MessageConsumer messageConsumer = null;
        try {
            Properties properties = new Properties();
            properties.put(Context.INITIAL_CONTEXT_FACTORY, "org.jboss.soa.esb.oracle.aq.AQInitialContextFactory");
            properties.put(AQInitialContextFactory.DB_SERVER, server);
            properties.put(AQInitialContextFactory.DB_INSTANCE, instance);
            properties.put(AQInitialContextFactory.DB_PORT, portStr);
            properties.put(AQInitialContextFactory.DB_USER, user);
            properties.put(AQInitialContextFactory.DB_PASSWD, password);
            properties.put(AQInitialContextFactory.DB_SCHEMA, schema);
            properties.put(AQInitialContextFactory.DB_DRIVER, driver);
            MockContextFactory.setAsInitial();
            Context context = new InitialContext(properties);
            QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory)
                context.lookup(AQInitialContextFactory.QUEUE_CONNECTION_FACTORY);
            connection = queueConnectionFactory.createQueueConnection();
            session = connection.createQueueSession(false,
            QueueSession.AUTO_ACKNOWLEDGE);
            Queue queue = (Queue) context.lookup(qName);
            messageProducer = session.createSender(queue);
            messageConsumer = session.createReceiver(queue);
            connection.start();
            TextMessage sendMessage = session.createTextMessage(MESSAGE_CONTENT);
            messageProducer.send(sendMessage);
            TextMessage receiveMessage = (TextMessage) messageConsumer.receive(2000);
            String receiveContent = receiveMessage.getText();
            assertEquals(MESSAGE_CONTENT, receiveContent);
           
        } catch (Exception e) {
            e.printStackTrace();
            assertTrue(false);
        } finally {
            if (messageProducer!=null) {
                try messageProducer.close();
                } catch (Exception e) {}
            }
            if (messageConsumer!=null) {
                try messageConsumer.close();
                } catch (Exception e) {}
            }
            if (session!=null) {
                try { session.close();
                } catch (Exception e) {}
            }
            if (connection!=null) {
                try { connection.close();
                } catch (Exception e) {}
            }
        }
    }
View Full Code Here

     *
     */
    @Test
    public void createQueueConnection()
    {
        QueueConnection queueConnection = null;
        Session session = null;
        System.out.println("Building our own db connection");
        try {
            DataSource ds = AQUtil.getSQLDataSource(server, instance, port, driver, user, password);
            QueueConnectionFactory queueFactory = AQjmsFactory.getQueueConnectionFactory(ds);
            queueConnection = queueFactory.createQueueConnection();
            assertNotNull(queueConnection);
            session = (AQjmsSession) queueConnection.createQueueSession(false,
                    Session.AUTO_ACKNOWLEDGE);
            assertNotNull(session);
        } catch (Throwable e) {
            e.printStackTrace();
            assertTrue(false);
        } finally {
            if (session!=null) {
                try { session.close();
                } catch (Exception e) {}
            }
            if (queueConnection!=null) {
                try { queueConnection.close();
                } catch (Exception e) {}
            }
        }
    }
View Full Code Here

     */
    @Test
    public void findGivenQueue()
    {
        boolean foundQueue=false;
        QueueConnection queueConnection = null;
        Session session = null;
        System.out.println("Building our own db connection");
        try {
            DataSource ds = AQUtil.getSQLDataSource(server, instance, port, driver, user, password);
            QueueConnectionFactory queueFactory = AQjmsFactory.getQueueConnectionFactory(ds);
            queueConnection = queueFactory.createQueueConnection();
            assertNotNull(queueConnection);
            session = (AQjmsSession) queueConnection.createQueueSession(false,
                    Session.AUTO_ACKNOWLEDGE);
            assertNotNull(session);
           
            List<DestinationInfo> list = AQUtil.getDestinationInfoList(ds, schema);
            // for each queue
            Iterator<DestinationInfo> iter = list.iterator();
            while (iter.hasNext()) {
                DestinationInfo di = iter.next();
                System.out.println("Found Destination: " + di.getQueueName());
                // register normal queue
                if (di.getQueueName().equalsIgnoreCase(qName)) {
                    System.out.println("Matched up given Queue: " + qName + " with " + di.getQueueName());
                    foundQueue=true;
                }
            }
            assertTrue(foundQueue);
           
        } catch (Throwable e) {
            e.printStackTrace();
            assertTrue(false);
        } finally {
            if (session!=null) {
                try { session.close();
                } catch (Exception e) {}
            }
            if (queueConnection!=null) {
                try { queueConnection.close();
                } catch (Exception e) {}
            }
        }
    }
View Full Code Here

    /**
     * Sends a message to the specified Q in Oracle and receives the same message.
     */
    public void drainQueue()
    {
        QueueConnection connection = null;
        QueueSession session = null;
        MessageConsumer messageConsumer = null;
        try {
            Hashtable<String,String> env = new Hashtable<String, String>();
            env.put(AQInitialContextFactory.DB_SERVER, server);
            env.put(AQInitialContextFactory.DB_INSTANCE, instance);
            env.put(AQInitialContextFactory.DB_PORT, portStr);
            env.put(AQInitialContextFactory.DB_USER, user);
            env.put(AQInitialContextFactory.DB_PASSWD, password);
            env.put(AQInitialContextFactory.DB_SCHEMA, schema);
            env.put(AQInitialContextFactory.DB_DRIVER, driver);
            MockContextFactory.setAsInitial();
            AQInitialContextFactory factory = new AQInitialContextFactory();
            Context context = factory.getInitialContext(env);
            XAQueueConnectionFactory queueConnectionFactory = (XAQueueConnectionFactory)
                context.lookup(AQInitialContextFactory.XA_QUEUE_CONNECTION_FACTORY);
            connection = queueConnectionFactory.createXAQueueConnection();
            session = connection.createQueueSession(false,
            QueueSession.AUTO_ACKNOWLEDGE);
            Queue queue = (Queue) context.lookup(qName);
            messageConsumer = session.createReceiver(queue);
            connection.start();
            TextMessage receiveMessage = session.createTextMessage(MESSAGE_CONTENT);
            while (receiveMessage!=null) {
                receiveMessage = (TextMessage) messageConsumer.receive(10);
                if (receiveMessage!=null) System.out.println("Drain:" + receiveMessage.getText());
            }  
        } catch (Exception e) {
            e.printStackTrace();
            assertTrue(false);
        } finally {
            if (messageConsumer!=null) {
                try messageConsumer.close();
                } catch (Exception e) {}
            }
            if (session!=null) {
                try { session.close();
                } catch (Exception e) {}
            }
            if (connection!=null) {
                try { connection.close();
                } catch (Exception e) {}
            }
        }
    }
View Full Code Here

     */
    @Test
    public void sendAndReceiveMessage()
    {
        drainQueue();
        QueueConnection connection = null;
        QueueSession session = null;
        MessageProducer messageProducer = null;
        MessageConsumer messageConsumer = null;
        try {
            Properties properties = new Properties();
            properties.put(Context.INITIAL_CONTEXT_FACTORY, "org.jboss.soa.esb.oracle.aq.AQInitialContextFactory");
            properties.put(AQInitialContextFactory.DB_SERVER, server);
            properties.put(AQInitialContextFactory.DB_INSTANCE, instance);
            properties.put(AQInitialContextFactory.DB_PORT, portStr);
            properties.put(AQInitialContextFactory.DB_USER, user);
            properties.put(AQInitialContextFactory.DB_PASSWD, password);
            properties.put(AQInitialContextFactory.DB_SCHEMA, schema);
            properties.put(AQInitialContextFactory.DB_DRIVER, driver);
            MockContextFactory.setAsInitial();
            Context context = new InitialContext(properties);
            XAQueueConnectionFactory xaQueueConnectionFactory = (XAQueueConnectionFactory)
                context.lookup(AQInitialContextFactory.XA_QUEUE_CONNECTION_FACTORY);
            connection = xaQueueConnectionFactory.createXAQueueConnection();
            session = connection.createQueueSession(false,
            QueueSession.AUTO_ACKNOWLEDGE);
            Queue queue = (Queue) context.lookup(qName);
            messageProducer = session.createSender(queue);
            messageConsumer = session.createReceiver(queue);
            connection.start();
            TextMessage sendMessage = session.createTextMessage(MESSAGE_CONTENT);
            messageProducer.send(sendMessage);
            TextMessage receiveMessage = (TextMessage) messageConsumer.receive(2000);
            String receiveContent = receiveMessage.getText();
            assertEquals(MESSAGE_CONTENT, receiveContent);
           
        } catch (Exception e) {
            e.printStackTrace();
            assertTrue(false);
        } finally {
            if (messageProducer!=null) {
                try messageProducer.close();
                } catch (Exception e) {}
            }
            if (messageConsumer!=null) {
                try messageConsumer.close();
                } catch (Exception e) {}
            }
            if (session!=null) {
                try { session.close();
                } catch (Exception e) {}
            }
            if (connection!=null) {
                try { connection.close();
                } catch (Exception e) {}
            }
        }
    }
View Full Code Here

                    return connections.get(JMSType.QUEUE);
                }
                else
                {
                    QueueConnectionFactory ccf = (QueueConnectionFactory) createOrReturnConnectionFactory();
                    QueueConnection qc = ccf.createQueueConnection();
                    connections.put(JMSType.QUEUE, qc);

                    return qc;
                }
            }
View Full Code Here

TOP

Related Classes of javax.jms.QueueConnection

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.