package org.jboss.test.mdb.bean;
import javax.ejb.MessageDrivenBean;
import javax.ejb.MessageDrivenContext;
import javax.ejb.EJBException;
import javax.jms.MessageListener;
import javax.jms.Message;
public class ExQueueBean implements MessageDrivenBean, MessageListener{
org.apache.log4j.Category log = org.apache.log4j.Category.getInstance(getClass());
private MessageDrivenContext ctx = null;
public ExQueueBean() {
}
public void setMessageDrivenContext(MessageDrivenContext ctx)
throws EJBException {
this.ctx = ctx;
}
public void ejbCreate() {}
public void ejbRemove() {ctx=null;}
public void onMessage(Message message) {
log.debug("ExQueueBean rolling back transaction" + message.toString());
ctx.setRollbackOnly();
}
}