consumer implementation

This release has stable consumer implementation for default and dynamic using blocking queue with runtime consumer identification.