the pulished messages will be taken in as a byte stream , the mesage will be transformed into andesmessagepart as its required by the andes kernal for processing concode_field_sep String MESSAGE_ID concode_elem_sep String MESSAGE_CONTENT_LENGTH concode_elem_sep String MQTT_META_INFO concode_elem_sep String TOPIC concode_elem_sep String DESTINATION concode_elem_sep String SINGLE_LEVEL_WILDCARD concode_elem_sep String MULTI_LEVEL_WILDCARD concode_elem_sep String PERSISTENCE concode_elem_sep Log log concode_elem_sep String QOSLEVEL concode_field_sep long generateMessageID concode_elem_sep boolean isTargetQueueBoundByMatchingToRoutingKey concode_elem_sep AndesMessageMetadata convertToAndesHeader concode_elem_sep ByteBuffer getContentFromMetaInformation concode_elem_sep AbstractMessage.QOSType getMQTTQOSTypeFromInteger concode_elem_sep int convertMQTTProtocolTypeToInteger concode_elem_sep String generateTopicSpecficClientID concode_elem_sep byte[] encodeMetaInfo concode_elem_sep boolean isWildCardSubscription
AndesMessagePart function ( byte [ ] arg0 , long arg1 ) { AndesMessagePart loc0 = new AndesMessagePart ( ) ; loc0 . setOffSet ( 0 ) ; loc0 . setData ( arg0 ) ; loc0 . setMessageID ( arg1 ) ; loc0 . setDataLength ( arg0 . length ) ; return loc0 ; }