Repository: camel Updated Branches: refs/heads/master dbd68347b -> e0fed4569
Fix CS Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e0fed456 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e0fed456 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e0fed456 Branch: refs/heads/master Commit: e0fed4569f1a6d111166eab0d4d07b9d20cf031c Parents: dbd6834 Author: lburgazzoli <lburgazz...@gmail.com> Authored: Fri Apr 7 18:16:06 2017 +0200 Committer: lburgazzoli <lburgazz...@gmail.com> Committed: Fri Apr 7 18:16:06 2017 +0200 ---------------------------------------------------------------------- .../camel-infinispan/src/main/docs/infinispan-component.adoc | 3 ++- .../component/infinispan/policy/InfinispanRoutePolicy.java | 4 ++-- .../infinispan/policy/InfinispanRoutePolicyTestBase.java | 6 +++--- 3 files changed, 7 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/e0fed456/components/camel-infinispan/src/main/docs/infinispan-component.adoc ---------------------------------------------------------------------- diff --git a/components/camel-infinispan/src/main/docs/infinispan-component.adoc b/components/camel-infinispan/src/main/docs/infinispan-component.adoc index 9dfa579..85f2615 100644 --- a/components/camel-infinispan/src/main/docs/infinispan-component.adoc +++ b/components/camel-infinispan/src/main/docs/infinispan-component.adoc @@ -59,7 +59,7 @@ with the following path and query parameters: | **host** | *Required* Specifies the host of the cache on Infinispan instance | | String |======================================================================= -#### Query Parameters (14 parameters): +#### Query Parameters (15 parameters): [width="100%",cols="2,5,^1,2",options="header"] |======================================================================= @@ -75,6 +75,7 @@ with the following path and query parameters: | **exceptionHandler** (consumer) | To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this options is not in use. By default the consumer will deal with exceptions that will be logged at WARN or ERROR level and ignored. | | ExceptionHandler | **exchangePattern** (consumer) | Sets the exchange pattern when the consumer creates an exchange. | | ExchangePattern | **command** (producer) | The operation to perform. | put | String +| **configurationProperties** (advanced) | Infinispan configuration properties. | | Map | **configurationUri** (advanced) | An implementation specific URI for the CacheManager | | String | **flags** (advanced) | A comma separated list of Flag to be applied by default on each cache invocation not applicable to remote caches. | | String | **synchronous** (advanced) | Sets whether synchronous processing should be strictly used or Camel is allowed to use asynchronous processing (if supported). | false | boolean http://git-wip-us.apache.org/repos/asf/camel/blob/e0fed456/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/policy/InfinispanRoutePolicy.java ---------------------------------------------------------------------- diff --git a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/policy/InfinispanRoutePolicy.java b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/policy/InfinispanRoutePolicy.java index 7103edf..7afc26a 100644 --- a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/policy/InfinispanRoutePolicy.java +++ b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/policy/InfinispanRoutePolicy.java @@ -356,7 +356,7 @@ public class InfinispanRoutePolicy extends RoutePolicySupport implements CamelCo private Cache<String, String> cache; private ScheduledFuture<?> future; - public EmbeddedCacheService(Cache<String, String> cache) { + EmbeddedCacheService(Cache<String, String> cache) { this.cache = cache; this.future = null; } @@ -427,7 +427,7 @@ public class InfinispanRoutePolicy extends RoutePolicySupport implements CamelCo private ScheduledFuture<?> future; private Long version; - public RemoteCacheService(RemoteCache<String, String> cache) { + RemoteCacheService(RemoteCache<String, String> cache) { this.cache = cache; this.future = null; this.version = null; http://git-wip-us.apache.org/repos/asf/camel/blob/e0fed456/components/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/policy/InfinispanRoutePolicyTestBase.java ---------------------------------------------------------------------- diff --git a/components/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/policy/InfinispanRoutePolicyTestBase.java b/components/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/policy/InfinispanRoutePolicyTestBase.java index 2091ed6..cad44c1 100644 --- a/components/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/policy/InfinispanRoutePolicyTestBase.java +++ b/components/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/policy/InfinispanRoutePolicyTestBase.java @@ -60,7 +60,7 @@ abstract class InfinispanRoutePolicyTestBase extends CamelTestSupport { @Test public void testLeadership()throws Exception { context.startRoute("route1"); - while(!policy1.isLeader()) { + while (!policy1.isLeader()) { Thread.sleep(250); } @@ -71,7 +71,7 @@ abstract class InfinispanRoutePolicyTestBase extends CamelTestSupport { Assert.assertFalse(policy2.isLeader()); context.stopRoute("route1"); - while(!policy2.isLeader()) { + while (!policy2.isLeader()) { Thread.sleep(250); } @@ -85,7 +85,7 @@ abstract class InfinispanRoutePolicyTestBase extends CamelTestSupport { Assert.assertTrue(policy2.isLeader()); context.stopRoute("route2"); - while(!policy1.isLeader()) { + while (!policy1.isLeader()) { Thread.sleep(250); }
