camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ningji...@apache.org
Subject svn commit: r729204 - /activemq/camel/branches/camel-1.x/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaExchange.java
Date Wed, 24 Dec 2008 03:12:12 GMT
Author: ningjiang
Date: Tue Dec 23 19:12:12 2008
New Revision: 729204

URL: http://svn.apache.org/viewvc?rev=729204&view=rev
Log:
CAMEL-1202 Applied patch with thanks to Trev

Modified:
    activemq/camel/branches/camel-1.x/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaExchange.java

Modified: activemq/camel/branches/camel-1.x/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaExchange.java
URL: http://svn.apache.org/viewvc/activemq/camel/branches/camel-1.x/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaExchange.java?rev=729204&r1=729203&r2=729204&view=diff
==============================================================================
--- activemq/camel/branches/camel-1.x/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaExchange.java
(original)
+++ activemq/camel/branches/camel-1.x/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaExchange.java
Tue Dec 23 19:12:12 2008
@@ -35,6 +35,12 @@
         super(camelContext, pattern);
         this.session = session;
     }
+    
+    public MinaExchange(DefaultExchange parent, IoSession session) {
+        super(parent);
+        this.session = session;
+    }
+
 
     /**
      * The associated Mina session, is <b>only</b> available for {@link MinaConsumer}.
@@ -44,5 +50,11 @@
     public IoSession getSession() {
         return session;
     }
+    
+    @Override
+    public Exchange newInstance() {
+        return new MinaExchange(this, getSession());
+    }
+
 
 }



Mime
View raw message