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
*/