activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r522843 - in /activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi: JbiEndpoint.java ToJbiProcessor.java
Date Tue, 27 Mar 2007 09:37:17 GMT
Author: jstrachan
Date: Tue Mar 27 02:37:16 2007
New Revision: 522843

URL: http://svn.apache.org/viewvc?view=rev&rev=522843
Log:
added a bit more debugging until I can figure out how to fix the test case :)

Modified:
    activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/JbiEndpoint.java
    activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/ToJbiProcessor.java

Modified: activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/JbiEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/JbiEndpoint.java?view=diff&rev=522843&r1=522842&r2=522843
==============================================================================
--- activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/JbiEndpoint.java
(original)
+++ activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/JbiEndpoint.java
Tue Mar 27 02:37:16 2007
@@ -17,14 +17,14 @@
  */
 package org.apache.camel.component.jbi;
 
+import org.apache.camel.Consumer;
 import org.apache.camel.Endpoint;
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.apache.camel.Producer;
-import org.apache.camel.Consumer;
+import org.apache.camel.impl.DefaultConsumer;
 import org.apache.camel.impl.DefaultEndpoint;
 import org.apache.camel.impl.DefaultProducer;
-import org.apache.camel.impl.DefaultConsumer;
 
 /**
  * Represents an {@link Endpoint} for interacting with JBI
@@ -42,21 +42,22 @@
     }
 
     public Producer<Exchange> createProducer() throws Exception {
-        return new DefaultProducer<Exchange>(this) {
+        return startService(new DefaultProducer<Exchange>(this) {
             public void onExchange(Exchange exchange) {
                 toJbiProcessor.onExchange(exchange);
             }
-        };
+        });
     }
 
     public Consumer<Exchange> createConsumer(final Processor<Exchange> processor)
throws Exception {
-        return new DefaultConsumer<Exchange>(this, processor) {
+        return startService(new DefaultConsumer<Exchange>(this, processor) {
             CamelJbiEndpoint jbiEndpoint;
 
             @Override
             protected void doStart() throws Exception {
                 super.doStart();
                 jbiEndpoint = jbiComponent.activateJbiEndpoint(JbiEndpoint.this, processor);
+                System.out.println(">>>>ĂŠactivated endpoint: " + jbiEndpoint);
             }
 
             @Override
@@ -68,7 +69,7 @@
 */
                 super.doStop();
             }
-        };
+        });
     }
 
     /*

Modified: activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/ToJbiProcessor.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/ToJbiProcessor.java?view=diff&rev=522843&r1=522842&r2=522843
==============================================================================
--- activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/ToJbiProcessor.java
(original)
+++ activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi/ToJbiProcessor.java
Tue Mar 27 02:37:16 2007
@@ -48,7 +48,10 @@
             DeliveryChannel deliveryChannel = componentContext.getDeliveryChannel();
             MessageExchangeFactory exchangeFactory = deliveryChannel.createExchangeFactory();
             MessageExchange messageExchange = binding.makeJbiMessageExchange(exchange, exchangeFactory);
+
             System.out.println("#### Configuring exchange with: " + destinationUri);
+            new Exception().printStackTrace(System.out);
+
             URIResolver.configureExchange(messageExchange, componentContext, destinationUri);
 
             System.out.println("#### service: " + messageExchange.getService() + " endpoint:
" + messageExchange.getEndpoint());



Mime
View raw message