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

Interface JmsIO.MessageMapper<T>

All Superinterfaces:
Serializable
Enclosing class:
JmsIO
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public static interface JmsIO.MessageMapper<T> extends Serializable
An interface used by JmsIO.Read for converting each jms Message into an element of the resulting PCollection.

  • Method Summary

    Modifier and Type
    Method
    Description
    T
    mapMessage(javax.jms.Message message)
     

  • Method Details