From: Bill D. <bde...@jb...> - 2005-09-29 23:08:28
|
User: bdecoste Date: 05/09/29 19:08:26 Added: src/test/org/jboss/ejb3/test/consumer DeploymentDescriptorQueueTestRemote.java DeploymentDescriptorQueueTestConsumer.java Log: jboss.xml for Consumer/Producer Revision Changes Path 1.1 date: 2005/09/29 23:08:26; author: bdecoste; state: Exp;jboss-ejb3/src/test/org/jboss/ejb3/test/consumer/DeploymentDescriptorQueueTestRemote.java Index: DeploymentDescriptorQueueTestRemote.java =================================================================== /* * JBoss, the OpenSource J2EE webOS * * Distributable under LGPL license. * See terms of license at gnu.org. */ package org.jboss.ejb3.test.consumer; import org.jboss.annotation.ejb.DeliveryMode; import org.jboss.annotation.ejb.MessageProperties; import org.jboss.annotation.ejb.Producer; /** * @version <tt>$Revision: 1.1 $</tt> * @author <a href="mailto:bde...@jb...">William DeCoste</a> */ public interface DeploymentDescriptorQueueTestRemote { void method1(String msg, int num); void method2(String msg, float num); } 1.1 date: 2005/09/29 23:08:26; author: bdecoste; state: Exp;jboss-ejb3/src/test/org/jboss/ejb3/test/consumer/DeploymentDescriptorQueueTestConsumer.java Index: DeploymentDescriptorQueueTestConsumer.java =================================================================== /* * JBoss, the OpenSource J2EE webOS * * Distributable under LGPL license. * See terms of license at gnu.org. */ package org.jboss.ejb3.test.consumer; import javax.ejb.ActivationConfigProperty; import javax.ejb.AroundInvoke; import javax.ejb.InvocationContext; import javax.ejb.PostConstruct; import javax.ejb.PreDestroy; import javax.jms.Message; import org.jboss.annotation.ejb.Consumer; import org.jboss.annotation.ejb.CurrentMessage; import org.jboss.annotation.ejb.DeliveryMode; import org.jboss.annotation.ejb.MessageProperties; import org.jboss.annotation.ejb.Producer; /** * @version <tt>$Revision: 1.1 $</tt> * @author <a href="mailto:bde...@jb...">William DeCoste</a> */ public class DeploymentDescriptorQueueTestConsumer implements DeploymentDescriptorQueueTestRemote { Message currentMessage; private Message setterMessage; void setMessage(Message msg) { setterMessage = msg; } public void method1(String msg, int num) { TestStatusBean.queueRan = "method1"; TestStatusBean.fieldMessage = currentMessage != null; TestStatusBean.setterMessage = setterMessage != null; System.out.println("method1(" + msg + ", " + num + ")"); } public void method2(String msg, float num) { TestStatusBean.queueRan = "method2"; TestStatusBean.fieldMessage = currentMessage != null; TestStatusBean.setterMessage = setterMessage != null; System.out.println("method2(" + msg + ", " + num + ")"); } @AroundInvoke public Object intercept(InvocationContext ctx) throws Exception { System.out.println("**** intercepted ****" + ctx.getMethod().getName()); TestStatusBean.interceptedQueue = ctx.getMethod().getName(); return ctx.proceed(); } @PostConstruct public void postConstruct() { TestStatusBean.postConstruct = true; } @PreDestroy public void preDestroy() { TestStatusBean.preDestroy = true; } } |