Package org.apache.beam.sdk.io.jms

Class TextMessageMapper

java.lang.Object

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

All Implemented Interfaces:

Serializable, BiFunction<String,javax.jms.Session,javax.jms.Message>, SerializableBiFunction<String,javax.jms.Session,javax.jms.Message>

public class TextMessageMapper
extends Object
implements SerializableBiFunction<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	Description
TextMessageMapper()

Method Summary

Modifier and Type	Method	Description
javax.jms.Message	apply(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 Details

TextMessageMapper

public TextMessageMapper()

Method Details

apply

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

Specified by:

apply in interface BiFunction<String,javax.jms.Session,javax.jms.Message>