lib/pushyd/consumer.rb in pushyd-0.20.0 vs lib/pushyd/consumer.rb in pushyd-0.20.1
- old
+ new
@@ -43,9 +43,12 @@
# Relay data if needed
handle_relay context, message, headers
# Handle errors and acknowledgments
# log_debug "handle_message : channel[#{@channel.inspect}]"
+ rescue Exception => e
+ log_error "handle_message: EXCEPTION: #{e.message}, #{e.inspect}", e.backtrace
+ channel_ackit(message[:tag], false)
rescue StandardError => e
log_error "handle_message: unknown: #{e.message}, #{e.inspect}", e.backtrace
channel_ackit(message[:tag], false)
else
channel_ackit(message[:tag], true)