[jboss-svn-commits] JBL Code SVN: r22410 - labs/jbossesb/workspace/skeagh/routing/jms/src/main/java/org/jboss/esb/jms.

[jboss-svn-commits at lists.jboss.org]

Author: beve
Date: 2008-09-04 12:05:39 -0400 (Thu, 04 Sep 2008)
New Revision: 22410

Modified:
   labs/jbossesb/workspace/skeagh/routing/jms/src/main/java/org/jboss/esb/jms/JmsInboundRouter.java
Log:
Just added the ServiceName to the logging statement


Modified: labs/jbossesb/workspace/skeagh/routing/jms/src/main/java/org/jboss/esb/jms/JmsInboundRouter.java
===================================================================
--- labs/jbossesb/workspace/skeagh/routing/jms/src/main/java/org/jboss/esb/jms/JmsInboundRouter.java	2008-09-04 15:41:12 UTC (rev 22409)
+++ labs/jbossesb/workspace/skeagh/routing/jms/src/main/java/org/jboss/esb/jms/JmsInboundRouter.java	2008-09-04 16:05:39 UTC (rev 22410)
@@ -30,8 +30,12 @@
 import org.jboss.esb.annotation.ConfigParam;
 import org.jboss.esb.annotation.ConfigParam.Use;
 import org.jboss.esb.annotations.Initialize;
+import org.jboss.esb.context.InvocationContext;
+import org.jboss.esb.message.Message;
 import org.jboss.esb.routing.InboundRouter;
 import org.jboss.esb.routing.MessageDispatcher;
+import org.jboss.esb.routing.RoutingException;
+import org.jboss.esb.service.ServiceName;
 import org.jboss.esb.util.AssertArgument;
 
 /**
@@ -68,6 +72,8 @@
      */
     private Properties properties;
 
+    private ServiceName serviceName;
+
     /**
      * Initializes this instance.
      */
@@ -82,11 +88,18 @@
             // add/overwrite properties from the configuration
             jmsProperties.putAll(properties);
         }
-        log.debug("JMSProperties : " + jmsProperties);
+        log.info("Service : + " + serviceName + ", JMSProperties : " + jmsProperties);
 
         // add this class as a JMS message listener...
     }
 
+    public void onMessage() throws RoutingException
+    {
+        Message esbMessage = new Message();
+        esbMessage.setPayload("test");
+        dispatcher.dispatch(esbMessage, new InvocationContext());
+    }
+
     /**
      * Gets the JMS properties.
      *