I am not leaking them anywhere, but I think there are places where I am processing a message in a future but that is in the worker. So in the scheduler we may not need them. I will take a look at it and remove it if they are not necessary here. Thanks !