You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2015/06/04 04:06:20 UTC
[38/50] [abbrv] storm git commit: Add initialization for
ResilientEventHubReceiver
Add initialization for ResilientEventHubReceiver
Otherwise, the recover logic will kick in for the first time.
Signed-off-by: Shanyu Zhao <sh...@microsoft.com>
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/9c2972ac
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/9c2972ac
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/9c2972ac
Branch: refs/heads/0.10.x-branch
Commit: 9c2972ac635ef5a7066b1abf19ffd5dc9e42718c
Parents: 86f326a
Author: Shanyu Zhao <sh...@microsoft.com>
Authored: Mon Jun 1 18:23:11 2015 -0700
Committer: Shanyu Zhao <sh...@microsoft.com>
Committed: Mon Jun 1 18:23:11 2015 -0700
----------------------------------------------------------------------
.../java/org/apache/storm/eventhubs/spout/EventHubReceiverImpl.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/9c2972ac/external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventHubReceiverImpl.java
----------------------------------------------------------------------
diff --git a/external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventHubReceiverImpl.java b/external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventHubReceiverImpl.java
index 7454af4..0fcad99 100755
--- a/external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventHubReceiverImpl.java
+++ b/external/storm-eventhubs/src/main/java/org/apache/storm/eventhubs/spout/EventHubReceiverImpl.java
@@ -71,6 +71,7 @@ public class EventHubReceiverImpl implements IEventHubReceiver {
long start = System.currentTimeMillis();
receiver = new ResilientEventHubReceiver(connectionString, entityName,
partitionId, consumerGroupName, defaultCredits, filter);
+ receiver.initialize();
long end = System.currentTimeMillis();
logger.info("created eventhub receiver, time taken(ms): " + (end-start));