camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject camel git commit: CAMEL-8438: Allow end users to extend the repo
Date Thu, 09 Jul 2015 10:51:10 GMT
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 <davsclaus@apache.org>
Authored: Thu Jul 9 12:57:36 2015 +0200
Committer: Claus Ibsen <davsclaus@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);


Mime
View raw message