- move amqp/em into a separate thread. - Things wanting to block until amqp/em are finished will still call   Socket#run, which now only blocks until the new amqp/em thread complete (with   Thread#join)
- move amqp/em into a separate thread.
- Things wanting to block until amqp/em are finished will still call
  Socket#run, which now only blocks until the new amqp/em thread complete (with
  Thread#join)


joekiller/logstash-kafka,Aloomaio/logstash-kafka,opentable/logstash-kafka,tinglinux/logstash-kafka,joekiller/logstash-kafka,opentable/logstash-kafka,Aloomaio/logstash-kafka,tinglinux/logstash-kafka