Package com.bloomberg.bmq

Interface Summary

Interface	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.
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
MessageProperties	Interface to manipulate with message properties.
MessageProperty	Represents a message property, which is a name-value pair.
MessageProperty.BinaryProperty	Represents message property which value has type BINARY.
MessageProperty.BoolProperty	Represents a boolean message property.
MessageProperty.ByteProperty	Represents one byte message property.
MessageProperty.Int32Property	Represents message property which value has type INT32.
MessageProperty.Int64Property	Represents message property which value has type INT64.
MessageProperty.ShortProperty	Represents message property which value has type SHORT.
MessageProperty.StringProperty	Represents message property which value has type STRING.
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.CloseQueueResult	Close queue status event.
QueueControlEvent.ConfigureQueueResult	Configure queue status event.
QueueControlEvent.OpenQueueResult	Open queue status event.
QueueControlEvent.ReopenQueueResult	Reopen queue status event.
QueueControlEvent.ResumeQueueResult	Resume queue status event.
QueueControlEvent.SuspendQueueResult	Suspend queue status event.
QueueEvent	Represents a BlazingMQ event related to the particular queue state.
QueueEventHandler	User callback interface to handle queue related events.
ResultCodes.AckCode
ResultCodes.CloseQueueCode
ResultCodes.ConfigureQueueCode
ResultCodes.GenericCode
ResultCodes.OpenQueueCode
ResultCodes.OperationResultCode<RESULT extends ResultCodes.GenericCode>
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.
SessionEventHandler	User callback interface to handle session related events.

Class Summary

Class	Description
MessageGUID	Provides a value-semantic global unique identifier for BlazingMQ messages.
QueueOptions	A value-semantic type for options related to a queue.
QueueOptions.Builder	A helper class to create immutable QueueOptions with custom settings.
ResultCodes
Session	Provides access to the BlazingMQ broker.
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.

Enum Summary

Enum	Description
CompressionAlgorithm	PUT message payload compression algorithm
HostHealthState	Enumeration for different host health states
MessageProperty.Type	Enum for supported data types for a message property.
QueueControlEvent.Type
QueueFlags	Represents all the flags that can be used at AbstractSession.getQueue(com.bloomberg.bmq.Uri, long, com.bloomberg.bmq.QueueEventHandler, com.bloomberg.bmq.AckMessageHandler, com.bloomberg.bmq.PushMessageHandler).
ResultCodes.AckResult
ResultCodes.CloseQueueResult
ResultCodes.ConfigureQueueResult
ResultCodes.GenericResult
ResultCodes.OpenQueueResult
SessionEvent.Type	Session event types.

Exception Summary

Exception	Description
BMQException	A RuntimeException which is raised when any failure happens during BlazingMQ SDK call execution.