activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r521428 - in /activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi: CamelJbiComponent.java CamelJbiEndpoint.java
Date Thu, 22 Mar 2007 20:00:20 GMT
Author: rajdavies
Date: Thu Mar 22 13:00:17 2007
New Revision: 521428

URL: http://svn.apache.org/viewvc?view=rev&rev=521428
Log:
update the binding

Modified:
    activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/CamelJbiComponent.java
    activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/CamelJbiEndpoint.java

Modified: activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/CamelJbiComponent.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/CamelJbiComponent.java?view=diff&rev=521428&r1=521427&r2=521428
==============================================================================
--- activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/CamelJbiComponent.java
(original)
+++ activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/CamelJbiComponent.java
Thu Mar 22 13:00:17 2007
@@ -24,6 +24,7 @@
 public class CamelJbiComponent extends DefaultComponent{
 
     private CamelJbiEndpoint[] endpoints;
+    private JbiBinding binding;
 
     /**
      * @return the endpoints
@@ -53,5 +54,19 @@
      */
     @Override protected Class[] getEndpointClasses(){
         return new Class[] { CamelJbiEndpoint.class };
+    }
+
+    /**
+     * @return the binding
+     */
+    public JbiBinding getBinding(){
+        return this.binding;
+    }
+
+    /**
+     * @param binding the binding to set
+     */
+    public void setBinding(JbiBinding binding){
+        this.binding=binding;
     }
 }

Modified: activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/CamelJbiEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/CamelJbiEndpoint.java?view=diff&rev=521428&r1=521427&r2=521428
==============================================================================
--- activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/CamelJbiEndpoint.java
(original)
+++ activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/CamelJbiEndpoint.java
Thu Mar 22 13:00:17 2007
@@ -27,17 +27,17 @@
 
     private static final QName SERVICE_NAME=new QName("http://camel.servicemix.org","CamelEndpointComponent");
     private JbiEndpoint jbiEndpoint;
+    private JbiBinding binding;
 
-    public CamelJbiEndpoint(JbiEndpoint jbiEndpoint){
+    public CamelJbiEndpoint(JbiEndpoint jbiEndpoint, JbiBinding binding){
         this.jbiEndpoint=jbiEndpoint;
+        this.binding=binding;
         this.service=SERVICE_NAME;
         this.endpoint=jbiEndpoint.getEndpointUri();
     }
 
     protected void processInOnly(MessageExchange exchange,NormalizedMessage in) throws Exception{
-        /*
-         * ToDo
-         */
+        jbiEndpoint.onExchange(new JbiExchange(jbiEndpoint.getContext(), binding, exchange));
     }
 
     protected void processInOut(MessageExchange exchange,NormalizedMessage in,NormalizedMessage
out) throws Exception{



Mime
View raw message