You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ha...@apache.org on 2008/11/12 05:02:01 UTC
svn commit: r713260 - in /activemq/camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi: RmiConsumer.java RmiEndpoint.java

Author: hadrian
Date: Tue Nov 11 20:02:00 2008
New Revision: 713260

URL: http://svn.apache.org/viewvc?rev=713260&view=rev
Log:
CAMEL-1078.  Removed BeanExchange.

Modified:
    activemq/camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiConsumer.java
    activemq/camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiEndpoint.java

Modified: activemq/camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiConsumer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiConsumer.java?rev=713260&r1=713259&r2=713260&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiConsumer.java (original)
+++ activemq/camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiConsumer.java Tue Nov 11 20:02:00 2008
@@ -24,8 +24,8 @@
 import java.rmi.registry.Registry;
 import java.rmi.server.UnicastRemoteObject;
 
+import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
-import org.apache.camel.component.bean.BeanExchange;
 import org.apache.camel.component.bean.BeanInvocation;
 import org.apache.camel.impl.DefaultConsumer;
 
@@ -86,8 +86,8 @@
             throw new IllegalStateException("The endpoint is not active: " + getEndpoint().getEndpointUri());
         }
         BeanInvocation invocation = new BeanInvocation(method, args);
-        BeanExchange exchange = (BeanExchange) getEndpoint().createExchange();
-        exchange.setInvocation(invocation);
+        Exchange exchange = getEndpoint().createExchange();
+        exchange.getIn().setBody(invocation);
         getProcessor().process(exchange);
         Throwable fault = exchange.getException();
         if (fault != null) {

Modified: activemq/camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiEndpoint.java?rev=713260&r1=713259&r2=713260&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiEndpoint.java (original)
+++ activemq/camel/trunk/components/camel-rmi/src/main/java/org/apache/camel/component/rmi/RmiEndpoint.java Tue Nov 11 20:02:00 2008
@@ -30,8 +30,8 @@
 import org.apache.camel.Processor;
 import org.apache.camel.Producer;
 import org.apache.camel.RuntimeCamelException;
-import org.apache.camel.component.bean.BeanExchange;
 import org.apache.camel.impl.DefaultEndpoint;
+import org.apache.camel.impl.DefaultExchange;
 
 /**
  * @version $Revision:520964 $
@@ -60,7 +60,7 @@
 
     @Override
     public Exchange createExchange(ExchangePattern pattern) {
-        return new BeanExchange(getCamelContext(), pattern);
+        return new DefaultExchange(getCamelContext(), pattern);
     }
 
     public Consumer createConsumer(Processor processor) throws Exception {