locked
Getting error while registering event-processor to ErrorEventHubProcessorHost . RRS feed

  • Question

  • Hi, I am writing a pub-sub application using event hub; for subscriber I have created a class "EventHubEventProcessor" implementing IEventProcessor and registering this to EventProcessorHost like below 

    ---------------

    ConnectionStringBuilder eventHubConnectionString = new ConnectionStringBuilder(namespaceName, eventHubName, sasKeyName, sasKey); 

            EventProcessorHost host = new EventProcessorHost(subscriber.getSubName(), eventHubName, consumerGroupName, eventHubConnectionString.toString(), storageConnectionString, storageAccountName);

           

            EventProcessorOptions options = new EventProcessorOptions();

            options.setExceptionNotification(new EventHubErrorNotificationHandler());

            

            EventHubEventProcessor.setHandler(subscriber, commitIntervel);

            try

            {

                host.registerEventProcessor(EventHubEventProcessor.class, options).get();

            }

            catch (Exception e)

            {

                System.out.print("Failure while registering: ");

                if (e instanceof ExecutionException)

                {

                    Throwable inner = e.getCause();

                    System.out.println(inner.toString());

                }

                else

                {

                    System.out.println(e.toString());

                }

            }

    ------------------

    I get below error and not able to register the event processor. I am running my application inside OSGI container.  

    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: Failure creating lease for partition, retrying
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: Caught java.util.concurrent.ExecutionException: java.lang.RuntimeException: Unable to invoke no-args constructor for class com.microsoft.azure.eventprocessorhost.AzureBlobLease. Register an InstanceCreator with Gson for this type may fix this problem.
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.report(FutureTask.java:122)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.get(FutureTask.java:192)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.PartitionManager.retryWrapper(PartitionManager.java:300)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.PartitionManager.initializeStores(PartitionManager.java:268)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.PartitionManager.initialize(PartitionManager.java:161)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.EventProcessorHost.lambda$registerEventProcessorFactory$0(EventProcessorHost.java:509)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.run(FutureTask.java:266)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.lang.Thread.run(Thread.java:745)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: Inner exception java.lang.RuntimeException: Unable to invoke no-args constructor for class com.microsoft.azure.eventprocessorhost.AzureBlobLease. Register an InstanceCreator with Gson for this type may fix this problem.
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.internal.ConstructorConstructor$12.construct(ConstructorConstructor.java:210)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$Adapter.read(ReflectiveTypeAdapterFactory.java:162)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:803)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:768)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:717)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:689)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.downloadLease(AzureStorageCheckpointLeaseManager.java:549)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.getLeaseSync(AzureStorageCheckpointLeaseManager.java:306)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.createLeaseIfNotExistsSync(AzureStorageCheckpointLeaseManager.java:351)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.lambda$createLeaseIfNotExists$8(AzureStorageCheckpointLeaseManager.java:327)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.run(FutureTask.java:266)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.lang.Thread.run(Thread.java:745)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: Failure creating lease for partition, retrying
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: Caught java.util.concurrent.ExecutionException: java.lang.RuntimeException: Unable to invoke no-args constructor for class com.microsoft.azure.eventprocessorhost.AzureBlobLease. Register an InstanceCreator with Gson for this type may fix this problem.
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.report(FutureTask.java:122)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.get(FutureTask.java:192)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.PartitionManager.retryWrapper(PartitionManager.java:300)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.PartitionManager.initializeStores(PartitionManager.java:268)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.PartitionManager.initialize(PartitionManager.java:161)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.EventProcessorHost.lambda$registerEventProcessorFactory$0(EventProcessorHost.java:509)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.run(FutureTask.java:266)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.lang.Thread.run(Thread.java:745)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: Inner exception java.lang.RuntimeException: Unable to invoke no-args constructor for class com.microsoft.azure.eventprocessorhost.AzureBlobLease. Register an InstanceCreator with Gson for this type may fix this problem.
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.internal.ConstructorConstructor$12.construct(ConstructorConstructor.java:210)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$Adapter.read(ReflectiveTypeAdapterFactory.java:162)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:803)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:768)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:717)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:689)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.downloadLease(AzureStorageCheckpointLeaseManager.java:549)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.getLeaseSync(AzureStorageCheckpointLeaseManager.java:306)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.createLeaseIfNotExistsSync(AzureStorageCheckpointLeaseManager.java:351)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.lambda$createLeaseIfNotExists$8(AzureStorageCheckpointLeaseManager.java:327)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.run(FutureTask.java:266)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.lang.Thread.run(Thread.java:745)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: Failure creating lease for partition, retrying
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: Caught java.util.concurrent.ExecutionException: java.lang.RuntimeException: Unable to invoke no-args constructor for class com.microsoft.azure.eventprocessorhost.AzureBlobLease. Register an InstanceCreator with Gson for this type may fix this problem.
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.report(FutureTask.java:122)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.get(FutureTask.java:192)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.PartitionManager.retryWrapper(PartitionManager.java:300)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.PartitionManager.initializeStores(PartitionManager.java:268)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.PartitionManager.initialize(PartitionManager.java:161)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.EventProcessorHost.lambda$registerEventProcessorFactory$0(EventProcessorHost.java:509)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.run(FutureTask.java:266)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.lang.Thread.run(Thread.java:745)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: Inner exception java.lang.RuntimeException: Unable to invoke no-args constructor for class com.microsoft.azure.eventprocessorhost.AzureBlobLease. Register an InstanceCreator with Gson for this type may fix this problem.
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.internal.ConstructorConstructor$12.construct(ConstructorConstructor.java:210)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$Adapter.read(ReflectiveTypeAdapterFactory.java:162)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:803)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:768)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:717)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:689)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.downloadLease(AzureStorageCheckpointLeaseManager.java:549)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.getLeaseSync(AzureStorageCheckpointLeaseManager.java:306)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.createLeaseIfNotExistsSync(AzureStorageCheckpointLeaseManager.java:351)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.lambda$createLeaseIfNotExists$8(AzureStorageCheckpointLeaseManager.java:327)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.run(FutureTask.java:266)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.lang.Thread.run(Thread.java:745)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: Failure creating lease for partition, retrying
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: Caught java.util.concurrent.ExecutionException: java.lang.RuntimeException: Unable to invoke no-args constructor for class com.microsoft.azure.eventprocessorhost.AzureBlobLease. Register an InstanceCreator with Gson for this type may fix this problem.
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.report(FutureTask.java:122)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.get(FutureTask.java:192)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.PartitionManager.retryWrapper(PartitionManager.java:300)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.PartitionManager.initializeStores(PartitionManager.java:268)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.PartitionManager.initialize(PartitionManager.java:161)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.EventProcessorHost.lambda$registerEventProcessorFactory$0(EventProcessorHost.java:509)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.run(FutureTask.java:266)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.lang.Thread.run(Thread.java:745)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: Inner exception java.lang.RuntimeException: Unable to invoke no-args constructor for class com.microsoft.azure.eventprocessorhost.AzureBlobLease. Register an InstanceCreator with Gson for this type may fix this problem.
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.internal.ConstructorConstructor$12.construct(ConstructorConstructor.java:210)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$Adapter.read(ReflectiveTypeAdapterFactory.java:162)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:803)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:768)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:717)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:689)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.downloadLease(AzureStorageCheckpointLeaseManager.java:549)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.getLeaseSync(AzureStorageCheckpointLeaseManager.java:306)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.createLeaseIfNotExistsSync(AzureStorageCheckpointLeaseManager.java:351)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.lambda$createLeaseIfNotExists$8(AzureStorageCheckpointLeaseManager.java:327)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.run(FutureTask.java:266)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.lang.Thread.run(Thread.java:745)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: Failure creating lease for partition, retrying
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: Caught java.util.concurrent.ExecutionException: java.lang.RuntimeException: Unable to invoke no-args constructor for class com.microsoft.azure.eventprocessorhost.AzureBlobLease. Register an InstanceCreator with Gson for this type may fix this problem.
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.report(FutureTask.java:122)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.get(FutureTask.java:192)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.PartitionManager.retryWrapper(PartitionManager.java:300)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.PartitionManager.initializeStores(PartitionManager.java:268)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.PartitionManager.initialize(PartitionManager.java:161)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.EventProcessorHost.lambda$registerEventProcessorFactory$0(EventProcessorHost.java:509)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.run(FutureTask.java:266)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.lang.Thread.run(Thread.java:745)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: Inner exception java.lang.RuntimeException: Unable to invoke no-args constructor for class com.microsoft.azure.eventprocessorhost.AzureBlobLease. Register an InstanceCreator with Gson for this type may fix this problem.
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.internal.ConstructorConstructor$12.construct(ConstructorConstructor.java:210)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$Adapter.read(ReflectiveTypeAdapterFactory.java:162)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:803)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:768)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:717)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.google.gson.Gson.fromJson(Gson.java:689)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.downloadLease(AzureStorageCheckpointLeaseManager.java:549)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.getLeaseSync(AzureStorageCheckpointLeaseManager.java:306)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.createLeaseIfNotExistsSync(AzureStorageCheckpointLeaseManager.java:351)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: com.microsoft.azure.eventprocessorhost.AzureStorageCheckpointLeaseManager.lambda$createLeaseIfNotExists$8(AzureStorageCheckpointLeaseManager.java:327)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.FutureTask.run(FutureTask.java:266)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    WARNING: host callsubscriber: partition 0: java.lang.Thread.run(Thread.java:745)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    SEVERE: host callsubscriber: partition 0: Out of retries creating lease for partition
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    SEVERE: host callsubscriber: Exception while initializing stores (Creating Lease), not starting partition manager
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    SEVERE: host callsubscriber: Caught java.lang.RuntimeException: Out of retries creating lease for partition
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    SEVERE: host callsubscriber: com.microsoft.azure.eventprocessorhost.PartitionManager.retryWrapper(PartitionManager.java:326)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    SEVERE: host callsubscriber: com.microsoft.azure.eventprocessorhost.PartitionManager.initializeStores(PartitionManager.java:268)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    SEVERE: host callsubscriber: com.microsoft.azure.eventprocessorhost.PartitionManager.initialize(PartitionManager.java:161)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    SEVERE: host callsubscriber: com.microsoft.azure.eventprocessorhost.EventProcessorHost.lambda$registerEventProcessorFactory$0(EventProcessorHost.java:509)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    SEVERE: host callsubscriber: java.util.concurrent.FutureTask.run(FutureTask.java:266)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    SEVERE: host callsubscriber: java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    SEVERE: host callsubscriber: java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    Apr 29, 2017 12:35:54 AM com.microsoft.azure.eventprocessorhost.EventProcessorHost log
    SEVERE: host callsubscriber: java.lang.Thread.run(Thread.java:745)
    Failure while registering: com.microsoft.azure.eventprocessorhost.ExceptionWithAction: java.lang.RuntimeException: Out of retries creating lease for partition

    Friday, April 28, 2017 7:36 PM