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