2
0
mirror of https://github.com/xcat2/confluent.git synced 2026-05-15 02:44:18 +00:00

Amend structure of AsyncMessage

This is an easier structure to traverse for a client.
This commit is contained in:
Jarrod Johnson
2016-03-19 17:25:47 -04:00
parent 8fac1ce5da
commit 75a747a6a2
+3 -2
View File
@@ -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):