User: pra
Date: 00/12/29 12:57:36
Added: src/main/org/jboss/test/mdb/bean QueueBean.java
TopicBean.java
Log:
Added test for MDB. OBS - this test does currently NOT work since it tests for
durableTopic and that does currently not work. Wich is a good thing to know
Revision Changes Path
1.1 jbosstest/src/main/org/jboss/test/mdb/bean/QueueBean.java
Index: QueueBean.java
===================================================================
/*
* Copyright (c) 2000 Peter Antman DN <[EMAIL PROTECTED]>
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) any later version
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
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;
/**
* MessageBeanImpl.java
*
*
* Created: Sat Nov 25 18:07:50 2000
*
* @author
* @version
*/
public class QueueBean implements MessageDrivenBean, MessageListener{
private MessageDrivenContext ctx = null;
public QueueBean() {
}
public void setMessageDrivenContext(MessageDrivenContext ctx)
throws EJBException {
this.ctx = ctx;
}
public void ejbCreate() {}
public void ejbRemove() {ctx=null;}
public void onMessage(Message message) {
System.err.println("DEBUG: QueueBean got message" + message.toString() );
}
} // MessageBeanImpl
1.1 jbosstest/src/main/org/jboss/test/mdb/bean/TopicBean.java
Index: TopicBean.java
===================================================================
/*
* Copyright (c) 2000 Peter Antman DN <[EMAIL PROTECTED]>
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) any later version
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
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;
/**
* MessageBeanImpl.java
*
*
* Created: Sat Nov 25 18:07:50 2000
*
* @author
* @version
*/
public class TopicBean implements MessageDrivenBean, MessageListener{
private MessageDrivenContext ctx = null;
public TopicBean() {
}
public void setMessageDrivenContext(MessageDrivenContext ctx)
throws EJBException {
this.ctx = ctx;
}
public void ejbCreate() {}
public void ejbRemove() {ctx=null;}
public void onMessage(Message message) {
System.err.println("DEBUG: TopicBean got message" + message.toString() );
}
} // MessageBeanImpl
