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 |
|---|---|
| JmsCheckpointMark |
Checkpoint for an unbounded JmsIO.Read.
|
| JmsIO |
An unbounded source for JMS destinations (queues or topics).
|
| JmsIO.Read<T> |
A
PTransform to read from a JMS destination. |
| JmsIO.UnboundedJmsSource<T> |
An unbounded JMS source.
|
| 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).
|