svn commit: r380689 - /incubator/servicemix/trunk/servicemix-components/src/main/java/org/apache/servicemix/components/jms/JmsInBinding.java

[gn...@apache.org]

Author: gnodet
Date: Fri Feb 24 07:26:35 2006
New Revision: 380689

URL: http://svn.apache.org/viewcvs?rev=380689&view=rev
Log:
SM-330: JmsInBinding and inheriting component fails after sending more than 1000 messages

Modified:
    incubator/servicemix/trunk/servicemix-components/src/main/java/org/apache/servicemix/components/jms/JmsInBinding.java

Modified: incubator/servicemix/trunk/servicemix-components/src/main/java/org/apache/servicemix/components/jms/JmsInBinding.java
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-components/src/main/java/org/apache/servicemix/components/jms/JmsInBinding.java?rev=380689&r1=380688&r2=380689&view=diff
==============================================================================
--- incubator/servicemix/trunk/servicemix-components/src/main/java/org/apache/servicemix/components/jms/JmsInBinding.java (original)
+++ incubator/servicemix/trunk/servicemix-components/src/main/java/org/apache/servicemix/components/jms/JmsInBinding.java Fri Feb 24 07:26:35 2006
@@ -18,6 +18,8 @@
 import javax.jbi.JBIException;
 import javax.jbi.messaging.ExchangeStatus;
 import javax.jbi.messaging.InOnly;
+import javax.jbi.messaging.MessageExchange;
+import javax.jbi.messaging.MessagingException;
 import javax.jbi.messaging.NormalizedMessage;
 import javax.jms.JMSException;
 import javax.jms.Message;
@@ -25,6 +27,7 @@
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.apache.servicemix.MessageExchangeListener;
 import org.apache.servicemix.components.util.ComponentSupport;
 import org.apache.servicemix.jbi.RuntimeJBIException;
 
@@ -34,7 +37,7 @@
  *
  * @version $Revision$
  */
-public class JmsInBinding extends ComponentSupport implements MessageListener {
+public class JmsInBinding extends ComponentSupport implements MessageListener, MessageExchangeListener {
     private static final Log log = LogFactory.getLog(JmsInBinding.class);
 
     private JmsMarshaler marshaler = new JmsMarshaler();
@@ -70,5 +73,10 @@
         catch (JBIException e) {
             throw new RuntimeJBIException(e);
         }
+    }
+
+    public void onMessageExchange(MessageExchange exchange) throws MessagingException {
+        // Do nothing as we only send in-only
+        // but this ensure that messages are not queued in the DeliveryChannel
     }
 }