@Experimental(value=SOURCE_SINK)
See: Description
Interface | Description |
---|---|
JmsIO.MessageMapper<T> |
An interface used by
JmsIO.Read for converting each jms Message into an element
of the resulting PCollection . |
Class | Description |
---|---|
JmsIO |
An unbounded source for JMS destinations (queues or topics).
|
JmsIO.Read<T> |
A
PTransform to read from a JMS destination. |
JmsIO.Write |
A
PTransform to write to a JMS queue. |
JmsRecord |
JmsRecord contains message payload of the record as well as metadata (JMS headers and
properties).
|