Uses of Package
com.bloomberg.bmq

Classes in com.bloomberg.bmq used by com.bloomberg.bmq

Class and Description
AbstractSession Interface to the Session that provides access to the BlazingMQ broker
AckMessage ACK message representation.
AckMessageHandler User callback interface to handle incoming ACK messages.
BMQException A RuntimeException which is raised when any failure happens during BlazingMQ SDK call execution.
CompressionAlgorithm PUT message payload compression algorithm
CorrelationId Provides an interface usable as an efficient identifier.
Event Represents a BlazingMQ event.
HostHealthMonitor Provides an interface for monitoring the health of the host.
HostHealthMonitor.Handler Provides an interface for handling changes detected by HostHealthMonitor
HostHealthState Enumeration for different host health states
MessageGUID Provides a value-semantic global unique identifier for BlazingMQ messages.
MessageProperties Interface to manipulate with message properties.
MessageProperty Represents a message property, which is a name-value pair.
MessageProperty.Type Enum for supported data types for a message property.
PushMessage PUSH message representation.
PushMessageHandler User callback interface to handle incoming PUSH messages.
PutMessage PUT message representation.
Queue SDK Queue representation.
QueueControlEvent Represents the queue related event that reports a status of asynchronous operation usually initiated by the user.
QueueControlEvent.Type
QueueEvent Represents a BlazingMQ event related to the particular queue state.
QueueEventHandler User callback interface to handle queue related events.
QueueFlags Represents all the flags that can be used at getQueue(com.bloomberg.bmq.Uri, long, com.bloomberg.bmq.QueueEventHandler, com.bloomberg.bmq.AckMessageHandler, com.bloomberg.bmq.PushMessageHandler).
QueueOptions A value-semantic type for options related to a queue.
QueueOptions.Builder A helper class to create immutable QueueOptions with custom settings.
ResultCodes.AckCode
ResultCodes.AckResult
ResultCodes.CloseQueueCode
ResultCodes.CloseQueueResult
ResultCodes.ConfigureQueueCode
ResultCodes.ConfigureQueueResult
ResultCodes.GenericCode
ResultCodes.GenericResult
ResultCodes.OpenQueueCode
ResultCodes.OpenQueueResult
ResultCodes.OperationResultCode
SessionEvent Represents a BlazingMQ event related to the whole session state.
SessionEvent.ConnectionLost Event that notifies the session has lost the broker connection.
SessionEvent.HostHealthRestored Event that notifies the health of the host has restored.
SessionEvent.HostUnhealthy Event that notifies the host has become unhealthy.
SessionEvent.Reconnected Event that notifies the session has restored the broker connection.
SessionEvent.SlowConsumerHighWatermark Event that notifies the inbound event buffer has reached the high watermark value.
SessionEvent.SlowConsumerNormal Event that notifies the inbound event buffer has reached the low watermark value.
SessionEvent.StartStatus Session start status event.
SessionEvent.StateRestored Event that notifies the session has restored the state of all opened queues.
SessionEvent.StopStatus Session stop status event.
SessionEvent.Type Session event types.
SessionEventHandler User callback interface to handle session related events.
SessionOptions A value-semantic type to configure session with the broker.
SessionOptions.Builder Helper class to create a SesssionOptions object with custom settings.
SessionOptions.InboundEventBufferWaterMark Immutable helper class to set sizes (in number of events) for the inbound event buffer high and low watermarks.
SessionOptions.WriteBufferWaterMark Immutable helper class to set sizes (in bytes) for write cache high and low watermarks on the channel.
Uri Provides value-semantic type and utilities for a BlazingMQ queue URI.