@Experimental(value=SOURCE_SINK)
See: Description
| Interface | Description |
|---|---|
| AutoScaler |
Enables users to specify their own `JMS` backlog reporters enabling
JmsIO to report
UnboundedSource.UnboundedReader#getTotalBacklogBytes(). |
| JmsIO.MessageMapper<T> |
An interface used by
JmsIO.Read for converting each jms Message into an element
of the resulting PCollection. |
| Class | Description |
|---|---|
| DefaultAutoscaler |
Default implementation of
AutoScaler. |
| JmsIO |
An unbounded source for JMS destinations (queues or topics).
|
| JmsIO.Read<T> |
A
PTransform to read from a JMS destination. |
| JmsIO.Write<EventT> |
A
PTransform to write to a JMS queue. |
| JmsRecord |
JmsRecord contains message payload of the record as well as metadata (JMS headers and
properties).
|
| TextMessageMapper |
The TextMessageMapper takes a
String value, a Session and returns a
TextMessage. |
| WriteJmsResult<EventT> |
Return type of
JmsIO.Write transform. |
| Exception | Description |
|---|---|
| JmsIOException |