1 46 47 package com.coridan.sample.basic.mdb; 48 49 import javax.ejb.MessageDrivenBean ; 50 import javax.ejb.MessageDrivenContext ; 51 import javax.jms.JMSException ; 52 import javax.jms.Message ; 53 import javax.jms.MessageListener ; 54 import javax.jms.TextMessage ; 55 import javax.naming.Context ; 56 57 import org.apache.commons.logging.Log; 58 import org.apache.commons.logging.LogFactory; 59 60 public class SampleMDB implements MessageDrivenBean , MessageListener { 61 private static final Log log = LogFactory.getLog(SampleMDB.class); 62 63 private transient MessageDrivenContext mdc = null; 64 private Context ctx; 65 66 public void setMessageDrivenContext(MessageDrivenContext mdc) { 67 this.mdc = mdc; 68 } 69 70 public void onMessage(Message msg) { 71 TextMessage txtMsg = null; 72 try { 73 if (msg instanceof TextMessage ) { 74 txtMsg = (TextMessage ) msg; 75 log.info("Received TextMessage: " + txtMsg.getText()); 76 } else { 77 log.info("Received message of type: " + msg.getClass().getName()); 78 } 79 } catch (JMSException e) { 80 e.printStackTrace(); 81 } catch (Throwable te) { 82 te.printStackTrace(); 83 mdc.setRollbackOnly(); 84 } 85 } 86 87 public void ejbRemove() { } 88 public void ejbCreate() { } 89 } | Popular Tags |