Added method Receiving messages from queue with additionally putting unacked(unprocessed properly) messages in temporary queue with returning message in a proper queue after TTL.
Add Logstash (ElasticSearch) logger
Removed error return on callback error.
Queue implementation