Use include_package instead of individual imports in Concurrency
Fixed an issue with lingering consumers in the integration specs
Publisher uses ConcurrentLinkedQueue instead of LinkedBlockingDeque for batch buffers