MQTT_DeserializePublish

Deserialize an MQTT PUBLISH packet.

MQTTStatus_t MQTT_DeserializePublish( const MQTTPacketInfo_t * pIncomingPacket,
                                      uint16_t * pPacketId,
                                      MQTTPublishInfo_t * pPublishInfo );

Parameters

[in]	pIncomingPacket	MQTTPacketInfo_t containing the buffer.
[out]	pPacketId	The packet ID obtained from the buffer.
[out]	pPublishInfo	Struct containing information about the publish.

Returns

MQTTBadParameter, MQTTBadResponse, or MQTTSuccess.

Example

// TransportRecv_t function for reading from the network.
int32_t socket_recv(
     NetworkContext_t * pNetworkContext,
     void * pBuffer,
     size_t bytesToRecv
);
// Some context to be used with the above transport receive function.
NetworkContext_t networkContext;
 
// Other variables used in this example.
MQTTStatus_t status;
MQTTPacketInfo_t incomingPacket;
MQTTPublishInfo_t publishInfo = { 0 };
uint16_t packetId;
 
int32_t bytesRecvd;
// A buffer to hold remaining data of the incoming packet.
uint8_t buffer[ BUFFER_SIZE ];
 
// Populate all fields of the incoming packet.
status = MQTT_GetIncomingPacketTypeAndLength(
     socket_recv,
     &networkContext,
     &incomingPacket
);
assert( status == MQTTSuccess );
assert( incomingPacket.remainingLength <= BUFFER_SIZE );
bytesRecvd = socket_recv(
     &networkContext,
     ( void * ) buffer,
     incomingPacket.remainingLength
);
incomingPacket.pRemainingData = buffer;
 
// Deserialize the publish information if the incoming packet is a publish.
if( ( incomingPacket.type & 0xF0 ) == MQTT_PACKET_TYPE_PUBLISH )
{
     status = MQTT_DeserializePublish( &incomingPacket, &packetId, &publishInfo );
     if( status == MQTTSuccess )
     {
         // The deserialized publish information can now be used from `publishInfo`.
     }
}