Fixing disk buffer IO
Initial version of AMQP input module