diff --git a/lib/ruote-amqp/receiver.rb b/lib/ruote-amqp/receiver.rb
index 2d96a98..b8c7f57 100644
--- a/lib/ruote-amqp/receiver.rb
+++ b/lib/ruote-amqp/receiver.rb
@@ -111,6 +111,12 @@ module RuoteAMQP

       return unless item.is_a?(Hash)

+      if item.has_key('fields') and item['fields'].has_key('__error__')
+        @context.error_handler.action_handle('dispatch', item,
+                                             ReceiveError.new(msg['fields']['__error__']))
+        return
+      end
+
       not_li = ! item.has_key?('definition')