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	torben	1275	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	torben	1277	System.out.println("got Message - sending reply to " + q.getQueueName() + " corrID=" + txt.getJMSCorrelationID());
40	torben	1275
41
42
43	torben	1277	sendReply(msg,q, txt.getJMSCorrelationID());
44	torben	1275
45
46			}
47
48			} catch (JMSException e) {
49			System.out.println("Error:" + e.getMessage() );
50			}
51
52			}
53
54	torben	1277	private void sendReply(String msg, Queue dest, String id) {
55	torben	1275	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	torben	1277	reply.setJMSCorrelationID(id);
69	torben	1275	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			}