You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2007/03/20 11:11:56 UTC
svn commit: r520346 - in
/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel:
Exchange.java impl/ExchangeSupport.java
Author: rajdavies
Date: Tue Mar 20 03:11:50 2007
New Revision: 520346
URL: http://svn.apache.org/viewvc?view=rev&rev=520346
Log:
add exchange id
Modified:
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/Exchange.java
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ExchangeSupport.java
Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/Exchange.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/Exchange.java?view=diff&rev=520346&r1=520345&r2=520346
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/Exchange.java (original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/Exchange.java Tue Mar 20 03:11:50 2007
@@ -27,6 +27,18 @@
* @param <F> fault type
*/
public interface Exchange<M,R,F> {
+
+ /**
+ * Returns the exchange id
+ * @return the unique id of the exchange
+ */
+ String getExchangeId();
+
+ /**
+ * Set the exchange id
+ * @param id
+ */
+ void setExchangeId(String id);
/**
* Accesses a specific header
Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ExchangeSupport.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ExchangeSupport.java?view=diff&rev=520346&r1=520345&r2=520346
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ExchangeSupport.java (original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ExchangeSupport.java Tue Mar 20 03:11:50 2007
@@ -28,6 +28,7 @@
private R response;
private F fault;
private Exception exception;
+ private String exchangeId;
public Exception getException() {
return exception;
@@ -60,4 +61,15 @@
public void setResponse(R response) {
this.response = response;
}
+
+
+ public String getExchangeId() {
+ return exchangeId;
+ }
+
+
+ public void setExchangeId(String id) {
+ this.exchangeId=id;
+ }
+
}