Master/Reference Architectures and Patterns/EJB 3.0 Code/Gerald Examples/src/examples/messaging/dd/LogClient.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

package examples.messaging.dd;

import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicPublisher;
import javax.jms.TopicSession;
import javax.naming.InitialContext;

public class LogClient {

    public static void main(String[] args) throws Exception {
        InitialContext ctx = new InitialContext(System.getProperties());

        Topic topic = (Topic) ctx.lookup("jms/Topic");        
        TopicConnectionFactory factory = 
            (TopicConnectionFactory) ctx
                .lookup("jms/TopicConnectionFactory");
        TopicConnection connection = factory.createTopicConnection();
        TopicSession session = connection.createTopicSession(false,
                Session.AUTO_ACKNOWLEDGE);
        
        TopicPublisher publisher = session.createPublisher(topic);

        // create and publish a message
        TextMessage msg = session.createTextMessage();
        msg.setText("This is a test message.");
        publisher.publish(msg);

        System.out.println("Message published. Please check application server's console to see the response from MDB.");
    }
}