diff --git a/confluent_server/confluent/messages.py b/confluent_server/confluent/messages.py
index 8233ae89..cb824755 100644
--- a/confluent_server/confluent/messages.py
+++ b/confluent_server/confluent/messages.py
@@ -850,8 +850,9 @@ class AsyncMessage(ConfluentMessage):
         self.msgpair = pair
 
     def raw(self):
-        return {'requestid': self.msgpair[0],
-                'response': self.msgpair[1].raw()}
+        return {'asyncresponse':
+            {'requestid': self.msgpair[0],
+             'response': self.msgpair[1].raw()}}
 
 class AsyncSession(ConfluentMessage):
     def __init__(self, id):