diff --git a/newrpc/__init__.py b/newrpc/__init__.py
index <HASH>..<HASH> 100644
--- a/newrpc/__init__.py
+++ b/newrpc/__init__.py
@@ -220,7 +220,7 @@ def iter_rpcresponses(queue, channel=None, timeout=None, **kwargs):
     for msg in qw:
         data = msg.payload
         if data['failure']:
-            raise RemoteError(**msg)
+            raise RemoteError(**data['failure'])
         elif data.get('ending', False):
             msg.ack()
             return
RemoteError change for kwargs