Examples of org.apache.activemq.ActiveMQConnection.createSession()

Class org.apache.activemq.ActiveMQConnection

Examples of org.apache.activemq.ActiveMQConnection.createSession()

org.apache.activemq.ActiveMQConnection.createSession()
Creates a Session object. @param transacted indicates whether the session is transacted @param acknowledgeMode indicates whether the consumer or the client willacknowledge any messages it receives; ignored if the session is transacted. Legal values are Session.AUTO_ACKNOWLEDGE, Session.CLIENT_ACKNOWLEDGE, and Session.DUPS_OK_ACKNOWLEDGE. @return a newly created session @throws JMSException if the Connection object fails tocreate a session due to some internal error or lack of support for the specific transaction and acknowledgement mode. @see Session#AUTO_ACKNOWLEDGE @see Session#CLIENT_ACKNOWLEDGE @see Session#DUPS_OK_ACKNOWLEDGE @since 1.1

        ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("failover:(" + url + ")");
        cf.setConsumerFailoverRedeliveryWaitPeriod(10000);
        final ActiveMQConnection connection = (ActiveMQConnection) cf.createConnection();
        connection.start();


        final Session producerSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        final Queue destination = producerSession.createQueue(QUEUE_NAME);


        final Session consumerSession = connection.createSession(true, Session.SESSION_TRANSACTED);
        final MessageConsumer testConsumer = consumerSession.createConsumer(destination);
        assertNull("no message yet", testConsumer.receiveNoWait());

View Full Code Here

        connection.start();


        final Session producerSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        final Queue destination = producerSession.createQueue(QUEUE_NAME);


        final Session consumerSession = connection.createSession(true, Session.SESSION_TRANSACTED);
        final MessageConsumer testConsumer = consumerSession.createConsumer(destination);
        assertNull("no message yet", testConsumer.receiveNoWait());
        
        produceMessage(producerSession, destination, 1);
        producerSession.close();

View Full Code Here


    private Message receiveMessage(ActiveMQConnectionFactory cf,
            Queue destination) throws Exception {
        final ActiveMQConnection connection = (ActiveMQConnection) cf.createConnection();
        connection.start();
        final Session consumerSession = connection.createSession(true, Session.SESSION_TRANSACTED);
        final MessageConsumer consumer = consumerSession.createConsumer(destination);
        Message msg = consumer.receive(5000);
        consumerSession.commit();
        connection.close();
        return msg;

View Full Code Here

        // send message to dlq immediately
        RedeliveryPolicy policy = connection.getRedeliveryPolicy();
        policy.setMaximumRedeliveries(0);        
        connection.start();
        
        Session session = connection.createSession(true, Session.SESSION_TRANSACTED);
        ActiveMQQueue destination = new ActiveMQQueue("camelRedeliveryQ");
        MessageProducer producer = session.createProducer(destination);
        
        MessageConsumer consumer = session.createConsumer(destination);
        // Send the messages

View Full Code Here

            service.execute(new Runnable() {
                @Override
                public void run() {
                    try {
                        ActiveMQConnection connection = (ActiveMQConnection) cf.createConnection();
                        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
                        Destination destination = session.createTemporaryQueue();
                        session.createProducer(destination);
                        connection.close();
                        TimeUnit.MILLISECONDS.sleep(ripple.nextInt(20));
                    } catch (Exception e) {

View Full Code Here

            service.execute(new Runnable() {
                @Override
                public void run() {
                    try {
                        ActiveMQConnection connection = (ActiveMQConnection) cf.createConnection();
                        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
                        Destination destination = session.createTemporaryQueue();
                        MessageProducer producer = session.createProducer(destination);
                        producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
                        producer.setTimeToLive(400);
                        producer.send(session.createTextMessage());

View Full Code Here

            service.execute(new Runnable() {
                @Override
                public void run() {
                    try {
                        ActiveMQConnection connection = (ActiveMQConnection) cf.createConnection();
                        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
                        Destination destination = session.createTemporaryQueue();
                        session.createProducer(destination);
                        connection.close();
                        TimeUnit.MILLISECONDS.sleep(ripple.nextInt(20));
                    } catch (Exception e) {

View Full Code Here

    public void testTablesHave() throws Exception {


        ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("vm://localhost?create=false");
        ActiveMQConnection connection = (ActiveMQConnection) cf.createConnection();


        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Destination destination = session.createQueue("TEST.FOO");
        MessageProducer producer = session.createProducer(destination);


        for (int i = 0; i < 10; ++i) {
            producer.send(session.createTextMessage("test"));

View Full Code Here

        waitForBridgeFormation(b, 1, 0);


        ActiveMQConnectionFactory sendFactory = createConnectionFactory(a);
        ActiveMQConnection sendConnection = createConnection(sendFactory);


        ActiveMQSession sendSession = (ActiveMQSession)sendConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        MessageProducer producer = sendSession.createProducer(sendQ);
        ActiveMQTempQueue realReplyQ = (ActiveMQTempQueue) sendSession.createTemporaryQueue();
        TextMessage message = sendSession.createTextMessage("1");
        message.setJMSReplyTo(realReplyQ);
        producer.send(message);

View Full Code Here


        // responder
        ActiveMQConnectionFactory consumerFactory = createConnectionFactory(b);
        ActiveMQConnection consumerConnection = createConnection(consumerFactory);


        ActiveMQSession consumerSession = (ActiveMQSession)consumerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        MessageConsumer consumer = consumerSession.createConsumer(sendQ);
        TextMessage received = (TextMessage) consumer.receive(receiveTimeout);
        assertNotNull("got request from sender ok", received);


        LOG.info("got request, sending reply");

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.