camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r935332 - /camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/ClosedCorrelationKeyException.java
Date Sun, 18 Apr 2010 11:25:41 GMT
Author: davsclaus
Date: Sun Apr 18 11:25:41 2010
New Revision: 935332

URL: http://svn.apache.org/viewvc?rev=935332&view=rev
Log:
Renamed option on aggregator

Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/ClosedCorrelationKeyException.java

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/ClosedCorrelationKeyException.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/ClosedCorrelationKeyException.java?rev=935332&r1=935331&r2=935332&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/ClosedCorrelationKeyException.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/aggregate/ClosedCorrelationKeyException.java
Sun Apr 18 11:25:41 2010
@@ -25,21 +25,19 @@ import org.apache.camel.Exchange;
  * @version $Revision$
  */
 public class ClosedCorrelationKeyException extends CamelExchangeException {
+    private final String correlationKey;
 
-    // the correlation key is not expected to be serialized
-    private final transient Object correlationKey;
-
-    public ClosedCorrelationKeyException(Object correlationKey, Exchange exchange) {
+    public ClosedCorrelationKeyException(String correlationKey, Exchange exchange) {
         super("The correlation key [" + correlationKey + "] has been closed", exchange);
         this.correlationKey = correlationKey;
     }
 
-    public ClosedCorrelationKeyException(Object correlationKey, Exchange exchange, Throwable
cause) {
+    public ClosedCorrelationKeyException(String correlationKey, Exchange exchange, Throwable
cause) {
         super("The correlation key [" + correlationKey + "] has been closed", exchange, cause);
         this.correlationKey = correlationKey;
     }
 
-    public Object getCorrelationKey() {
+    public String getCorrelationKey() {
         return correlationKey;
     }
 }



Mime
View raw message