Currently for outbound http calls to external services, we wait for the request to complete before moving on to processing the next message/event. We should allow for a configurable concurrency value per channel, that allows us to make a certain amount of concurrent HTTP requests, to allow for faster processing.
Twisted's DeferredSemaphore might help us here. http://twistedmatrix.com/documents/current/api/twisted.internet.defer.DeferredSemaphore.html
Currently for outbound http calls to external services, we wait for the request to complete before moving on to processing the next message/event. We should allow for a configurable concurrency value per channel, that allows us to make a certain amount of concurrent HTTP requests, to allow for faster processing.
Twisted's DeferredSemaphore might help us here. http://twistedmatrix.com/documents/current/api/twisted.internet.defer.DeferredSemaphore.html