All Classes

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