Master/Reference Architectures and Patterns/EJB 3.0 Code/Gerald Examples/src/examples/messaging/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
35
36
37
38

package examples.messaging;

import javax.jms.*;
import javax.naming.InitialContext;

public class LogClient {

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

        // 1: Lookup connection factory        
        TopicConnectionFactory factory = 
            (TopicConnectionFactory) ctx.lookup("jms/TopicConnectionFactory");
        
        // 2: Use connection factory to create JMS connection
        TopicConnection connection = factory.createTopicConnection();
        
        // 3: Use connection to create a session
        TopicSession session = 
            connection.createTopicSession(false,Session.AUTO_ACKNOWLEDGE);
        
        // 4: Lookup destination 
        Topic topic = (Topic)ctx.lookup("jms/Topic");        
        
        // 5: Create a message publisher 
        TopicPublisher publisher = session.createPublisher(topic);

        // 6: Create and publish a message
        TextMessage msg = session.createTextMessage();
        msg.setText("This is a test message.");
        publisher.send(msg);
        
        // finish
        publisher.close();
        System.out.println("Message published. Please check application server's console to see the response from MDB.");
    }
}