Fixed CS
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/6aa5fd87 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/6aa5fd87 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/6aa5fd87 Branch: refs/heads/master Commit: 6aa5fd87b2359eeb31520cfa693577a88c9936dc Parents: d8b5456 Author: Claus Ibsen <[email protected]> Authored: Fri Feb 6 06:24:38 2015 +0100 Committer: Claus Ibsen <[email protected]> Committed: Fri Feb 6 06:24:38 2015 +0100 ---------------------------------------------------------------------- .../org/apache/camel/component/dataset/DataSetEndpoint.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/6aa5fd87/camel-core/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java b/camel-core/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java index 7ed8e77..74bc4b5 100644 --- a/camel-core/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java +++ b/camel-core/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java @@ -44,9 +44,9 @@ import org.slf4j.LoggerFactory; @UriEndpoint(scheme = "dataset", consumerClass = DataSetConsumer.class, label = "core,testing") public class DataSetEndpoint extends MockEndpoint implements Service { private final transient Logger log; + private final AtomicInteger receivedCounter = new AtomicInteger(); @UriPath(name = "name", description = "name of DataSet to lookup in the registry") private volatile DataSet dataSet; - private final AtomicInteger receivedCounter = new AtomicInteger(); @UriParam(defaultValue = "0") private int minRate; @UriParam(defaultValue = "3") @@ -62,7 +62,7 @@ public class DataSetEndpoint extends MockEndpoint implements Service { public DataSetEndpoint() { this.log = LoggerFactory.getLogger(DataSetEndpoint.class); // optimize as we dont need to copy the exchange - copyOnExchange = false; + setCopyOnExchange(false); } public DataSetEndpoint(String endpointUri, Component component, DataSet dataSet) { @@ -70,7 +70,7 @@ public class DataSetEndpoint extends MockEndpoint implements Service { this.dataSet = dataSet; this.log = LoggerFactory.getLogger(endpointUri); // optimize as we dont need to copy the exchange - copyOnExchange = false; + setCopyOnExchange(false); } public static void assertEquals(String description, Object expected, Object actual, Exchange exchange) {
