1 28 29 package samplemdb; 32 33 import javax.ejb.MessageDrivenBean; 34 import javax.ejb.MessageDrivenContext; 35 import javax.jms.Message; 36 import javax.jms.MessageListener; 37 import javax.jms.TextMessage; 38 import javax.jms.JMSException; 39 40 44 public class MdbBean implements MessageDrivenBean, MessageListener { 45 46 private transient MessageDrivenContext mdbContext; 47 48 52 55 public MdbBean() { 56 } 57 58 68 69 public void setMessageDrivenContext(MessageDrivenContext ctx) { 70 System.out.println("MdbBean setMessageDrivenContext"); 71 mdbContext = ctx; 72 } 73 74 82 public void ejbRemove() { 83 System.out.println("MdbBean ejbRemove"); 84 } 85 86 89 public void ejbCreate() { 90 System.out.println("MdbBean ejbCreate"); 91 } 92 93 96 public void onMessage(Message message) { 97 System.out.println("MdbBean onMessage"); 98 try { 99 TextMessage mess = (TextMessage) message; 100 System.out.println("Message received: " + mess.getText()); 101 } catch (JMSException ex) { 102 System.err.println("Exception caught: " + ex); 103 } 104 } 105 } | Popular Tags |