diff --git a/pyorient/messages/base.py b/pyorient/messages/base.py index 541817b..9b834e8 100644 --- a/pyorient/messages/base.py +++ b/pyorient/messages/base.py @@ -200,9 +200,9 @@ def _decode_header(self): # 80: \x50 Request Push 1 byte: Push command id push_command_id = self._decode_field(FIELD_BYTE) push_message = self._decode_field( FIELD_STRING ) - _, payload = self.get_serializer().decode(push_message) - if self._push_callback: - self._push_callback(push_command_id, payload) + # _, payload = self.get_serializer().decode(push_message) + # if self._push_callback: + # self._push_callback(push_command_id, payload) # self._cluster_map.set_hi_availability_list( # self._decode_field( FIELD_STRING ) @@ -214,9 +214,10 @@ def _decode_header(self): while end_flag == 3: self._decode_field( FIELD_INT ) # FAKE SESSION ID = 2^-31 self._decode_field( FIELD_BYTE ) # 80: 0x50 Request Push - self._cluster_map.set_hi_availability_list( - self._decode_field( FIELD_STRING ) - ) # JSON WITH THE NEW CLUSTER CFG + cluster_map_field = self._decode_field( FIELD_STRING ); + #self._cluster_map.set_hi_availability_list( + # cluster_map_field + #) # JSON WITH THE NEW CLUSTER CFG """ :type: self._cluster_map pyorient.messages.cluster.Information