org.apache.beam.sdk.io.jms

Class TextMessageMapper

java.lang.Object

org.apache.beam.sdk.io.jms.TextMessageMapper

All Implemented Interfaces:

java.io.Serializable, java.util.function.BiFunction<java.lang.String,javax.jms.Session,javax.jms.Message>, SerializableBiFunction<java.lang.String,javax.jms.Session,javax.jms.Message>

public class TextMessageMapper
extends java.lang.Object
implements SerializableBiFunction<java.lang.String,javax.jms.Session,javax.jms.Message>

The TextMessageMapper takes a String value, a Session and returns a TextMessage.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TextMessageMapper()

Method Summary

Modifier and Type	Method and Description
javax.jms.Message	apply(java.lang.String value, javax.jms.Session session)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.BiFunction

andThen

Constructor Detail

TextMessageMapper

public TextMessageMapper()

Method Detail

apply

public javax.jms.Message apply(java.lang.String value,
                               javax.jms.Session session)

Specified by:

apply in interface java.util.function.BiFunction<java.lang.String,javax.jms.Session,javax.jms.Message>