Repository: camel Updated Branches: refs/heads/master e8976d138 -> a35caf738
CAMEL-10849: Salesforce: subscription channel ... ...created per component Adds logging of replayIds on channel subscription and refactors method `addTopicReplayId` to `addChannelReplayId` on `CometDReplayExtension` to reflect the true functionality of the method. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a35caf73 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a35caf73 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a35caf73 Branch: refs/heads/master Commit: a35caf738e703d6bb629afb7cb8039f4e0ddc43f Parents: e8976d1 Author: Zoran Regvart <zregv...@apache.org> Authored: Thu Feb 23 14:54:47 2017 +0100 Committer: Zoran Regvart <zregv...@apache.org> Committed: Fri Feb 24 10:09:41 2017 +0100 ---------------------------------------------------------------------- .../salesforce/internal/streaming/CometDReplayExtension.java | 4 ++-- .../salesforce/internal/streaming/SubscriptionHelper.java | 6 +++++- 2 files changed, 7 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/a35caf73/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/CometDReplayExtension.java ---------------------------------------------------------------------- diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/CometDReplayExtension.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/CometDReplayExtension.java index 3081804..f0156ef 100644 --- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/CometDReplayExtension.java +++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/CometDReplayExtension.java @@ -66,8 +66,8 @@ public class CometDReplayExtension extends Adapter { private final ConcurrentMap<String, Long> dataMap = new ConcurrentHashMap<>(); private final AtomicBoolean supported = new AtomicBoolean(); - public void addTopicReplayId(final String topicName, final long replayId) { - dataMap.put(topicName, replayId); + public void addChannelReplayId(final String channelName, final long replayId) { + dataMap.put(channelName, replayId); } @Override http://git-wip-us.apache.org/repos/asf/camel/blob/a35caf73/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java ---------------------------------------------------------------------- diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java index 1f593cf..fb5d454 100644 --- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java +++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java @@ -419,7 +419,11 @@ public class SubscriptionHelper extends ServiceSupport { if (replayId.isPresent()) { final String channelName = getChannelName(topicName); - REPLAY_EXTENSION.addTopicReplayId(channelName, replayId.get()); + final Long replayIdValue = replayId.get(); + + LOG.info("Set Replay extension to replay from `{}` for channel `{}`", replayIdValue, channelName); + + REPLAY_EXTENSION.addChannelReplayId(channelName, replayIdValue); } }
