Examples of javax.jms.TopicPublisher.publish()

javax.jms.TopicPublisher.publish()
Publishes a message to the topic. Uses the TopicPublisher's default delivery mode, priority, and time to live. @param message the message to publish @exception JMSException if the JMS provider fails to publish the messagedue to some internal error. @exception MessageFormatException if an invalid message is specified. @exception InvalidDestinationException if a client uses this methodwith a TopicPublisher with an invalid topic. @exception java.lang.UnsupportedOperationException if a client uses thismethod with a TopicPublisher that did not specify a topic at creation time. @see javax.jms.MessageProducer#getDeliveryMode() @see javax.jms.MessageProducer#getTimeToLive() @see javax.jms.MessageProducer#getPriority()

        TopicSession session1 = con.createTopicSession(true, AMQSession.AUTO_ACKNOWLEDGE);
        TopicPublisher publisher = session1.createPublisher(topic);
        MessageConsumer consumer1 = session1.createConsumer(topic);
        con.start();
        TextMessage tm = session1.createTextMessage("Hello");
        publisher.publish(tm);
        session1.commit();
        tm = (TextMessage) consumer1.receive(10000L);
        assertNotNull(tm);
        String msgText = tm.getText();
        assertEquals("Hello", msgText);

View Full Code Here

        String msgText = tm.getText();
        assertEquals("Hello", msgText);
        tm = session1.createTextMessage();
        msgText = tm.getText();
        assertNull(msgText);
        publisher.publish(tm);
        session1.commit();
        tm = (TextMessage) consumer1.receive(10000L);
        assertNotNull(tm);
        session1.commit();
        msgText = tm.getText();

View Full Code Here

        session1.commit();
        msgText = tm.getText();
        assertNull(msgText);
        tm.clearBody();
        tm.setText("Now we are not null");
        publisher.publish(tm);
        session1.commit();
        tm = (TextMessage) consumer1.receive(2000);
        assertNotNull(tm);
        session1.commit();
        msgText = tm.getText();

View Full Code Here

        assertEquals("Now we are not null", msgText);


        tm = session1.createTextMessage("");
        msgText = tm.getText();
        assertEquals("Empty string not returned", "", msgText);
        publisher.publish(tm);
        session1.commit();
        tm = (TextMessage) consumer1.receive(2000);
        session1.commit();
        assertNotNull(tm);
        assertEquals("Empty string not returned", "", msgText);

View Full Code Here

        con.start();
        TextMessage m;
        TextMessage message;


        //send message to all consumers
        publisher.publish(session1.createTextMessage("hello-new2"));
        session1.commit();
        //test normal subscriber gets message
        m = (TextMessage) normal.receive(1000);
        assertNotNull(m);
        session1.commit();

View Full Code Here


        //send message to all consumers
        message = session1.createTextMessage("hello2");
        message.setStringProperty("Selector", "select");


        publisher.publish(message);
        session1.commit();


        //test normal subscriber gets message
        m = (TextMessage) normal.receive(1000);
        assertNotNull(m);

View Full Code Here




        message = session2.createTextMessage("hello2");
        message.setStringProperty("Selector", "select");


        publisher2.publish(message);
        session2.commit();


        //test normal subscriber gets message
        m = (TextMessage) normal.receive(1000);
        assertNotNull(m);

View Full Code Here

        TextMessage m;
        TextMessage message;


        // Send non-matching message
        message = session.createTextMessage("non-matching 1");
        publisher.publish(message);
        session.commit();


        // Send and consume matching message
        message = session.createTextMessage("hello");
        message.setStringProperty("Selector", "select");

View Full Code Here


        // Send and consume matching message
        message = session.createTextMessage("hello");
        message.setStringProperty("Selector", "select");


        publisher.publish(message);
        session.commit();


        m = (TextMessage) selector.receive(1000);
        assertNotNull("should have received message", m);
        assertEquals("Message contents were wrong", "hello", m.getText());

View Full Code Here

        assertNotNull("should have received message", m);
        assertEquals("Message contents were wrong", "hello", m.getText());


        // Send non-matching message
        message = session.createTextMessage("non-matching 2");
        publisher.publish(message);
        session.commit();


        // Assert queue count is 0
        long depth = ((AMQTopicSessionAdaptor) session).getSession().getQueueDepth(topic);
        assertEquals("Queue depth was wrong", 0, depth);

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.