thoerup/messagedriven/ReverserBean.java

package dk.thoerup.messagedriven;

import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.InitialContext;


@MessageDriven(mappedName = "jms/reverse", activationConfig =  {
      @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
      @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
  })

public class ReverserBean implements MessageListener {

        @Override
        public void onMessage(Message message) {
                
                try {                   
                        if (message instanceof TextMessage) {
                                TextMessage txt = (TextMessage) message;
                                String msg = reverse( txt.getText() );
                                
                                Destination d = txt.getJMSReplyTo();
                                Queue q = (Queue) d;
                                
                                
                                System.out.println("got Message - sending reply to " + q.getQueueName() + " corrID=" + txt.getJMSCorrelationID());
                                
                                
                                sendReply(msg,q, txt.getJMSCorrelationID());
                                
                                
                        }
                        
                } catch (JMSException e) {
                        System.out.println("Error:" + e.getMessage() );
                }
                                
        } 
        
        private void sendReply(String msg, Queue dest, String id) {
                try {
                        InitialContext ic = new InitialContext();
                
                        ConnectionFactory cf = (ConnectionFactory)ic.lookup("jms/helloFactory");
                        Connection con = cf.createConnection();
                        Session session = con.createSession(false, Session.AUTO_ACKNOWLEDGE);
                        MessageProducer producer = session.createProducer(dest);
                        
                        
                        TextMessage reply = session.createTextMessage();
                        reply.setStringProperty("name", "reply");
                        reply.setText(msg);
                        reply.setJMSCorrelationID(id);
                        producer.send(reply);
                        
                        System.out.println("reply send messageid=" + reply.getJMSMessageID() );
                        
                        con.close();
                        
                }catch (Exception e) {
                        System.out.println("Error " + e);
                }
                
        }
        
        
        private String reverse(String str) {
                StringBuilder sb = new StringBuilder();
                
                for (int i=str.length()-1; i>=0; i--) {
                        sb.append( str.charAt(i) );
                }
                
                return sb.toString();
        }
}
1	package dk.thoerup.messagedriven;
2
3	import javax.ejb.ActivationConfigProperty;
4	import javax.ejb.MessageDriven;
5	import javax.jms.Connection;
6	import javax.jms.ConnectionFactory;
7	import javax.jms.Destination;
8	import javax.jms.JMSException;
9	import javax.jms.Message;
10	import javax.jms.MessageListener;
11	import javax.jms.MessageProducer;
12	import javax.jms.Queue;
13	import javax.jms.Session;
14	import javax.jms.TextMessage;
15	import javax.naming.InitialContext;
16
17
18
19
20	@MessageDriven(mappedName = "jms/reverse", activationConfig = {
21	@ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
22	@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
23	})
24
25	public class ReverserBean implements MessageListener {
26
27	@Override
28	public void onMessage(Message message) {
29
30	try {
31	if (message instanceof TextMessage) {
32	TextMessage txt = (TextMessage) message;
33	String msg = reverse( txt.getText() );
34
35	Destination d = txt.getJMSReplyTo();
36	Queue q = (Queue) d;
37
38
39	System.out.println("got Message - sending reply to " + q.getQueueName() + " corrID=" + txt.getJMSCorrelationID());
40
41
42
43	sendReply(msg,q, txt.getJMSCorrelationID());
44
45
46	}
47
48	} catch (JMSException e) {
49	System.out.println("Error:" + e.getMessage() );
50	}
51
52	}
53
54	private void sendReply(String msg, Queue dest, String id) {
55	try {
56	InitialContext ic = new InitialContext();
57
58	ConnectionFactory cf = (ConnectionFactory)ic.lookup("jms/helloFactory");
59	Connection con = cf.createConnection();
60	Session session = con.createSession(false, Session.AUTO_ACKNOWLEDGE);
61	MessageProducer producer = session.createProducer(dest);
62
63
64
65	TextMessage reply = session.createTextMessage();
66	reply.setStringProperty("name", "reply");
67	reply.setText(msg);
68	reply.setJMSCorrelationID(id);
69	producer.send(reply);
70
71	System.out.println("reply send messageid=" + reply.getJMSMessageID() );
72
73	con.close();
74
75	}catch (Exception e) {
76	System.out.println("Error " + e);
77	}
78
79	}
80
81
82	private String reverse(String str) {
83	StringBuilder sb = new StringBuilder();
84
85	for (int i=str.length()-1; i>=0; i--) {
86	sb.append( str.charAt(i) );
87	}
88
89	return sb.toString();
90	}
91	}