Add initialization for ResilientEventHubReceiver Otherwise, the recover logic will kick in for the first time.
Signed-off-by: Shanyu Zhao <[email protected]> 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/master Commit: 9c2972ac635ef5a7066b1abf19ffd5dc9e42718c Parents: 86f326a Author: Shanyu Zhao <[email protected]> Authored: Mon Jun 1 18:23:11 2015 -0700 Committer: Shanyu Zhao <[email protected]> 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));
