shims/qpid-proton-python/src/jms_hdrs_props_test/Receiver.py [220:282]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - assert self.jms_msg_type == 'JMS_OBJECTMESSAGE_TYPE' assert message.annotations[QPID_JMS_TYPE_ANNOTATION_NAME] == proton.byte(1) return self._get_java_obj(message.body) def _get_java_obj(self, java_obj_bytes): """ Take bytes from serialized Java object and construct a Java object, then return its toString() value. The work of 'translating' the bytes to a Java object and obtaining its class and value is done in a Java utility org.apache.qpid.interop_test.obj_util.BytesToJavaObj located in jar JavaObjUtils.jar. java_obj_bytes: hex string representation of bytes from Java object (eg 'aced00057372...') returns: string containing Java class value as returned by the toString() method """ java_obj_bytes_str = ''.join(["%02x" % ord(x) for x in java_obj_bytes]).strip() out_str = subprocess.check_output(['java', '-cp', 'target/JavaObjUtils.jar', 'org.apache.qpid.interop_test.obj_util.BytesToJavaObj', java_obj_bytes_str]) out_str_list = out_str.split('\n')[:-1] # remove trailing \n if len(out_str_list) > 1: raise InteropTestError('Unexpected return from JavaObjUtils: %s' % out_str) colon_index = out_str_list[0].index(':') if colon_index < 0: raise InteropTestError('Unexpected format from JavaObjUtils: %s' % out_str) java_class_name = out_str_list[0][:colon_index] java_class_value_str = out_str_list[0][colon_index+1:] if java_class_name != self.current_subtype: raise InteropTestError('Unexpected class name from JavaObjUtils: expected %s, recieved %s' % (self.current_subtype, java_class_name)) return java_class_value_str def _receive_jms_streammessage(self, message): """Receives a JMS stream message""" assert self.jms_msg_type == 'JMS_STREAMMESSAGE_TYPE' assert message.annotations[QPID_JMS_TYPE_ANNOTATION_NAME] == proton.byte(4) # Every message is a list with one item [value] assert len(message.body) == 1 value = message.body[0] if self.current_subtype == 'boolean': return str(value) if self.current_subtype == 'byte': return hex(value) if self.current_subtype == 'bytes': return base64.b64encode(value).decode('utf-8') if self.current_subtype == 'char': return base64.b64encode(bytes(value, 'utf-8')).decode('utf-8') if self.current_subtype == 'double': return '0x%016x' % struct.unpack('!Q', struct.pack('!d', value))[0] if self.current_subtype == 'float': return '0x%08x' % struct.unpack('!L', struct.pack('!f', value))[0] if self.current_subtype == 'int': return hex(value) if self.current_subtype == 'long': return hex(int(value)) if self.current_subtype == 'short': return hex(value) if self.current_subtype == 'string': return str(value) raise InteropTestError('JmsRecieverShim._receive_jms_streammessage(): ' + 'JMS message type %s: Unknown or unsupported subtype \'%s\'' % (self.jms_msg_type, self.current_subtype)) def _receive_jms_textmessage(self, message): - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - shims/qpid-proton-python/src/jms_messages_test/Receiver.py [205:267]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - assert self.jms_msg_type == 'JMS_OBJECTMESSAGE_TYPE' assert message.annotations[QPID_JMS_TYPE_ANNOTATION_NAME] == proton.byte(1) return self._get_java_obj(message.body) def _get_java_obj(self, java_obj_bytes): """ Take bytes from serialized Java object and construct a Java object, then return its toString() value. The work of 'translating' the bytes to a Java object and obtaining its class and value is done in a Java utility org.apache.qpid.interop_test.obj_util.BytesToJavaObj located in jar JavaObjUtils.jar. java_obj_bytes: hex string representation of bytes from Java object (eg 'aced00057372...') returns: string containing Java class value as returned by the toString() method """ java_obj_bytes_str = ''.join(["%02x" % ord(x) for x in java_obj_bytes]).strip() out_str = subprocess.check_output(['java', '-cp', 'target/JavaObjUtils.jar', 'org.apache.qpid.interop_test.obj_util.BytesToJavaObj', java_obj_bytes_str]) out_str_list = out_str.split('\n')[:-1] # remove trailing \n if len(out_str_list) > 1: raise InteropTestError('Unexpected return from JavaObjUtils: %s' % out_str) colon_index = out_str_list[0].index(':') if colon_index < 0: raise InteropTestError('Unexpected format from JavaObjUtils: %s' % out_str) java_class_name = out_str_list[0][:colon_index] java_class_value_str = out_str_list[0][colon_index+1:] if java_class_name != self.current_subtype: raise InteropTestError('Unexpected class name from JavaObjUtils: expected %s, recieved %s' % (self.current_subtype, java_class_name)) return java_class_value_str def _receive_jms_streammessage(self, message): """Receives a JMS stream message""" assert self.jms_msg_type == 'JMS_STREAMMESSAGE_TYPE' assert message.annotations[QPID_JMS_TYPE_ANNOTATION_NAME] == proton.byte(4) # Every message is a list with one item [value] assert len(message.body) == 1 value = message.body[0] if self.current_subtype == 'boolean': return str(value) if self.current_subtype == 'byte': return hex(value) if self.current_subtype == 'bytes': return base64.b64encode(value).decode('utf-8') if self.current_subtype == 'char': return base64.b64encode(bytes(value, 'utf-8')).decode('utf-8') if self.current_subtype == 'double': return '0x%016x' % struct.unpack('!Q', struct.pack('!d', value))[0] if self.current_subtype == 'float': return '0x%08x' % struct.unpack('!L', struct.pack('!f', value))[0] if self.current_subtype == 'int': return hex(value) if self.current_subtype == 'long': return hex(int(value)) if self.current_subtype == 'short': return hex(value) if self.current_subtype == 'string': return str(value) raise InteropTestError('JmsRecieverShim._receive_jms_streammessage(): ' + 'JMS message type %s: Unknown or unsupported subtype \'%s\'' % (self.jms_msg_type, self.current_subtype)) def _receive_jms_textmessage(self, message): - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -