[jboss-svn-commits] JBL Code SVN: r36599 - labs/jbossesb/branches/JBESB_4_9_CP/product/docs/Programmers_Guide/en-US/extras/connectors_and_adaptors.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Fri Feb 11 12:05:41 EST 2011
Author: kevin.conner at jboss.com
Date: 2011-02-11 12:05:40 -0500 (Fri, 11 Feb 2011)
New Revision: 36599
Modified:
labs/jbossesb/branches/JBESB_4_9_CP/product/docs/Programmers_Guide/en-US/extras/connectors_and_adaptors/jmsendpointinflowgateway.java
Log:
Fix method name: JBESB-3570
Modified: labs/jbossesb/branches/JBESB_4_9_CP/product/docs/Programmers_Guide/en-US/extras/connectors_and_adaptors/jmsendpointinflowgateway.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_9_CP/product/docs/Programmers_Guide/en-US/extras/connectors_and_adaptors/jmsendpointinflowgateway.java 2011-02-11 16:56:06 UTC (rev 36598)
+++ labs/jbossesb/branches/JBESB_4_9_CP/product/docs/Programmers_Guide/en-US/extras/connectors_and_adaptors/jmsendpointinflowgateway.java 2011-02-11 17:05:40 UTC (rev 36599)
@@ -1,19 +1,19 @@
public class JmsEndpoint implements InflowGateway, MessageListener
{
private ServiceInvoker service;
- private PackageJmsMessageContents transformer = new
- PackageJmsMessageContents();
+ private PackageJmsMessageContents transformer = new PackageJmsMessageContents();
+
public void setServiceInvoker(ServiceInvoker invoker)
{
this.service = invoker;
}
+
public void onMessage(Message message)
{
try
{
- org.jboss.soa.esb.message.Message esbMessage =
- transformer.process(message);
- service.postMessage(esbMessage);
+ org.jboss.soa.esb.message.Message esbMessage = transformer.process(message);
+ service.deliverAsync(esbMessage);
}
catch (Exception e)
{
More information about the jboss-svn-commits
mailing list