- handleAckMessage(AckMessage) - Method in interface com.bloomberg.bmq.AckMessageHandler
-
User specified ACK message handler.
- handleConnectionLostSessionEvent(SessionEvent.ConnectionLost) - Method in interface com.bloomberg.bmq.SessionEventHandler
-
- handleHostHealthRestoredSessionEvent(SessionEvent.HostHealthRestored) - Method in interface com.bloomberg.bmq.SessionEventHandler
-
- handleHostUnhealthySessionEvent(SessionEvent.HostUnhealthy) - Method in interface com.bloomberg.bmq.SessionEventHandler
-
- handlePushMessage(PushMessage) - Method in interface com.bloomberg.bmq.PushMessageHandler
-
User specified PUSH message handler.
- handleQueueEvent(QueueControlEvent) - Method in interface com.bloomberg.bmq.QueueEventHandler
-
User specified handler for the queue events.
- handleReconnectedSessionEvent(SessionEvent.Reconnected) - Method in interface com.bloomberg.bmq.SessionEventHandler
-
- handleSessionEvent(SessionEvent) - Method in interface com.bloomberg.bmq.SessionEventHandler
-
User specified handler for session events.
- handleSlowConsumerHighWatermarkEvent(SessionEvent.SlowConsumerHighWatermark) - Method in interface com.bloomberg.bmq.SessionEventHandler
-
- handleSlowConsumerNormalEvent(SessionEvent.SlowConsumerNormal) - Method in interface com.bloomberg.bmq.SessionEventHandler
-
- handleStartStatusSessionEvent(SessionEvent.StartStatus) - Method in interface com.bloomberg.bmq.SessionEventHandler
-
- handleStateRestoredSessionEvent(SessionEvent.StateRestored) - Method in interface com.bloomberg.bmq.SessionEventHandler
-
- handleStopStatusSessionEvent(SessionEvent.StopStatus) - Method in interface com.bloomberg.bmq.SessionEventHandler
-
- hasConsumerPriority() - Method in class com.bloomberg.bmq.QueueOptions
-
Returns whether consumerPriority has been set for this object, or whether it
implicitly holds k_CONSUMER_PRIORITY_DEFAULT.
- hashCode() - Method in class com.bloomberg.bmq.MessageGUID
-
Returns a hash code value for this MessageGUID object.
- hashCode() - Method in class com.bloomberg.bmq.QueueOptions
-
Returns a hash code value for this QueueOptions object.
- hashCode() - Method in class com.bloomberg.bmq.Uri
-
Returns a hash code value for this Uri object.
- hasMaxUnconfirmedBytes() - Method in class com.bloomberg.bmq.QueueOptions
-
Returns whether maxUnconfirmedBytes has been set for this object, or whether it
implicitly holds k_MAX_UNCONFIRMED_BYTES_DEFAULT.
- hasMaxUnconfirmedMessages() - Method in class com.bloomberg.bmq.QueueOptions
-
Returns whether maxUnconfirmedMessages has been set for this object, or whether it
implicitly holds k_MAX_UNCONFIRMED_MESSAGES_DEFAULT.
- hasMessageProperties() - Method in interface com.bloomberg.bmq.PushMessage
-
Returns true if the application data of this message contains message properties.
- hasSuspendsOnBadHostHealth() - Method in class com.bloomberg.bmq.QueueOptions
-
Returns whether suspendsOnBadHostHealth has been set for this object, or whether it
implicitly holds k_SUSPENDS_ON_BAD_HOST_HEALTH_DEFAULT.
- highWaterMark() - Method in class com.bloomberg.bmq.SessionOptions.InboundEventBufferWaterMark
-
Returns HWM value.
- highWaterMark() - Method in class com.bloomberg.bmq.SessionOptions.WriteBufferWaterMark
-
Returns HWM value.
- HostHealthMonitor - Interface in com.bloomberg.bmq
-
Provides an interface for monitoring the health of the host.
- hostHealthMonitor() - Method in class com.bloomberg.bmq.SessionOptions
-
Returns an object which monitors the health of the host.
- HostHealthMonitor.Handler - Interface in com.bloomberg.bmq
-
Provides an interface for handling changes detected by HostHealthMonitor
- hostHealthState() - Method in interface com.bloomberg.bmq.HostHealthMonitor
-
Queries the current health of the host
- HostHealthState - Enum in com.bloomberg.bmq
-
Enumeration for different host health states
- scheme() - Method in class com.bloomberg.bmq.Uri
-
Returns scheme part of the URI in terms of the URI RFC terminology.
- session() - Method in interface com.bloomberg.bmq.Event
-
Returns interface to the session that has generated this event.
- Session - Class in com.bloomberg.bmq
-
Provides access to the BlazingMQ broker.
- Session(SessionEventHandler) - Constructor for class com.bloomberg.bmq.Session
-
Creates a new session object with default session options.
- Session(SessionOptions, SessionEventHandler) - Constructor for class com.bloomberg.bmq.Session
-
Creates a new session object.
- SessionEvent - Interface in com.bloomberg.bmq
-
Represents a BlazingMQ event related to the whole session state.
- SessionEvent.ConnectionLost - Interface in com.bloomberg.bmq
-
Event that notifies the session has lost the broker connection.
- SessionEvent.HostHealthRestored - Interface in com.bloomberg.bmq
-
Event that notifies the health of the host has restored.
- SessionEvent.HostUnhealthy - Interface in com.bloomberg.bmq
-
Event that notifies the host has become unhealthy.
- SessionEvent.Reconnected - Interface in com.bloomberg.bmq
-
Event that notifies the session has restored the broker connection.
- SessionEvent.SlowConsumerHighWatermark - Interface in com.bloomberg.bmq
-
Event that notifies the inbound event buffer has reached the high watermark value.
- SessionEvent.SlowConsumerNormal - Interface in com.bloomberg.bmq
-
Event that notifies the inbound event buffer has reached the low watermark value.
- SessionEvent.StartStatus - Interface in com.bloomberg.bmq
-
Session start status event.
- SessionEvent.StateRestored - Interface in com.bloomberg.bmq
-
Event that notifies the session has restored the state of all opened queues.
- SessionEvent.StopStatus - Interface in com.bloomberg.bmq
-
Session stop status event.
- SessionEvent.Type - Enum in com.bloomberg.bmq
-
Session event types.
- SessionEventHandler - Interface in com.bloomberg.bmq
-
User callback interface to handle session related events.
- SessionOptions - Class in com.bloomberg.bmq
-
A value-semantic type to configure session with the broker.
- SessionOptions.Builder - Class in com.bloomberg.bmq
-
Helper class to create a SesssionOptions object with custom settings.
- SessionOptions.InboundEventBufferWaterMark - Class in com.bloomberg.bmq
-
Immutable helper class to set sizes (in number of events) for the inbound event buffer high
and low watermarks.
- SessionOptions.WriteBufferWaterMark - Class in com.bloomberg.bmq
-
Immutable helper class to set sizes (in bytes) for write cache high and low watermarks on the
channel.
- setAck(long) - Static method in enum com.bloomberg.bmq.QueueFlags
-
Sets the specified flags representation for ack.
- setAdmin(long) - Static method in enum com.bloomberg.bmq.QueueFlags
-
Sets the specified flags representation for admin.
- setBrokerUri(URI) - Method in class com.bloomberg.bmq.SessionOptions.Builder
-
Sets URI to connect with the broker.
- setCloseQueueTimeout(Duration) - Method in class com.bloomberg.bmq.SessionOptions.Builder
-
Sets timeout value for close queue operation
- setCompressionAlgorithm(CompressionAlgorithm) - Method in interface com.bloomberg.bmq.PutMessage
-
Sets message payload compression algorithm.
- setConfigureQueueTimeout(Duration) - Method in class com.bloomberg.bmq.SessionOptions.Builder
-
Sets timeout value for configure queue operation
- setConsumerPriority(int) - Method in class com.bloomberg.bmq.QueueOptions.Builder
-
Sets priority of a consumer with respect to delivery of messages.
- setCorrelationId() - Method in interface com.bloomberg.bmq.PutMessage
-
Sets and returns a new CorrelationId that contains an auto-assigned integer value
starting from 1 and up to 0xFFFFFF.
- setCorrelationId(Object) - Method in interface com.bloomberg.bmq.PutMessage
-
Sets and returns a new CorrelationId that binds an auto-assigned integer value
starting from 1 and up to 0xFFFFFF and the user specified Object.
- setHostHealthMonitor(HostHealthMonitor) - Method in class com.bloomberg.bmq.SessionOptions.Builder
-
Sets host health monitor object.
- setInboundBufferWaterMark(SessionOptions.InboundEventBufferWaterMark) - Method in class com.bloomberg.bmq.SessionOptions.Builder
-
Sets low and high inbound buffer watermark values
- setMaxUnconfirmedBytes(long) - Method in class com.bloomberg.bmq.QueueOptions.Builder
-
Sets maximum accumulated bytes of all outstanding messages that can be sent by the broker
without being confirmed.
- setMaxUnconfirmedMessages(long) - Method in class com.bloomberg.bmq.QueueOptions.Builder
-
Sets maximum number of outstanding messages that can be sent by the broker without being
confirmed.
- setOpenQueueTimeout(Duration) - Method in class com.bloomberg.bmq.SessionOptions.Builder
-
Sets timeout value for open queue operation
- setPropertyAsBinary(String, byte[]) - Method in interface com.bloomberg.bmq.MessageProperties
-
Sets a property with the specified name having the specified value as an
array of bytes.
- setPropertyAsBool(String, boolean) - Method in interface com.bloomberg.bmq.MessageProperties
-
Sets a property with the specified name having the specified value of the
type boolean.
- setPropertyAsByte(String, byte) - Method in interface com.bloomberg.bmq.MessageProperties
-
Sets a property with the specified name having the specified value of the
type byte.
- setPropertyAsInt32(String, int) - Method in interface com.bloomberg.bmq.MessageProperties
-
Sets a property with the specified name having the specified value of the
type int.
- setPropertyAsInt64(String, long) - Method in interface com.bloomberg.bmq.MessageProperties
-
Sets a property with the specified name having the specified value of the
type long.
- setPropertyAsShort(String, short) - Method in interface com.bloomberg.bmq.MessageProperties
-
Sets a property with the specified name having the specified value of the
type short.
- setPropertyAsString(String, String) - Method in interface com.bloomberg.bmq.MessageProperties
-
Sets a property with the specified name having the specified value of the
type String.
- setReader(long) - Static method in enum com.bloomberg.bmq.QueueFlags
-
Sets the specified flags representation for reader.
- setStartTimeout(Duration) - Method in class com.bloomberg.bmq.SessionOptions.Builder
-
Sets session start timeout
- setStatsDumpInterval(Duration) - Method in class com.bloomberg.bmq.SessionOptions.Builder
-
Sets the stats dump interval to the specified 'value'.
- setStopTimeout(Duration) - Method in class com.bloomberg.bmq.SessionOptions.Builder
-
Sets session stop timeout
- setSuspendsOnBadHostHealth(boolean) - Method in class com.bloomberg.bmq.QueueOptions.Builder
-
Sets whether queue should suspend when the host machine is unhealthy.
- setWriteBufferWaterMark(SessionOptions.WriteBufferWaterMark) - Method in class com.bloomberg.bmq.SessionOptions.Builder
-
Sets low and high channel watermark values
- setWriter(long) - Static method in enum com.bloomberg.bmq.QueueFlags
-
Sets the specified flags representation for writer.
- SIZE_BINARY - Static variable in class com.bloomberg.bmq.MessageGUID
-
The size of a buffer needed to represent a GUID.
- SIZE_HEX - Static variable in class com.bloomberg.bmq.MessageGUID
-
The size of a hexadecimal string representation of the GUID.
- start(Duration) - Method in interface com.bloomberg.bmq.AbstractSession
-
Connect to the BlazingMQ broker and start the message processing
- start(Duration) - Method in class com.bloomberg.bmq.Session
-
Connects to the BlazingMQ broker and start the message processing.
- startAsync(Duration) - Method in interface com.bloomberg.bmq.AbstractSession
-
Connect to the BlazingMQ broker and start the message processing
- startAsync(Duration) - Method in class com.bloomberg.bmq.Session
-
Connects to the BlazingMQ broker and start the message processing
- startTimeout() - Method in class com.bloomberg.bmq.SessionOptions
-
Returns timeout value that defines how much time the user gives to the
Session for successful start.
- statsDumpInterval() - Method in class com.bloomberg.bmq.SessionOptions
-
Returns interval (in seconds) at which to dump stats in the logs.
- status() - Method in interface com.bloomberg.bmq.AckMessage
-
Returns the status of this message set by the broker.
- stop(Duration) - Method in interface com.bloomberg.bmq.AbstractSession
-
Gracefully disconnect from the BlazingMQ broker and stop the operation of this 'Session'.
- stop(Duration) - Method in class com.bloomberg.bmq.Session
-
Gracefully disconnects from the BlazingMQ broker and stop the operation of this session.
- stopAsync(Duration) - Method in interface com.bloomberg.bmq.AbstractSession
-
Gracefully disconnect from the BlazingMQ broker and stop the operation of this 'Session'.
- stopAsync(Duration) - Method in class com.bloomberg.bmq.Session
-
Gracefully disconnects from the BlazingMQ broker and stop the operation of this session.
- stopTimeout() - Method in class com.bloomberg.bmq.SessionOptions
-
Returns timeout value that defines how much time the user gives to the
Session for successful stop.
- value() - Method in interface com.bloomberg.bmq.MessageProperty.BinaryProperty
-
Returns this property value as byte array.
- value() - Method in interface com.bloomberg.bmq.MessageProperty.BoolProperty
-
Returns this property value as Boolean.
- value() - Method in interface com.bloomberg.bmq.MessageProperty.ByteProperty
-
Returns this property value as Byte.
- value() - Method in interface com.bloomberg.bmq.MessageProperty.Int32Property
-
Returns this property value as Integer.
- value() - Method in interface com.bloomberg.bmq.MessageProperty.Int64Property
-
Returns this property value as Long.
- value() - Method in interface com.bloomberg.bmq.MessageProperty.ShortProperty
-
Returns this property value as Short.
- value() - Method in interface com.bloomberg.bmq.MessageProperty.StringProperty
-
Returns this property value as String.
- value() - Method in interface com.bloomberg.bmq.MessageProperty
-
Returns this property value.
- valueOf(String) - Static method in enum com.bloomberg.bmq.CompressionAlgorithm
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.bloomberg.bmq.HostHealthState
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.bloomberg.bmq.MessageProperty.Type
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.bloomberg.bmq.QueueControlEvent.Type
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.bloomberg.bmq.QueueFlags
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.bloomberg.bmq.ResultCodes.AckResult
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.bloomberg.bmq.ResultCodes.CloseQueueResult
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.bloomberg.bmq.ResultCodes.ConfigureQueueResult
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.bloomberg.bmq.ResultCodes.GenericResult
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.bloomberg.bmq.ResultCodes.OpenQueueResult
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.bloomberg.bmq.SessionEvent.Type
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum com.bloomberg.bmq.CompressionAlgorithm
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.bloomberg.bmq.HostHealthState
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.bloomberg.bmq.MessageProperty.Type
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.bloomberg.bmq.QueueControlEvent.Type
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.bloomberg.bmq.QueueFlags
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.bloomberg.bmq.ResultCodes.AckResult
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.bloomberg.bmq.ResultCodes.CloseQueueResult
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.bloomberg.bmq.ResultCodes.ConfigureQueueResult
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.bloomberg.bmq.ResultCodes.GenericResult
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.bloomberg.bmq.ResultCodes.OpenQueueResult
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.bloomberg.bmq.SessionEvent.Type
-
Returns an array containing the constants of this enum type, in
the order they are declared.