Because of the autoload functionality, errors in classes get swallowed causing the worker to hang and the message to sit unacked.
reproduce as such:
# app/services/bad_apple.rb
class BadApple
def incomplete_method_def
{
end
end
#app/consumers/sample_consumer.rb
class SampleConsumer
include Emque::Consuming.consumer
def message_handler(message)
BadApple.new
end
end