Examples of javax.jms.Session.createDurableSubscriber()

javax.jms.Session.createDurableSubscriber()

        MessageProducer producer = session1.createProducer(topic);


        _logger.info("Create Session 2");
        Session session2 = con.createSession(false, AMQSession.NO_ACKNOWLEDGE);
        _logger.info("Create Durable Subscriber on Session 2");
        TopicSubscriber consumer2 = session2.createDurableSubscriber(topic, "MySubscription");


        _logger.info("Starting connection");
        con.start();


        _logger.info("Producer sending message A");

View Full Code Here


        Session sessionProd = con.createSession(false, ackMode);
        MessageProducer producer = sessionProd.createProducer(topic);


        Session session2 = con.createSession(false, ackMode);
        TopicSubscriber consumer2 = session2.createDurableSubscriber(topic, "MySubscription");


        con.start();


        //send message A and check both consumers receive
        producer.send(session1.createTextMessage("A"));

View Full Code Here

        //Send message C, then connect consumer 3 to durable subscription and get
        //message B if not using NO_ACK, then receive C with consumer 1 and 3
        producer.send(session1.createTextMessage("C"));


        Session session3 = con.createSession(false, ackMode);
        MessageConsumer consumer3 = session3.createDurableSubscriber(topic, "MySubscription");


        if(ackMode == AMQSession.NO_ACKNOWLEDGE)
        {
            //Do nothing if NO_ACK was used, as prefetch means the message was dropped
            //when we didn't call receive() to get it before closing consumer 2

View Full Code Here

        // Create consumer 2.
        AMQConnection con2 = (AMQConnection) getConnection("guest", "guest");
        con2.start();
        Session session2 = con2.createSession(false, ackMode);


        TopicSubscriber consumer2 = session2.createDurableSubscriber(topic, "MySubscription");


        // Send message and check that both consumers get it and only it.
        producer.send(session0.createTextMessage("A"));


        msg = consumer1.receive(POSITIVE_RECEIVE_TIMEOUT);

View Full Code Here

        // and also gets message C sent after it was disconnected.
        AMQConnection con3 = (AMQConnection) getConnection("guest", "guest");
        con3.start();
        Session session3 = con3.createSession(false, ackMode);


        TopicSubscriber consumer3 = session3.createDurableSubscriber(topic, "MySubscription");


        if(ackMode == AMQSession.NO_ACKNOWLEDGE)
        {
            //Do nothing if NO_ACK was used, as prefetch means the message was dropped
            //when we didn't call receive() to get it before closing consumer 2

View Full Code Here

      AMQTopic topic = new AMQTopic((AMQConnection) conn, "MyTestDurableWithInvalidSelectorTopic");
      MessageProducer producer = session.createProducer(topic);
      producer.send(session.createTextMessage("testDurableWithInvalidSelector1"));
      try 
      {
        TopicSubscriber deadSubscriber = session.createDurableSubscriber(topic, "testDurableWithInvalidSelectorSub",
                                        "=TEST 'test", true);
        assertNull("Subscriber should not have been created", deadSubscriber);
      } 
      catch (JMSException e)
      {

View Full Code Here

      } 
      catch (JMSException e)
      {
        assertTrue("Wrong type of exception thrown", e instanceof InvalidSelectorException);
      }
      TopicSubscriber liveSubscriber = session.createDurableSubscriber(topic, "testDurableWithInvalidSelectorSub");
      assertNotNull("Subscriber should have been created", liveSubscriber);


      producer.send(session.createTextMessage("testDurableWithInvalidSelector2"));
      
      Message msg = liveSubscriber.receive(POSITIVE_RECEIVE_TIMEOUT);

View Full Code Here

      conn.start();
      Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
      AMQTopic topic = new AMQTopic((AMQConnection) conn, "testDurableWithInvalidDestinationTopic");
      try 
      {
        TopicSubscriber deadSubscriber = session.createDurableSubscriber(null, "testDurableWithInvalidDestinationsub");
        assertNull("Subscriber should not have been created", deadSubscriber);
      } 
      catch (InvalidDestinationException e)
      {
        // This was expected

View Full Code Here

        // This was expected
      }
      MessageProducer producer = session.createProducer(topic);      
      producer.send(session.createTextMessage("testDurableWithInvalidSelector1"));
      
      TopicSubscriber liveSubscriber = session.createDurableSubscriber(topic, "testDurableWithInvalidDestinationsub");
      assertNotNull("Subscriber should have been created", liveSubscriber);
      
      producer.send(session.createTextMessage("testDurableWithInvalidSelector2"));
      Message msg = liveSubscriber.receive(POSITIVE_RECEIVE_TIMEOUT);
      assertNotNull ("Message should have been received", msg);

View Full Code Here

        Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
        AMQTopic topic = new AMQTopic((AMQConnection) conn, "testResubscribeWithChangedSelector");
        MessageProducer producer = session.createProducer(topic);
        
        // Create durable subscriber that matches A
        TopicSubscriber subA = session.createDurableSubscriber(topic, 
                "testResubscribeWithChangedSelector",
                "Match = True", false);


        // Send 1 matching message and 1 non-matching message
        sendMatchingAndNonMatchingMessage(session, producer);

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.