You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by bi...@apache.org on 2014/03/08 13:43:25 UTC
git commit: Use interface rather than concrete class during casting
Repository: camel
Updated Branches:
refs/heads/master 335e6f725 -> 7c21b39bf
Use interface rather than concrete class during casting
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/7c21b39b
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/7c21b39b
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/7c21b39b
Branch: refs/heads/master
Commit: 7c21b39bf713cec68b320405e25972a807607748
Parents: 335e6f7
Author: Bilgin Ibryam <bi...@apache.org>
Authored: Sat Mar 8 12:43:02 2014 +0000
Committer: Bilgin Ibryam <bi...@apache.org>
Committed: Sat Mar 8 12:43:02 2014 +0000
----------------------------------------------------------------------
.../component/infinispan/InfinispanConsumer.java | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/7c21b39b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConsumer.java b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConsumer.java
index b5051a6..cb5161a 100644
--- a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConsumer.java
+++ b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConsumer.java
@@ -20,7 +20,7 @@ import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.impl.DefaultConsumer;
import org.infinispan.Cache;
-import org.infinispan.manager.DefaultCacheManager;
+import org.infinispan.manager.EmbeddedCacheManager;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -28,7 +28,7 @@ public class InfinispanConsumer extends DefaultConsumer {
private static final transient Logger LOGGER = LoggerFactory.getLogger(InfinispanProducer.class);
private final InfinispanConfiguration configuration;
private final InfinispanSyncEventListener listener;
- private DefaultCacheManager defaultCacheManager;
+ private EmbeddedCacheManager cacheManager;
public InfinispanConsumer(InfinispanEndpoint endpoint, Processor processor, InfinispanConfiguration configuration) {
super(endpoint, processor);
@@ -56,13 +56,13 @@ public class InfinispanConsumer extends DefaultConsumer {
@Override
protected void doStart() throws Exception {
- if (configuration.getCacheContainer() instanceof DefaultCacheManager) {
- defaultCacheManager = (DefaultCacheManager) configuration.getCacheContainer();
+ if (configuration.getCacheContainer() instanceof EmbeddedCacheManager) {
+ cacheManager = (EmbeddedCacheManager) configuration.getCacheContainer();
Cache<Object, Object> cache;
if (configuration.getCacheName() != null) {
- cache = defaultCacheManager.getCache(configuration.getCacheName());
+ cache = cacheManager.getCache(configuration.getCacheName());
} else {
- cache = defaultCacheManager.getCache();
+ cache = cacheManager.getCache();
}
cache.addListener(listener);
} else {
@@ -73,8 +73,8 @@ public class InfinispanConsumer extends DefaultConsumer {
@Override
protected void doStop() throws Exception {
- if (defaultCacheManager != null) {
- defaultCacheManager.removeListener(listener);
+ if (cacheManager != null) {
+ cacheManager.removeListener(listener);
}
super.doStop();
}