1 28 29 32 package newsamplemdb; 33 34 import javax.ejb.MessageDrivenBean; 35 import javax.ejb.MessageDrivenContext; 36 import javax.jms.Message; 37 import javax.jms.MessageListener; 38 import javax.jms.TextMessage; 39 import javax.jms.JMSException; 40 41 42 43 46 public class MdbBean implements MessageDrivenBean, MessageListener { 47 48 private transient MessageDrivenContext mdbContext; 49 50 51 52 56 60 public MdbBean() { 61 } 62 63 74 75 public void setMessageDrivenContext(MessageDrivenContext ctx) { 76 System.out.println( "MdbBean setMessageDrivenContext"); 77 mdbContext = ctx; 78 } 79 80 89 public void ejbRemove() { 90 System.out.println( "MdbBean ejbRemove"); 91 } 92 93 97 public void ejbCreate() { 98 System.out.println( "MdbBean ejbCreate"); 99 } 100 101 104 public void onMessage(Message message) { 105 System.out.println( "MdbBean onMessage"); 106 try{ 107 TextMessage mess = (TextMessage)message; 108 System.out.println( "Message received: "+mess.getText()); 109 }catch(JMSException ex){ 110 System.err.println("Exception caught: "+ex); 111 } 112 } 113 114 117 public void onMessage1(Message message) { 118 System.out.println( "MdbBean onMessage1"); 119 try{ 120 TextMessage mess = (TextMessage)message; 121 System.out.println( "Message received: "+mess.getText()); 122 }catch(JMSException ex){ 123 System.err.println("Exception caught: "+ex); 124 } 125 } 126 } 127 | Popular Tags |