vertx / io.vertx.rxjava.ext.stomp

Package io.vertx.rxjava.ext.stomp

Types

Acknowledgement

open class Acknowledgement

Structure passed to acknowledgement handler called when a ACK or NACK frame is received. The handler receives an instance of io.vertx.rxjava.ext.stomp.Acknowledgement with the subscription io.vertx.ext.stomp.Frame and the impacted messages. The list of messages depends on the type of acknowledgment used by the subscription. Subscriptions using the client mode receives all messages that were waiting for acknowledgment that were sent before the acknowledged messages. The list also contains the acknowledged message. This is a cumulative acknowledgement. Subscriptions using the client-individual mode receives a singleton list containing only the acknowledged message. NOTE: This class has been automatically generated from the io.vertx.ext.stomp.Acknowledgement non RX-ified interface using Vert.x codegen.

Destination

open class Destination

Represents a STOMP destination. Depending on the implementation, the message delivery is different. Queue are sending message to only one subscribers, while topics are broadcasting the message to all subscribers. Implementations must be thread-safe. NOTE: This class has been automatically generated from the io.vertx.ext.stomp.Destination non RX-ified interface using Vert.x codegen.

DestinationFactory

open class DestinationFactory

Interface implemented to customize the destination creation. NOTE: This class has been automatically generated from the io.vertx.ext.stomp.DestinationFactory non RX-ified interface using Vert.x codegen.

Frames

open class Frames

Utility methods to build common io.vertx.ext.stomp.Frames. It defines a non-STOMP frame (PING) that is used for heartbeats. When such frame is written on the wire it is just the 0 byte. This class is thread-safe. NOTE: This class has been automatically generated from the io.vertx.ext.stomp.Frames non RX-ified interface using Vert.x codegen.

StompClientConnection

open class StompClientConnection

Once a connection to the STOMP server has been made, client receives a io.vertx.rxjava.ext.stomp.StompClientConnection, that let send and receive STOMP frames. NOTE: This class has been automatically generated from the io.vertx.ext.stomp.StompClientConnection non RX-ified interface using Vert.x codegen.

StompServer

open class StompServer

Defines a STOMP server. STOMP servers delegates to a io.vertx.rxjava.ext.stomp.StompServerHandler that let customize the behavior of the server. By default, it uses a handler compliant with the STOMP specification, but let you change anything. NOTE: This class has been automatically generated from the io.vertx.ext.stomp.StompServer non RX-ified interface using Vert.x codegen.