You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2008/06/10 17:13:21 UTC

svn commit: r666147 - in /servicemix/smx3/trunk/common/servicemix-common/src/main/java/org/apache/servicemix/common: AsyncBaseLifeCycle.java ServiceMixComponent.java

Author: gnodet
Date: Tue Jun 10 08:13:21 2008
New Revision: 666147

URL: http://svn.apache.org/viewvc?rev=666147&view=rev
Log:
Restore compatibility

Modified:
    servicemix/smx3/trunk/common/servicemix-common/src/main/java/org/apache/servicemix/common/AsyncBaseLifeCycle.java
    servicemix/smx3/trunk/common/servicemix-common/src/main/java/org/apache/servicemix/common/ServiceMixComponent.java

Modified: servicemix/smx3/trunk/common/servicemix-common/src/main/java/org/apache/servicemix/common/AsyncBaseLifeCycle.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/trunk/common/servicemix-common/src/main/java/org/apache/servicemix/common/AsyncBaseLifeCycle.java?rev=666147&r1=666146&r2=666147&view=diff
==============================================================================
--- servicemix/smx3/trunk/common/servicemix-common/src/main/java/org/apache/servicemix/common/AsyncBaseLifeCycle.java (original)
+++ servicemix/smx3/trunk/common/servicemix-common/src/main/java/org/apache/servicemix/common/AsyncBaseLifeCycle.java Tue Jun 10 08:13:21 2008
@@ -629,6 +629,25 @@
         }
     }
 
+    @Deprecated
+    public void sendConsumerExchange(MessageExchange exchange, ExchangeProcessor processor) throws MessagingException {
+        if (exchange.getStatus() == ExchangeStatus.ACTIVE) {
+            processors.put(exchange.getExchangeId(), processor);
+        }
+        channel.send(exchange);
+    }
+
+    @Deprecated
+    public void prepareConsumerExchange(MessageExchange exchange, Endpoint endpoint) throws MessagingException {
+        prepareExchange(exchange, endpoint);
+    }
+
+    @Deprecated
+    public void sendConsumerExchange(MessageExchange exchange, Endpoint endpoint) throws MessagingException {
+        prepareExchange(exchange, endpoint);
+        channel.send(exchange);
+    }
+
     /**
      * Handle an exchange sent to an EPR resolved by this component
      * 

Modified: servicemix/smx3/trunk/common/servicemix-common/src/main/java/org/apache/servicemix/common/ServiceMixComponent.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/trunk/common/servicemix-common/src/main/java/org/apache/servicemix/common/ServiceMixComponent.java?rev=666147&r1=666146&r2=666147&view=diff
==============================================================================
--- servicemix/smx3/trunk/common/servicemix-common/src/main/java/org/apache/servicemix/common/ServiceMixComponent.java (original)
+++ servicemix/smx3/trunk/common/servicemix-common/src/main/java/org/apache/servicemix/common/ServiceMixComponent.java Tue Jun 10 08:13:21 2008
@@ -73,6 +73,12 @@
      */
     public void prepareExchange(MessageExchange exchange, Endpoint endpoint) throws MessagingException;
 
+    @Deprecated
+    public void prepareConsumerExchange(MessageExchange exchange, Endpoint endpoint) throws MessagingException;
+
+    @Deprecated
+    public void sendConsumerExchange(MessageExchange exchange, Endpoint endpoint) throws MessagingException;
+
     /**
      * @return the QName of the element used in EPR
      */