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>
- See Also:
-
Constructor Details
-
TextMessageMapper
public TextMessageMapper()
-
-
Method Details
-
apply
- Specified by:
apply
in interfaceBiFunction<String,
javax.jms.Session, javax.jms.Message>
-