com.solace.messaging.util

Class MessageToSDTMapConverter

java.lang.Object

com.solace.messaging.util.MessageToSDTMapConverter

All Implemented Interfaces:

Converter, Converter.BytesToObject<SolaceSDTMap>, com.solace.messaging.util.internal.SolaceTypeConverter.MessageToSolaceType<SolaceSDTMap>

@ProviderType
public class MessageToSDTMapConverter
extends Object
implements com.solace.messaging.util.internal.SolaceTypeConverter.MessageToSolaceType<SolaceSDTMap>, Converter.BytesToObject<SolaceSDTMap>

Message payload converter to be used for receiving messages with JCSMP legacy SDTMap type. The following example illustrates use of MessageToSDTMapConverter with the InboundMessage#getAndConvertPayload(BytesToObject, Class).

    final MessagingService service; //Assuming service instance is initialized
    final DirectMessageReceiver receiver = service
      .createDirectMessageReceiverBuilder()
      .withSubscriptions(TopicSubscription.of("some/topic"))
       .build().start();

    final SolaceSDTMap map = receiver.receiveMessage()
         .getAndConvertPayload(new MessageToSDTMapConverter(), SolaceSDTMap.class);
 

For corresponding publisher sample refer to the SolaceSDTMapToMessageConverter

Nested Class Summary

Nested classes/interfaces inherited from interface com.solace.messaging.util.Converter

Converter.BytesToObject<T extends Serializable>, Converter.ObjectToBytes<T extends Serializable>

Constructor Summary

Constructors

Constructor and Description
MessageToSDTMapConverter()

Method Summary

Modifier and Type	Method and Description
SolaceSDTMap	convert(byte[] src) Converts the provided byte-array to the specified type.
SolaceSDTMap	get(com.solacesystems.jcsmp.BytesXMLMessage message)

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageToSDTMapConverter

public MessageToSDTMapConverter()

Method Detail

convert

public SolaceSDTMap convert(byte[] src)
                     throws PubSubPlusClientException.IncompatibleMessageException

Description copied from interface: Converter.BytesToObject

Converts the provided byte-array to the specified type.

Specified by:

convert in interface Converter.BytesToObject<SolaceSDTMap>

Parameters:

src - a byte-array; a null check on this parameter is required in the implementation of this method

Returns:

a business object reconstructed from the specified byte-array

Throws:

PubSubPlusClientException.IncompatibleMessageException - if an incompatible message payload is found

get

public SolaceSDTMap get(com.solacesystems.jcsmp.BytesXMLMessage message)
                 throws PubSubPlusClientException.IncompatibleMessageException

Specified by:

get in interface com.solace.messaging.util.internal.SolaceTypeConverter.MessageToSolaceType<SolaceSDTMap>

Throws:

PubSubPlusClientException.IncompatibleMessageException