From 75a747a6a2c08c218145d4bdee4d90c582bdaa93 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Sat, 19 Mar 2016 17:25:47 -0400 Subject: [PATCH] Amend structure of AsyncMessage This is an easier structure to traverse for a client. --- confluent_server/confluent/messages.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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):