Package com.azure.spring.messaging.storage.queue.support.converter

Class StorageQueueMessageConverter

java.lang.Object

com.azure.spring.messaging.converter.AbstractAzureMessageConverter<com.azure.storage.queue.models.QueueMessageItem,com.azure.storage.queue.models.QueueMessageItem>

com.azure.spring.messaging.storage.queue.support.converter.StorageQueueMessageConverter

All Implemented Interfaces:

AzureMessageConverter<com.azure.storage.queue.models.QueueMessageItem,com.azure.storage.queue.models.QueueMessageItem>

public class StorageQueueMessageConverter
extends AbstractAzureMessageConverter<com.azure.storage.queue.models.QueueMessageItem,com.azure.storage.queue.models.QueueMessageItem>

A converter to turn a Message to QueueMessageItem and vice versa.

Constructor Summary

Constructors

Constructor	Description
StorageQueueMessageConverter()	Create an instance of StorageQueueMessageConverter.
StorageQueueMessageConverter(ObjectMapper objectMapper)	Create an instance of StorageQueueMessageConverter.

Method Summary

Modifier and Type	Method	Description
protected com.azure.storage.queue.models.QueueMessageItem	fromByte(byte[] payload)
protected com.azure.storage.queue.models.QueueMessageItem	fromString(String payload)
protected ObjectMapper	getObjectMapper()
protected byte[]	getPayload(com.azure.storage.queue.models.QueueMessageItem azureMessage)

Methods inherited from class com.azure.spring.messaging.converter.AbstractAzureMessageConverter

buildCustomHeaders, fromMessage, fromPayload, internalToMessage, setCustomHeaders, toMessage, toPayload

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.azure.spring.messaging.converter.AzureMessageConverter

toMessage

Constructor Details

StorageQueueMessageConverter

public StorageQueueMessageConverter()

Create an instance of StorageQueueMessageConverter.

StorageQueueMessageConverter

public StorageQueueMessageConverter(ObjectMapper objectMapper)

Create an instance of StorageQueueMessageConverter.

Parameters:

objectMapper - the object mapper.

Method Details

getObjectMapper

protected ObjectMapper getObjectMapper()

Specified by:

getObjectMapper in class AbstractAzureMessageConverter<com.azure.storage.queue.models.QueueMessageItem,com.azure.storage.queue.models.QueueMessageItem>

getPayload

protected byte[] getPayload(com.azure.storage.queue.models.QueueMessageItem azureMessage)

Specified by:

getPayload in class AbstractAzureMessageConverter<com.azure.storage.queue.models.QueueMessageItem,com.azure.storage.queue.models.QueueMessageItem>

fromString

protected com.azure.storage.queue.models.QueueMessageItem fromString(String payload)

Specified by:

fromString in class AbstractAzureMessageConverter<com.azure.storage.queue.models.QueueMessageItem,com.azure.storage.queue.models.QueueMessageItem>

fromByte

protected com.azure.storage.queue.models.QueueMessageItem fromByte(byte[] payload)

Specified by:

fromByte in class AbstractAzureMessageConverter<com.azure.storage.queue.models.QueueMessageItem,com.azure.storage.queue.models.QueueMessageItem>