svn commit: r464239 - in /incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common: BaseComponent.java ServiceMixComponent.java

[gn...@apache.org]

Author: gnodet
Date: Sun Oct 15 10:58:05 2006
New Revision: 464239

URL: http://svn.apache.org/viewvc?view=rev&rev=464239
Log:
Add a method on ServiceMixComponent to send consumer exchanges from endpoints

Modified:
    incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/BaseComponent.java
    incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/ServiceMixComponent.java

Modified: incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/BaseComponent.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/BaseComponent.java?view=diff&rev=464239&r1=464238&r2=464239
==============================================================================
--- incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/BaseComponent.java (original)
+++ incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/BaseComponent.java Sun Oct 15 10:58:05 2006
@@ -26,6 +26,7 @@
 import javax.jbi.component.ComponentLifeCycle;
 import javax.jbi.component.ServiceUnitManager;
 import javax.jbi.messaging.MessageExchange;
+import javax.jbi.messaging.MessagingException;
 import javax.jbi.messaging.MessageExchange.Role;
 import javax.jbi.servicedesc.ServiceEndpoint;
 
@@ -187,5 +188,9 @@
     public Executor getExecutor() {
         return lifeCycle.getExecutor();
     }
-    
+
+    public void sendConsumerExchange(MessageExchange exchange, Endpoint endpoint) throws MessagingException {
+        lifeCycle.sendConsumerExchange(exchange, endpoint);
+    }
+
 }

Modified: incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/ServiceMixComponent.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/ServiceMixComponent.java?view=diff&rev=464239&r1=464238&r2=464239
==============================================================================
--- incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/ServiceMixComponent.java (original)
+++ incubator/servicemix/trunk/servicemix-common/src/main/java/org/apache/servicemix/common/ServiceMixComponent.java Sun Oct 15 10:58:05 2006
@@ -22,6 +22,8 @@
 
 import javax.jbi.component.Component;
 import javax.jbi.component.ComponentContext;
+import javax.jbi.messaging.MessageExchange;
+import javax.jbi.messaging.MessagingException;
 
 /**
  * Represents an extended JBI Component implementation which exposes some extra features
@@ -54,4 +56,13 @@
      * @return Returns the name of the component
      */
     public String getComponentName();
+    
+    /**
+     * Sends a consumer exchange from the given endpoint. 
+     * 
+     * @param exchange the exchange to send
+     * @param endpoint the endpoint sending the exchange
+     * @throws MessagingException
+     */
+    public void sendConsumerExchange(MessageExchange exchange, Endpoint endpoint) throws MessagingException;
 }