CAMEL-8681 Polish the code of InfinispanOperation
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/bc07f316 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/bc07f316 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/bc07f316 Branch: refs/heads/master Commit: bc07f3168863eda55a72247aac2f473f3890aff6 Parents: 105525e Author: Willem Jiang <willem.ji...@gmail.com> Authored: Wed Apr 22 15:02:26 2015 +0800 Committer: Willem Jiang <willem.ji...@gmail.com> Committed: Wed Apr 22 15:02:26 2015 +0800 ---------------------------------------------------------------------- .../infinispan/InfinispanOperation.java | 25 ++++++++++---------- 1 file changed, 12 insertions(+), 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/bc07f316/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanOperation.java ---------------------------------------------------------------------- diff --git a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanOperation.java b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanOperation.java index 3fb0a88..e53c715 100644 --- a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanOperation.java +++ b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanOperation.java @@ -59,12 +59,12 @@ public class InfinispanOperation { void execute(BasicCache<Object, Object> cache, Exchange exchange) { Object result; if (!ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME)) && !ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME_UNIT))) { - long lifespan = (long) exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME); - String timeUnit = (String) exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME_UNIT); + long lifespan = exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME, long.class); + String timeUnit = exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME_UNIT, String.class); if (!ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME)) && !ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT))) { - long maxIdle = (long) exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME); - String maxIdleTimeUnit = (String) exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT); + long maxIdle = exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME, long.class); + String maxIdleTimeUnit = (String) exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT, String.class); result = cache.put(getKey(exchange), getValue(exchange), lifespan, TimeUnit.valueOf(timeUnit), maxIdle, TimeUnit.valueOf(maxIdleTimeUnit)); } else { result = cache.put(getKey(exchange), getValue(exchange), lifespan, TimeUnit.valueOf(timeUnit)); @@ -77,14 +77,13 @@ public class InfinispanOperation { }, PUTALL { @Override void execute(BasicCache<Object, Object> cache, Exchange exchange) { - Object result; if (!ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME)) && !ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME_UNIT))) { - long lifespan = (long) exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME); - String timeUnit = (String) exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME_UNIT); + long lifespan = exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME, long.class); + String timeUnit = exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME_UNIT, String.class); if (!ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME)) && !ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT))) { - long maxIdle = (long) exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME); - String maxIdleTimeUnit = (String) exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT); + long maxIdle = exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME, long.class); + String maxIdleTimeUnit = exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT, String.class); cache.putAll(getMap(exchange), lifespan, TimeUnit.valueOf(timeUnit), maxIdle, TimeUnit.valueOf(maxIdleTimeUnit)); } else { cache.putAll(getMap(exchange), lifespan, TimeUnit.valueOf(timeUnit)); @@ -98,12 +97,12 @@ public class InfinispanOperation { void execute(BasicCache<Object, Object> cache, Exchange exchange) { Object result; if (!ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME)) && !ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME_UNIT))) { - long lifespan = (long) exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME); - String timeUnit = (String) exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME_UNIT); + long lifespan = exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME, long.class); + String timeUnit = exchange.getIn().getHeader(InfinispanConstants.LIFESPAN_TIME_UNIT, String.class); if (!ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME)) && !ObjectHelper.isEmpty(exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT))) { - long maxIdle = (long) exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME); - String maxIdleTimeUnit = (String) exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT); + long maxIdle = exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME, long.class); + String maxIdleTimeUnit = exchange.getIn().getHeader(InfinispanConstants.MAX_IDLE_TIME_UNIT, String.class); result = cache.putIfAbsent(getKey(exchange), getValue(exchange), lifespan, TimeUnit.valueOf(timeUnit), maxIdle, TimeUnit.valueOf(maxIdleTimeUnit)); } else { result = cache.putIfAbsent(getKey(exchange), getValue(exchange), lifespan, TimeUnit.valueOf(timeUnit));
