You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2015/07/09 12:51:10 UTC
camel git commit: CAMEL-8438: Allow end users to extend the repo
Repository: camel
Updated Branches:
refs/heads/master 0b75c4ebf -> 8673d5779
CAMEL-8438: Allow end users to extend the repo
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/8673d577
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/8673d577
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/8673d577
Branch: refs/heads/master
Commit: 8673d5779bce94af9042556e994c99261b64f1a0
Parents: 0b75c4e
Author: Claus Ibsen <da...@apache.org>
Authored: Thu Jul 9 12:57:36 2015 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Thu Jul 9 12:57:36 2015 +0200
----------------------------------------------------------------------
.../aggregate/hazelcast/HazelcastAggregationRepository.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/8673d577/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java
----------------------------------------------------------------------
diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java b/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java
index 66ba725..8b85b3a 100644
--- a/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java
+++ b/components/camel-hazelcast/src/main/java/org/apache/camel/processor/aggregate/hazelcast/HazelcastAggregationRepository.java
@@ -53,7 +53,7 @@ import org.slf4j.LoggerFactory;
* {@link HazelcastAggregationRepository} passing a reference to the instance.
*
*/
-public final class HazelcastAggregationRepository extends ServiceSupport
+public class HazelcastAggregationRepository extends ServiceSupport
implements RecoverableAggregationRepository,
OptimisticLockingAggregationRepository {
private static final Logger LOG = LoggerFactory.getLogger(HazelcastAggregationRepository.class.getName());
@@ -327,7 +327,6 @@ public final class HazelcastAggregationRepository extends ServiceSupport
TransactionContext tCtx = hzInstance.newTransactionContext(tOpts);
try {
-
tCtx.beginTransaction();
TransactionalMap<String, DefaultExchangeHolder> tCache = tCtx.getMap(cache.getName());
@@ -407,7 +406,7 @@ public final class HazelcastAggregationRepository extends ServiceSupport
}
}
- private Exchange unmarshallExchange(CamelContext camelContext, DefaultExchangeHolder holder) {
+ protected Exchange unmarshallExchange(CamelContext camelContext, DefaultExchangeHolder holder) {
Exchange exchange = null;
if (holder != null) {
exchange = new DefaultExchange(camelContext);