KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > beans > SimpleMessageBean


1 package beans;
2
3 import javax.ejb.*;
4 import javax.jms.Message JavaDoc;
5 import javax.jms.MessageListener JavaDoc;
6 import javax.jms.JMSException JavaDoc;
7 import javax.jms.TextMessage JavaDoc;
8 import java.util.logging.Logger JavaDoc;
9
10 /**
11  * This is the bean class for the SimpleMessageBean enterprise bean.
12  * Created May 16, 2006 4:03:36 PM
13  * @author ak199487
14  */
15 public class SimpleMessageBean implements MessageDrivenBean, MessageListener JavaDoc {
16     private MessageDrivenContext context;
17     static final Logger JavaDoc logger =Logger.getLogger("SimpleMessageBean");
18
19     // <editor-fold defaultstate="collapsed" desc="EJB infrastructure methods. Click on the + sign on the left to edit the code.">
20
21     /**
22      * @see javax.ejb.MessageDrivenBean#setMessageDrivenContext(javax.ejb.MessageDrivenContext)
23      */
24     public void setMessageDrivenContext(MessageDrivenContext aContext) {
25         context = aContext;
26     }
27     
28     /**
29      * See section 15.4.4 of the EJB 2.0 specification
30      * See section 15.7.3 of the EJB 2.1 specification
31      */
32     public void ejbCreate() {
33         // TODO Add code to acquire and use other enterprise resources (DataSource, JMS, enterprise bean, Web services)
34 }
35     
36     /**
37      * @see javax.ejb.MessageDrivenBean#ejbRemove()
38      */
39     public void ejbRemove() {
40         // TODO release any resource acquired in ejbCreate.
41 // The code here should handle the possibility of not getting invoked
42 // See section 15.7.3 of the EJB 2.1 specification
43 }
44     
45     // </editor-fold>
46
47     public void onMessage(Message JavaDoc aMessage) {
48          TextMessage JavaDoc msg = null;
49
50   try {
51     if (aMessage instanceof TextMessage JavaDoc) {
52       msg = (TextMessage JavaDoc) aMessage;
53       logger.info("MESSAGE BEAN: Message received: " +
54         msg.getText());
55     } else {
56       logger.warning("Message of wrong type: " +
57         aMessage.getClass().getName());
58     }
59   } catch (JMSException JavaDoc e) {
60     e.printStackTrace();
61    context.setRollbackOnly();
62   } catch (Throwable JavaDoc te) {
63     te.printStackTrace();
64   }
65 }
66
67
68     
69     
70 }
71
Popular Tags