How to pass parameters to an implementation of IEventProcessor

You just need to use RegisterEventProcessorFactoryAsync to pass in a factory instance. That factory class can pass in whatever parameters are appropriate in the factory method possibly by passing them into the factory in the first place, or having the factory vary the behavior. In the code sketched out below you can see two parameters being passed into the IEventProcessor. One of them from the factory's parameters and the other is a counter of how many times the factory has been called.

class AzureStreamProcessor : IEventProcessor{     ....}class AzureStreamProcessorFactory : IEventProcessorFactory{    public AzureStreamProcessorFactory(string str)    {         this.randomString = str;    }    private string randomString;    private int numCreated = 0;    IEventProcessor IEventProcessorFactory.CreateEventProcessor(PartitionContext context)    {        return new AzureStreamProcessor(context, randomString, Interlocked.Increment(ref numCreated));    }}host.RegisterEventProcessorFactoryAsync(new AzureStreamProcessorFactory("a parameter"), options);

May be try doing a constructor dependency injection to the MyEventProcessor class with a parameter something like below.

     public class MyEventProcessor : IEventProcessor    {        Stopwatch checkpointStopWatch;                    //TODO: get provider id from parent class         IParameters _parameter;    public MyEventProcessor (IParameters param)    {      this._parameter  = param;     }        public async Task CloseAsync(PartitionContext context, CloseReason reason)        {            Debug.WriteLine("Processor Shutting Down. Partition '{0}', Reason: '{1}'.", context.Lease.PartitionId, reason);            if (reason == CloseReason.Shutdown)            {                await context.CheckpointAsync();            }        }.....

Use _parameter to retrieve what you need.

below is how you can register the dependencies for your IParameters

Here i use Ninject dependency resolver.

//Bind the class that implements IParameter. var parameters = new Parameter();paramters.Property = "my data" kernel.Bind<IParameters>().ToConstant(parameters);

hope that helps