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());
+ }
+
}
