org.apache.ignite.stream.jms11

Interface MessageTransformer<T extends javax.jms.Message,K,V>

Type Parameters:

T - The type of JMS Message.

K - The type of the cache key.

V - The type of the cache value.

public interface MessageTransformer<T extends javax.jms.Message,K,V>

Implement this interface to transform from a Message to a set of cache entries in the form of a Map.

Method Summary

Modifier and Type	Method and Description
@Nullable Map<K,V>	apply(T message) Transformation function.

Method Detail

apply

@Nullable
@Nullable Map<K,V> apply(T message)

Transformation function.

Parameters:

message - The message received from the JMS broker.

Returns:

Set of cache entries to add to the cache. It could be empty or null if the message should be skipped.