svn commit: r522843 - in /activemq/camel/trunk/camel-jbi/src/main/java/org/apache/camel/component/jbi: JbiEndpoint.java ToJbiProcessor.java

[jstrachan]

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 [EMAIL PROTECTED] 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());