com.solacesystems.jcsmp.serialization

Class Consumed

java.lang.Object

com.solacesystems.jcsmp.serialization.Consumed

public final class Consumed
extends Object

Utility class to create a message processing XMLMessageListener with a Deserializer.

Method Summary

Modifier and Type	Method and Description
static <T> XMLMessageListener	with(com.solace.serdes.Deserializer<T> deserializer, BiConsumer<BytesXMLMessage,T> onData, BiConsumer<BytesXMLMessage,RuntimeException> onDeserializationException, Consumer<JCSMPException> onListenerException) Creates an XMLMessageListener used by XMLMessageConsumer with lamda functions for message payload deserialize.

Methods inherited from class java.lang.Object

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

Method Detail

with

public static <T> XMLMessageListener with(com.solace.serdes.Deserializer<T> deserializer,
                                          BiConsumer<BytesXMLMessage,T> onData,
                                          BiConsumer<BytesXMLMessage,RuntimeException> onDeserializationException,
                                          Consumer<JCSMPException> onListenerException)

Creates an XMLMessageListener used by XMLMessageConsumer with lamda functions for message payload deserialize.

Type Parameters:

T - The generic type parameter for the onData callback method.

Parameters:

deserializer - The Deserializer of type T to process the user properties and payload of the message into an object. Must not be null.

onData - The BiConsumer callback to provide the original message and deserialized payload of type T. If null a noop callback is used instead.

onDeserializationException - The BiConsumer callback when message deserialize raises an exception. The message is provided to handle a processing failure to handle a message gracefully. If null a noop callback is used instead.

onListenerException - The Consumer callback that is equivalent to XMLMessageListener.onException(JCSMPException). If null a noop callback is used instead.

Returns:

XMLMessageListener instance to process messages into objects of type T.

Throws:

IllegalArgumentException - when deserializer is null.