- Generated by
1.8.11
|
UM Java API
6.16
|
Public Member Functions | |
| LBM () throws LBMException | |
| void | setLogger (LBMLogging logger) |
Static Public Member Functions | |
| static void | setLicenseFile (String licenseFile) throws LBMException |
| static void | setLicenseString (String licenseString) throws LBMException |
| static boolean | getLicenseUMMNMValid () throws LBMException |
| static boolean | getLicenseVDSValid () throws LBMException |
| static void | setConfiguration (String fileName) throws LBMException |
| static void | setConfigurationXml (String fileName, String applicationName) throws LBMException |
| static void | setConfigurationXmlString (String xmlString, String applicationName) throws LBMException |
| static void | setUmmInfo (LBMUMMInfo info) throws LBMException |
| static String | version () |
| static String | legalInfo () |
| static void | setDebugFilename (String filename) throws LBMException |
| static void | setDebugMask (long mask) |
| static void | lbmLogDebugMessage (long mask, String message) |
| static void | setUimLossRate (int rate) |
| static void | setLbtrmLossRate (int rate) |
| static void | setLbtrmSrcLossRate (int rate) |
| static void | setLbtruLossRate (int rate) |
| static void | setLbtruSrcLossRate (int rate) |
| static void | setDebugLogCallback (boolean enable) |
| static void | dumpDebugLog (String filename, boolean append) throws LBMException |
| static void | asyncOperationCancel (long handle) throws LBMException |
| static void | asyncOperationCancel (long handle, int flags) throws LBMEWouldBlockException, LBMException |
| static void | asyncOperationStatus (long handle) throws LBMException |
| static void | asyncOperationStatus (long handle, int flags) throws LBMEWouldBlockException, LBMException |
Protected Member Functions | |
| void | finalize () |
| void | log (int level, String message) throws LBMException |
LBM Utility class. This class can be subclassed to override the default logging callback used by LBM or a Java logger may be passed to the setLogger() methods to direct LBM logging.
| com.latencybusters.lbm.LBM.LBM | ( | ) | throws LBMException |
Instantiate LBM utility class (initializes log)
| LBMException | if any initialization error occurs. |
|
static |
Cancel the asynchronous operation referred to by the given handle.
Calling this function will cause the associated asynchronous operation's async operation callback function to be called with a canceled status. If the operation could not be canceled (either it has already completed, an exception is thrown. Otherwise, the operation was found and guaranteed to have been truly canceled. It is generally not safe to call this function from within an asynchronous operation callback for the same handle that is being canceled. There is one exception: it is safe to call cancel on a handle from within the initial LBM_ASYNC_OP_STATUS_IN_PROGRESS that delivers the handle; this is in fact a reasonable way to simulate a non-blocking synchronous call.
| handle | The handle to the asynchronous operation. |
| LBMException | if the operation could not be canceled. |
|
static |
Cancel the asynchronous operation referred to by the given handle.
Calling this function will cause the associated asynchronous operation's async operation callback function to be called with a canceled status. If the operation could not be canceled (either it has already completed, an exception is thrown. Otherwise, the operation was found and guaranteed to have been truly canceled. It is generally not safe to call this function from within an asynchronous operation callback for the same handle that is being canceled. There is one exception: it is safe to call cancel on a handle from within the initial LBM_ASYNC_OP_STATUS_IN_PROGRESS that delivers the handle; this is in fact a reasonable way to simulate a non-blocking synchronous call.
| handle | The handle to the asynchronous operation. |
| flags | Flags affecting the behavior of the cancel call; pass 0 if no flags desired. |
| LBMEWouldBlockException | if the non-block flag was passed and the operation would block. |
| LBMException | if the operation could not be canceled. |
|
static |
Query the status of the asynchronous operation referred to by the given handle.
Calling this function will cause the associated asynchronous operation's async operation callback function to be called with current status information. This is a merely a polling mechanism, and the information returned is guaranteed to be correct only for the duration of the async operation callback function. It may change immediately afterwards. It is not safe to (nor should it be necessary to) call this function from within an asynchronous operation callback for the same handle that status is being requested for.
| handle | The handle to the asynchronous operation. |
| LBMException | if the operation could not be found. |
|
static |
Query the status of the asynchronous operation referred to by the given handle.
Calling this function will cause the associated asynchronous operation's async operation callback function to be called with current status information. This is a merely a polling mechanism, and the information returned is guaranteed to be correct only for the duration of the async operation callback function. It may change immediately afterwards. It is not safe to (nor should it be necessary to) call this function from within an asynchronous operation callback for the same handle that status is being requested for.
| handle | The handle to the asynchronous operation. |
| flags | Flags affecting the behavior of the status call; pass 0 if no flags desired. |
| LBMEWouldBlockException | if the non-block flag was passed and the operation would block. |
| LBMException | if the operation could not be found. |
|
static |
Dump the in-memory LBM debug log to a specified file.
| filename | Name of the file to dump debug log events to. |
| append | Set to true to append the debug log to the file; otherwise, the file is overwritten. |
|
protected |
This method is for internal use only, and is not supported for customer applications.
|
static |
Determines whether UMMNM is licensed for use.
| LBMException | if licenseString doesn't contain a valid LBM license. |
|
static |
Determines whether VDS is licensed for use.
| LBMException | if licenseString doesn't contain a valid LBM license. |
|
static |
Write debug message to debug file. This method is for internal use only.
| mask | The mask used for debugging purposes. |
| message | The debug message to write. |
|
static |
|
protected |
/** Logging callback. This method may be overridden by a subclass or the logging maybe handled by a specify logging interface.
| level | Log level of message |
| message | Log message |
| LBMException | When an error occurs while calling the log callback |
|
static |
Configure LBM attributes from a file, tftp or http URL.
| fileName | String containing a file name or URL (tftp or http). File names ending with a ".xml" extension will be processed by the setConfigurationXml API with a null applicationName. |
| LBMException | if fileName contains an invalid filename, doesn't exist, or doesn't contain a valid LBM configuration file. |
|
static |
Configure LBM attributes from a file, tftp or http URL.
| fileName | String containing the path or URL (tftp or http) to the XML configuraton file. |
| applicationName | String containing the name of this applicaiton which must match an application tag in the XML configuration file. This parameter may be null, in which case the application tag with no name is matched. |
| LBMException | if fileName contains an invalid filename, doesn't exist, doesn't contain a valid LBM XML configuration file, or LBM XML configuration has already been loaded. |
|
static |
Configure LBM attributes from a String
| xmlString | String containing LBM XML configuration data. |
| applicationName | String containing the name of this applicaiton which must match an application tag in the XML configuration string. This parameter may be null, in which case the application tag with no name is matched. |
| LBMException | if xmlString is empty, doesn't exist, doesn't contain valid LBM XML configuration data, or LBM XML configuration has already been loaded. |
|
static |
Set the LBM debug filename.
| filename | The name of the file to be written with debug data. |
| LBMException | if out of memory. |
|
static |
Enable logging of debug messages to the application logging callback set by LBM.setLogger(). By default, if lbm debug logging is enabled it is sent to the filename specified by setDebugFilename(), or stderr. Calling setDebugLogCallback() with a value of true will redirect debug logging to the application logger set by setLogger(), or stderr if no logger is set.
| enable | true enables, false disables. |
|
static |
Set the LBM debug mask, as suggested by the support team.
| mask | The mask used for debugging purposes. |
|
static |
Set the LBTRM receiver-side loss rate.
| rate | The percentage (0-100) loss to be simulated. |
|
static |
Set the LBTRM source-side loss rate.
| rate | The percentage (0-100) loss to be simulated. |
|
static |
Set the LBTRU receiver-side loss rate.
| rate | The percentage (0-100) loss to be simulated. |
|
static |
Set the LBTRU source-side loss rate.
| rate | The percentage (0-100) loss to be simulated. |
|
static |
Initialize the LBM license from the contents of a disk file. This method will only be effective if it is called before any other LBM API method.
| licenseFile | String containing the name of a file that contains the LBM license. This string is the same as that which would otherwise be specified as the value of the LBM_LICENSE_FILENAME environmental variable. |
| LBMException | if licenseFile doesn't contain a valid filename, doesn't exist, or contains an invalid LBM license. |
|
static |
Initialize the LBM license from a string. This method will only be effective if it is called before any other LBM API method.
| licenseString | String containing LBM license. This string is the same as that which would otherwise be specified as the value of the LBM_LICENSE_INFO environmental variable. |
| LBMException | if licenseString doesn't contain a valid LBM license. |
| void com.latencybusters.lbm.LBM.setLogger | ( | LBMLogging | logger | ) |
Inform LBM to use a specific logger for logging
| logger | Logging object implementing the LBMLogging interface |
|
static |
Set the UIM receiver-side loss rate.
| rate | The percentage (0-100) loss to be simulated. |
|
static |
Connect to and retrieve configuration from a UMM daemon. This method will only be effective if it is called before any other LBM API method.
| info | UMM daemon connection options |
| LBMException | if UMM info has already been loaded, or if some other error was encountered. |
|
static |
|
static |
Asynchronous operation info flag. This is the very first notification for this particular asynchronous operation.
|
static |
Asynchronous operation info flag. Asynchronous operation callback is being called directly inline from within an API call.
|
static |
Asynchronous operation info status flag. This is the very last notification for this particular asynchronous operation.
|
static |
Asynchronous operation info flag. This is the only notification that will be delivered for this particular asynchronous operation.
|
static |
Invalid asynchronous operation handle.
|
static |
Asynchronous operation status code. Overall operation has been successfully canceled. This is a terminal status code.
|
static |
Asynchronous operation status code. Overall operation has completed successfully. This is a terminal status code.
|
static |
Asynchronous operation status code. Overall operation has failed. This is a terminal status code.
|
static |
Asynchronous operation status code. Overall operation is still in progress.
|
static |
Asynchronous operation type. UMQ queue topic list.
Referenced by com.latencybusters.lbm.LBMAsyncOperationInfo.contextQueueTopicListInfo().
|
static |
Asynchronous operation type. UMQ queue message list.
Referenced by com.latencybusters.lbm.LBMAsyncOperationInfo.receiverQueueMessageListInfo().
|
static |
Asynchronous operation type. UMQ queue message retrieve.
Referenced by com.latencybusters.lbm.LBMAsyncOperationInfo.receiverQueueMessageRetrieveInfo().
|
static |
Asynchronous operation cancel flag. Do not block if the operation cannot be immediately canceled.
|
static |
Asynchronous operation status flag. Do not block if the operation's status cannot be retrieved immediately.
|
static |
Application header type representing user data.
Referenced by com.latencybusters.lbm.LBMApplicationHeaderChainElement.setType().
|
static |
Indicates that the queue instance list has changed.
|
static |
Indicates context registration is complete.
|
static |
Flag indicating that registration completed with only quorum reached.
|
static |
Indicates context registration failed with an error.
|
static |
Indicates context registration with a single queue instance was successful.
|
static |
Context operational mode: Daemon
|
static |
Context operational mode: Embedded
|
static |
Context operational mode: Sequential
|
static |
LBM error: Application Error .
Referenced by com.latencybusters.lbm.LBMApplicationException.LBMApplicationException().
|
static |
|
static |
LBM error: An invalid argument was passed.
Referenced by com.latencybusters.lbm.LBMMessage.extractUMEAck(), com.latencybusters.lbm.LBMMessage.getSerializedResponse(), com.latencybusters.lbm.LBMMessage.hrTimestampNanoseconds(), com.latencybusters.lbm.LBMHotFailoverReceiver.LBMHotFailoverReceiver(), com.latencybusters.lbm.LBMHotFailoverSource.LBMHotFailoverSource(), com.latencybusters.lbm.LBMReceiver.LBMReceiver(), com.latencybusters.lbm.LBMSource.LBMSource(), com.latencybusters.lbm.LBMSSource.LBMSSource(), com.latencybusters.lbm.LBMStatistics.LBMStatistics(), com.latencybusters.lbm.LBMContext.processEvents(), com.latencybusters.lbm.LBMMessage.respond(), and com.latencybusters.lbm.LBMContext.respond().
|
static |
LBM error: Error parsing message selector.
|
static |
LBM error: The store is not fully registered.
|
static |
LBM error: The queue is not fully registered.
|
static |
LBM error: Operation could not be completed due to memory allocation error.
|
static |
LBM error: Operation was invalid due to error in internal processing.
Referenced by com.latencybusters.lbm.LBMException.LBMException(), and com.latencybusters.lbm.LBMRuntimeException.LBMRuntimeException().
|
static |
LBM error: Operation failed due to unrecoverable OS system call error.
Referenced by com.latencybusters.lbm.LBMSSource.buffPut(), com.latencybusters.lbm.LBMSource.messageBuffersCancel(), com.latencybusters.lbm.LBMAsyncOperationInfo.receiverQueueMessageRetrieveInfo(), and com.latencybusters.lbm.LBMContext.requestTopicResolution().
|
static |
LBM error: Operation timed out waiting to complete.
|
static |
LBM error: UME registration not completed.
|
static |
Infinite blocking time for running event queue
Referenced by com.latencybusters.lbm.LBMEventQueue.run().
|
static |
Event queue monitor event type: Warning of excessive delay for event.
|
static |
Event queue monitor event type: Notification of something being added to queue.
|
static |
Poll and dispatch a single event when running the event queue
|
static |
Event queue monitor event type: Warning of event queue size.
|
static |
LBM error: Function would block, but object is set to be nonblocking.
|
static |
Specify a ULB flight size
|
static |
Specify a UME flight size
|
static |
Specify a UMQ flight size
|
static |
Resolver Event Advertisement Type
Referenced by com.latencybusters.lbm.LBMContext.requestTopicResolution().
|
static |
LBMR is an eviction notice
|
static |
Source is Late Join Capable
|
static |
Source is a ULB type
|
static |
Source is UME Capable
|
static |
Source is UMQ Capable
|
static |
UME Flag present is version field
|
static |
UMQ Flag present is version field
|
static |
Domain ID Present in the resolver event info field
|
static |
Source ID Present in the resolver event info field
|
static |
Source ID Type Present in the resolver event info field
|
static |
Version is Present in the resolver event info field
|
static |
Source cost function return value to indicate this source should be permanently rejected.
|
static |
UME Receiver Liveness Deletion EOF
|
static |
UME Receiver Liveness Deletion TIMEOUT
|
static |
Use SSL for all umm connections
|
static |
Max allowed number of failover UMM Daemons
Referenced by com.latencybusters.lbm.LBMUMMInfo.LBMUMMInfo().
|
static |
For UMS application
|
static |
For Store Daemon
|
static |
For Gateway Daemon
|
static |
Logging level: Alert
|
static |
Logging level: Critical
|
static |
Logging level: Debug
|
static |
Logging level: Emergency
|
static |
Logging level: Error
|
static |
Logging level: Informational
|
static |
Logging level: Notice
|
static |
Logging level: Warning
Referenced by com.latencybusters.lbm.LBMContext.allocTopic(), and com.latencybusters.lbm.LBMHFX.createReceiver().
|
static |
LBM message type: Beginning of Transport Session from source.
|
static |
Sending/receiving flag: Message is complete batch (Batch should be sent ASAP)
|
static |
LBM message type: Data message. Data is valid.
Referenced by com.latencybusters.lbm.LBMMessage.dataBuffer(), and com.latencybusters.lbm.LBMMessage.getMessagesBuffer().
|
static |
Sending/receiving flag: End batch (Batch should be sent ASAP)
|
static |
LBM message type: End of Transport Session from source.
|
static |
Receiving flag: End batch
|
static |
Receiving flag: The message contains a 32 bit hot failover sequence number
Referenced by com.latencybusters.lbm.LBMMessage.hfSequenceNumber().
|
static |
Receiving flag: The message contains a 64 bit hot failover sequence number.
Referenced by com.latencybusters.lbm.LBMMessage.hfSequenceNumber().
|
static |
Receiving flag: Hot failover duplicate message
|
static |
Receiving flag: Hot Failover optional message
|
static |
Receiving flag: Non-HF message
|
static |
Receiving flag: Immediate message
|
static |
Channel flag: Numbered channel message
|
static |
Receiving flag: The message was recovered via OTR
|
static |
Receiving flag: Retransmitted message
|
static |
Receiving flag: Start batch
|
static |
Receiving flag; Message has no topic.
|
static |
Receiving flag: Retransmitted message
|
static |
Receiving flag: Reassigned UMQ message
|
static |
Receiving flag; Resubmitted UMQ message
|
static |
Sending flag: Flush messages. Message is to be sent ASAP (not implicitly or explicitly batched). This also flushes waiting messages that were explicitly or implicitly batched
|
static |
LBM message type: Hot failover notification that the expected sequence number has been reset via a source send reset.
|
static |
Maximum source name length
|
static |
Maximum topic name length
|
static |
Notification that no source has been found for topic. Still querying for topic source.
|
static |
Message property type: boolean
Referenced by com.latencybusters.lbm.LBMMessageProperty.getBoolean(), com.latencybusters.lbm.LBMMessageProperty.getByte(), com.latencybusters.lbm.LBMMessageProperty.getDouble(), com.latencybusters.lbm.LBMMessageProperty.getFloat(), com.latencybusters.lbm.LBMMessageProperty.getInteger(), com.latencybusters.lbm.LBMMessageProperty.getLong(), com.latencybusters.lbm.LBMMessageProperty.getObject(), com.latencybusters.lbm.LBMMessageProperty.getShort(), com.latencybusters.lbm.LBMMessageProperty.getString(), and com.latencybusters.lbm.LBMMessageProperties.LBMMessageProperties().
|
static |
Message property type: byte
Referenced by com.latencybusters.lbm.LBMMessageProperty.getBoolean(), com.latencybusters.lbm.LBMMessageProperty.getByte(), com.latencybusters.lbm.LBMMessageProperty.getDouble(), com.latencybusters.lbm.LBMMessageProperty.getFloat(), com.latencybusters.lbm.LBMMessageProperty.getInteger(), com.latencybusters.lbm.LBMMessageProperty.getLong(), com.latencybusters.lbm.LBMMessageProperty.getObject(), com.latencybusters.lbm.LBMMessageProperty.getShort(), com.latencybusters.lbm.LBMMessageProperty.getString(), and com.latencybusters.lbm.LBMMessageProperties.LBMMessageProperties().
|
static |
Message property type: double
Referenced by com.latencybusters.lbm.LBMMessageProperty.getBoolean(), com.latencybusters.lbm.LBMMessageProperty.getByte(), com.latencybusters.lbm.LBMMessageProperty.getDouble(), com.latencybusters.lbm.LBMMessageProperty.getFloat(), com.latencybusters.lbm.LBMMessageProperty.getInteger(), com.latencybusters.lbm.LBMMessageProperty.getLong(), com.latencybusters.lbm.LBMMessageProperty.getObject(), com.latencybusters.lbm.LBMMessageProperty.getShort(), com.latencybusters.lbm.LBMMessageProperty.getString(), and com.latencybusters.lbm.LBMMessageProperties.LBMMessageProperties().
|
static |
Message property type: float
Referenced by com.latencybusters.lbm.LBMMessageProperty.getBoolean(), com.latencybusters.lbm.LBMMessageProperty.getByte(), com.latencybusters.lbm.LBMMessageProperty.getDouble(), com.latencybusters.lbm.LBMMessageProperty.getFloat(), com.latencybusters.lbm.LBMMessageProperty.getInteger(), com.latencybusters.lbm.LBMMessageProperty.getLong(), com.latencybusters.lbm.LBMMessageProperty.getObject(), com.latencybusters.lbm.LBMMessageProperty.getShort(), com.latencybusters.lbm.LBMMessageProperty.getString(), and com.latencybusters.lbm.LBMMessageProperties.LBMMessageProperties().
|
static |
Message property type: int
Referenced by com.latencybusters.lbm.LBMMessageProperty.getBoolean(), com.latencybusters.lbm.LBMMessageProperty.getByte(), com.latencybusters.lbm.LBMMessageProperty.getDouble(), com.latencybusters.lbm.LBMMessageProperty.getFloat(), com.latencybusters.lbm.LBMMessageProperty.getInteger(), com.latencybusters.lbm.LBMMessageProperty.getLong(), com.latencybusters.lbm.LBMMessageProperty.getObject(), com.latencybusters.lbm.LBMMessageProperty.getShort(), com.latencybusters.lbm.LBMMessageProperty.getString(), and com.latencybusters.lbm.LBMMessageProperties.LBMMessageProperties().
|
static |
Message property type: long
Referenced by com.latencybusters.lbm.LBMMessageProperty.getBoolean(), com.latencybusters.lbm.LBMMessageProperty.getByte(), com.latencybusters.lbm.LBMMessageProperty.getDouble(), com.latencybusters.lbm.LBMMessageProperty.getFloat(), com.latencybusters.lbm.LBMMessageProperty.getInteger(), com.latencybusters.lbm.LBMMessageProperty.getLong(), com.latencybusters.lbm.LBMMessageProperty.getObject(), com.latencybusters.lbm.LBMMessageProperty.getShort(), com.latencybusters.lbm.LBMMessageProperty.getString(), and com.latencybusters.lbm.LBMMessageProperties.LBMMessageProperties().
|
static |
Message property type: short
Referenced by com.latencybusters.lbm.LBMMessageProperty.getBoolean(), com.latencybusters.lbm.LBMMessageProperty.getByte(), com.latencybusters.lbm.LBMMessageProperty.getDouble(), com.latencybusters.lbm.LBMMessageProperty.getFloat(), com.latencybusters.lbm.LBMMessageProperty.getInteger(), com.latencybusters.lbm.LBMMessageProperty.getLong(), com.latencybusters.lbm.LBMMessageProperty.getObject(), com.latencybusters.lbm.LBMMessageProperty.getShort(), com.latencybusters.lbm.LBMMessageProperty.getString(), and com.latencybusters.lbm.LBMMessageProperties.LBMMessageProperties().
|
static |
Message property type: string
Referenced by com.latencybusters.lbm.LBMMessageProperty.getBoolean(), com.latencybusters.lbm.LBMMessageProperty.getByte(), com.latencybusters.lbm.LBMMessageProperty.getDouble(), com.latencybusters.lbm.LBMMessageProperty.getFloat(), com.latencybusters.lbm.LBMMessageProperty.getInteger(), com.latencybusters.lbm.LBMMessageProperty.getLong(), com.latencybusters.lbm.LBMMessageProperty.getObject(), com.latencybusters.lbm.LBMMessageProperty.getShort(), com.latencybusters.lbm.LBMMessageProperty.getString(), and com.latencybusters.lbm.LBMMessageProperties.LBMMessageProperties().
|
static |
LBM message type: Request message from source.
Referenced by com.latencybusters.lbm.LBMMessage.respond().
|
static |
LBM message type: Reserved for internal use.
|
static |
LBM message type: Response message from requestee.
|
static |
Sending/receiving flag: Start batch
|
static |
UME receiver notification of deregistration completion. Deregistration completion info (in the form of a UMEDeregistrationCompleteInfo object) can be retrieved with the LBMMessage#deregistrationCompleteInfo() method.
|
static |
UME receiver deregistration successful (extended version). Deregistration info (in the form of a UMEDeregistrationSuccessInfo object) can be retrieved with the LBMMessage#deregistrationSuccessInfo() method.
|
static |
Deregistration was flagged as coming from a RPP store
|
static |
UME receiver notification of source registration change. Data holds info message.
|
static |
UME receiver notification of registration completion. Registration completion info (in the form of a UMERegistrationCompleteInfo object) can be retrieved with the LBMMessage#registrationCompleteInfo() method.
|
static |
Registration completed with only quorum reached. Flag for UME receiver registration complete messages.
|
static |
Registration completed with RX REQ maximum used.
|
static |
The source session ID field of the UME registration complete info object is valid.
|
static |
UME receiver registration encountered an error. Data holds error message.
|
static |
UME receiver registration successful.
Referenced by com.latencybusters.lbm.LBMMessage.receiverRegistrationId(), and com.latencybusters.lbm.LBMMessage.sourceRegistrationId().
|
static |
UME receiver registration successful (extended version). Registration info (in the form of a UMERegistrationSuccessInfo object) can be retrieved with the LBMMessage#registrationSuccessInfo() method.
|
static |
Registration was flagged as coming from a store that is configured to not cache data. This flag may be set in an extended UME registration success message.
|
static |
Registration was flagged as an old receiver by the store. An old receiver is one the store had cached. This flag may be set in an extended UME registration success message.
|
static |
Registration was flagged as coming from a store that has allowed a RPP receiver.. Flag for UME receiver registration complete messages.
|
static |
The source session ID field in the registration success info object is valid.
|
static |
UMQ receiver notification of deregistration completion. Deregistration completion info (in the form of a UMQDeregistrationCompleteInfo object) can be retrieved with the LBMMessage#queueDeregistrationCompleteInfo() method.
|
static |
Deregistration completed with ULB source. Flag for UMQ receiver registration complete messages.
|
static |
LBM message type: UMQ receiver notification of assignment of a particular index from a particular queue or ULB source. Index assignment info (in the form of a UMQIndexAssignedInfo object) can be retrieved with the LBMMessage#queueIndexAssignedInfo() method.
|
static |
Index assignment was from a ULB source. Flag for UMQ receiver index assignment messages.
|
static |
LBM message type: UMQ receiver index assignment eligibility start/stop encountered an error. Data holds error message.
|
static |
LBM message type: UMQ receiver notification of beginning of index assignment eligibility. Index assignment eligibility start completion info (in the form of a UMQIndexAssignmentEligibilityStartCompleteInfo object) can be retrieved with the LBMMessage#queueIndexAssignmentEligibilityStartCompleteInfo() method.
|
static |
Index assignment eligibility start completed at a ULB source. Flag for UMQ receiver index assignment eligibility start complete messages.
|
static |
LBM message type: UMQ receiver notification of end of index assignment eligibility. Index assignment eligibility stop completion info (in the form of a UMQIndexAssignmentEligibilityStopCompleteInfo object) can be retrieved with the LBMMessage#queueIndexAssignmentEligibilityStopCompleteInfo() method.
|
static |
Index assignment eligibility stop completed at a ULB source. Flag for UMQ receiver index assignment eligibility stop complete messages.
|
static |
LBM message type: UMQ receiver notification of end of assignment of a particular index from a particular queue or ULB source. Index assignment info (in the form of a UMQIndexReleasedInfo object) can be retrieved with the LBMMessage#queueIndexReleasedInfo() method.
|
static |
Index released from a ULB source. Flag for UMQ receiver index released messages.
|
static |
Instead of requesting reassignment, request the message be discarded.
|
static |
UMQ receiver notification of registration completion. Registration completion info (in the form of a UMQRegistrationCompleteInfo object) can be retrieved with the LBMMessage#queueRegistrationCompleteInfo() method.
|
static |
Registration completed with only quorum reached. Flag for UMQ receiver registration complete messages.
|
static |
Registration completed with ULB source. Flag for UMQ receiver registration complete messages.
|
static |
UMQ receiver notification of registration error. Registration error information (in the form of a string) can be retrieved with the LBMMessage#dataString() method.
|
static |
LBM message type: Missing message detected and not recovered in given time.
|
static |
LBM message type: Missing burst of messages detected and not recovered.
|
static |
User does not wish LBM to take locks in the main processing loop; specifically the context lock and timer lock.
|
static |
User supplies a valid time of day.
Referenced by com.latencybusters.lbm.LBMContext.processEvents().
|
static |
Block the caller indefinitely until the message is sent.
|
static |
Source event: For unicast transport, means receiver has connected.
|
static |
Source event: For LBM daemon usage only, means daemon has confirmed src created
|
static |
Source event: For unicast transport, means receiver has disconnected.
|
static |
Source event: flight size notification. The flightSizeNotification() method will return an info object containing additional information.
|
static |
Messages in flight has exceeded the threshold.
|
static |
Messages in flight is now below the threshold.
|
static |
Specifies a ULB flight size.
|
static |
Specifies a UME flight size.
|
static |
Specifies a UMQ flight size.
|
static |
Source event: Informs the application of the sequence numbers used with a message. Event data holds sequence number data.
|
static |
Source event: Informs the application of the high-resolution timestamp of a sent message. Event data holds timestamp related information.
|
static |
Source event: (UME only) UME Confirmed Delivery of Message from a receiver. Event data holds ACK information which includes the registration ID, the message sequence number, and the client object argument passed into the LBMSource.send() method.
|
static |
Source event: For UME only, means UME Confirmed Delivery of Message from receiver (extended form). Event data holds ACK information.
|
static |
Confirmation received with Explicit ACK (EXACK) flagged.
|
static |
Confirmation received with Out-of-Order Delivery (OOD) flagged.
|
static |
Confirmation received for specified number of unique ACKs.
|
static |
Confirmation received with User Specified Rcv Registration ID flagged.
|
static |
Whole message (each fragment) delivery confirmed
|
static |
Source event: UME source notification of deregistration completion. Deregistration completion info (in the form of a UMESourceEventDeregistrationCompleteInfo object) can be retrieved with the LBMMessage#deregistrationCompleteInfo() method.
|
static |
Source event: UME source deregistration successful (extended version). Deregistration info (in the form of a UMESourceEventDeregistrationSuccessInfo object) can be retrieved with the LBMMessage#deregistrationSuccessInfo() method.
|
static |
Source event: For UMP only, means a message is NOT stable, and the source has given up waiting for stability. Event data tells which store the message is not stable at and the reason the source gave up. Event data holds information about where and why the message is not stable.
|
static |
Message not stable due to explicitly reported unrecoverable loss at the store or receiver.
|
static |
Message not stable information has store information
|
static |
Message not stable due to stability lifetime timeout.
|
static |
Source event: (UME only) Indicates that a message has been reclaimed. Event data holds the message sequence number and the client object argument passed into the LBMSource.send() method.
|
static |
Source event: Indicates that a message has been reclaimed (extended version). Event data holds ACK information.
|
static |
Reclaim notification is the result of a forced reclaim
|
static |
Source event: (UME only) UME ACK from store indicates message is stable. Event data holds ACK information which includes the registration ID, the message sequence number, and the client object argument passed into the LBMSource.send() method.
|
static |
Source event: For UME only, means UME ACK from store indicates message is stable (extended form). Event data holds ACK information.
|
static |
Message stable for intergroup stability
|
static |
Message stable for intragroup stability
|
static |
Message is stable according to behavior desired
|
static |
Message stable information has active store information
|
static |
Message stabilized via the setUMEMessageStable API
|
static |
Whole message (each fragment) is stable
|
static |
Source event: (UME only) Registration of source complete. Data (in the form of a UMESourceEventRegistrationCompleteInfo object) can be retrieved with the LBMSourceEvent#registrationCompleteInfo() method.
|
static |
Registration completed with only quorum reached.
|
static |
Source event: (UME only) Registration of source failed with an error. Event data holds the error string.
|
static |
Source event: (UME only) Registration of source successful. Event data holds the registration ID
|
static |
Source event: (UME only) Registration of source successful (extended version). Data (in the form of a UMESourceEventRegistrationSuccessInfo object) can be retrieved with the LBMSourceEvent#registrationSuccessInfo() method.
|
static |
Registration was flagged as coming from a store that is configured to not send ACKs for stability (no-cache store).
|
static |
Registration was flagged as an old source by the store. An old source is one the store had cached.
|
static |
Registration was flagged as coming from a store that allows and has accepted RPP persistent topics
|
static |
Source event: (UME only) Store has not been active within timeout. Event data holds an info string.
|
static |
Source event: For UMQ only, informs the application of the Message ID assigned with a message. The messageIdInfo() method will return an info object containing additional information.
|
static |
Source event: For UMQ only, means a message is stable with the a queue instance. The queueAckInfo() method will return an info object containing additional information.
|
static |
Flag indicating that a message is stable across groups according to behavior desired.
|
static |
Flag indicating that a message is stable within a group.
|
static |
Flag indicating that a message is stable according to behavior desired.
|
static |
Message stabilized via the setUMQMessageStable API
|
static |
Source event: For UMQ only, means registration of source complete. The queueRegistrationCompleteInfo() method will return an info object containing additional information.
|
static |
Flag indicating that registration completed with only quorum reached.
|
static |
Source event: For UMQ only, means registration of source failed with an error. The dataString() method will return the error message.
|
static |
Source event: For UMQ only, means a ULB message has been assigned to a receiver. The ulbMessageInfo() method will return an info object containing additional information.
|
static |
Source event: For UMQ only, means a ULB message has been consumed or discarded from all application sets. The ulbMessageInfo() method will return an info object containing additional information.
|
static |
Source event: For UMQ only, means a ULB message has been consumed by a receiver. The ulbMessageInfo() method will return an info object containing additional information.
|
static |
Source event: For UMQ only, means a ULB message has been reassigned from a receiver. The ulbMessageInfo() method will return an info object containing additional information.
|
static |
Source event: For UMQ only, means a ULB message has been reached end-of-life. The ulbMessageInfo() method will return an info object containing additional information.
|
static |
Timeout is the result of the reassign API being called with the DISCARD flag set
|
static |
Timeout is the result of the reassign API being called by a receiver
|
static |
Timeout is the result of hitting the umq_ulb_application_set_message_max_reassignments number of assignments
|
static |
Timeout is the result of the total lifetime expiring
|
static |
Source event: For UMQ only, means a receiver has deregistered from the source. The ulbReceiverInfo() method will return an info object containing additional information.
|
static |
Source event: For UMQ only, means a receiver has signalled it is ready for messages to be assigned to it. The ulbReceiverInfo() method will return an info object containing additional information.
|
static |
Source event: For UMQ only, means a receiver has registered with the source. The ulbReceiverInfo() method will return an info object containing additional information.
|
static |
Source event: For UMQ only, means a receiver has reached end-of-life. The ulbReceiverInfo() method will return an info object containing additional information.
|
static |
Source event: Following earlier LBMEWouldBlockException, this event means that the source is ready for more sends.
|
static |
Source wakeup event flag: Unblocked source is a context-level multicast immediate mode source.
|
static |
Source wakeup event flag: Unblocked source is a normal (or hot failover) source.
|
static |
Source wakeup event flag: Unblocked source is a context-level request source.
|
static |
Source wakeup event flag: Unblocked source is a context-level response source.
|
static |
Source wakeup event flag: Unblocked source is a context-level unicast immediate mode source.
|
static |
If message could not be sent immediately, throw LBMEWouldBlockException
|
static |
Send message with included application header chain.
Referenced by com.latencybusters.lbm.LBMSourceSendExInfo.setApplicationHeaderChain().
|
static |
Send message with included channel information.
Referenced by com.latencybusters.lbm.LBMSourceSendExInfo.setChannelInfo().
|
static |
Send message with a 32 bit hot failover sequence number.
|
static |
Send message with a 64 bit hot failover sequence number.
|
static |
Send message marked as an optional message for Hot Failover
|
static |
Send message with supplied properties
Referenced by com.latencybusters.lbm.LBMSourceSendExInfo.getHfSequenceNumberBigInt(), and com.latencybusters.lbm.LBMSourceSendExInfo.setMessageProperties().
|
static |
Inform application of the sequence numbers used for message.
|
static |
Inform application of the sequence numbers used for message (fragmented messages only).
|
static |
Send messages associating them with the supplied UMQ index
Referenced by com.latencybusters.lbm.LBMSourceSendExInfo.setIndexInfo().
|
static |
Inform application of the UMQ Message ID used for the message.
|
static |
Send message with supplied total lifetime
Referenced by com.latencybusters.lbm.LBMSourceSendExInfo.setTotalLifetimeInfo().
|
static |
Quorum and Consensus store behaviour
|
static |
Round Robin store behaviour
|
static |
Send messages using supplied Spectrum channel information.
Referenced by com.latencybusters.lbm.LBMSSourceSendExInfo.setChannel().
|
static |
Send message with the supplied messages properties.
Referenced by com.latencybusters.lbm.LBMSSourceSendExInfo.setMessageProperties().
|
static |
Rebuild buffer before sending message.
|
static |
Inform application of the sequence numbers used for message.
|
static |
Inform application of the sequence numbers used for message (fragmented messages only).
|
static |
UMP client data pointer is valid.
|
static |
Update Spectrum Channel number before sending message.
|
static |
Update message property values before sending message.
|
static |
User buffer has been supplied
Referenced by com.latencybusters.lbm.LBMSSourceSendExInfo.setUserSuppliedBuffer().
|
static |
Request advertisements from quiescent sources.
|
static |
Request context advertisements from quiescent contexts.
|
static |
Request context queries from quiescent contexts.
|
static |
Request queries from quiescent receivers.
|
static |
Request queries from quiescent wildcard receivers
|
static |
Transport statistics type: BROKER transport.
Referenced by com.latencybusters.lbm.LBMReceiverStatistics.outOfOrder(), com.latencybusters.lbm.LBMSourceStatistics.retransmissionsQueued(), com.latencybusters.lbm.LBMSourceStatistics.typeName(), and com.latencybusters.lbm.LBMReceiverStatistics.typeName().
|
static |
Transport statistics type: Daemon is being used.
|
static |
Transport statistics type: LBT-IPC transport.
Referenced by com.latencybusters.lbm.LBMReceiverStatistics.LBMReceiverStatistics(), com.latencybusters.lbm.LBMSourceStatistics.LBMSourceStatistics(), com.latencybusters.lbm.LBMReceiverStatistics.outOfOrder(), com.latencybusters.lbm.LBMSourceStatistics.retransmissionsQueued(), com.latencybusters.lbm.LBMSourceStatistics.typeName(), and com.latencybusters.lbm.LBMReceiverStatistics.typeName().
|
static |
Transport statistics type: LBT-RDMA transport.
Referenced by com.latencybusters.lbm.LBMReceiverStatistics.outOfOrder(), com.latencybusters.lbm.LBMSourceStatistics.retransmissionsQueued(), com.latencybusters.lbm.LBMSourceStatistics.typeName(), and com.latencybusters.lbm.LBMReceiverStatistics.typeName().
|
static |
Transport statistics type: LBT-RM transport.
Referenced by com.latencybusters.lbm.LBMImmediateMessageReceiverStatistics.LBMImmediateMessageReceiverStatistics(), com.latencybusters.lbm.LBMImmediateMessageSourceStatistics.LBMImmediateMessageSourceStatistics(), com.latencybusters.lbm.LBMReceiverStatistics.LBMReceiverStatistics(), com.latencybusters.lbm.LBMSourceStatistics.LBMSourceStatistics(), com.latencybusters.lbm.LBMImmediateMessageReceiverStatistics.outOfOrder(), com.latencybusters.lbm.LBMReceiverStatistics.outOfOrder(), com.latencybusters.lbm.LBMImmediateMessageSourceStatistics.retransmissionBytesSent(), com.latencybusters.lbm.LBMSourceStatistics.retransmissionsQueued(), com.latencybusters.lbm.LBMImmediateMessageSourceStatistics.typeName(), com.latencybusters.lbm.LBMImmediateMessageReceiverStatistics.typeName(), com.latencybusters.lbm.LBMSourceStatistics.typeName(), and com.latencybusters.lbm.LBMReceiverStatistics.typeName().
|
static |
Transport statistics type: LBT-RU transport.
Referenced by com.latencybusters.lbm.LBMReceiverStatistics.LBMReceiverStatistics(), com.latencybusters.lbm.LBMSourceStatistics.LBMSourceStatistics(), com.latencybusters.lbm.LBMReceiverStatistics.outOfOrder(), com.latencybusters.lbm.LBMSourceStatistics.retransmissionsQueued(), com.latencybusters.lbm.LBMSourceStatistics.typeName(), and com.latencybusters.lbm.LBMReceiverStatistics.typeName().
|
static |
Transport statisitics type: LBT-SMX transport.
Referenced by com.latencybusters.lbm.LBMReceiverStatistics.LBMReceiverStatistics(), com.latencybusters.lbm.LBMSourceStatistics.LBMSourceStatistics(), com.latencybusters.lbm.LBMReceiverStatistics.outOfOrder(), com.latencybusters.lbm.LBMSourceStatistics.retransmissionsQueued(), com.latencybusters.lbm.LBMSourceStatistics.typeName(), and com.latencybusters.lbm.LBMReceiverStatistics.typeName().
|
static |
Transport statistics type: TCP transport.
Referenced by com.latencybusters.lbm.LBMImmediateMessageReceiverStatistics.LBMImmediateMessageReceiverStatistics(), com.latencybusters.lbm.LBMImmediateMessageSourceStatistics.LBMImmediateMessageSourceStatistics(), com.latencybusters.lbm.LBMReceiverStatistics.LBMReceiverStatistics(), com.latencybusters.lbm.LBMSourceStatistics.LBMSourceStatistics(), com.latencybusters.lbm.LBMImmediateMessageReceiverStatistics.outOfOrder(), com.latencybusters.lbm.LBMReceiverStatistics.outOfOrder(), com.latencybusters.lbm.LBMImmediateMessageSourceStatistics.retransmissionBytesSent(), com.latencybusters.lbm.LBMSourceStatistics.retransmissionsQueued(), com.latencybusters.lbm.LBMImmediateMessageSourceStatistics.typeName(), com.latencybusters.lbm.LBMImmediateMessageReceiverStatistics.typeName(), com.latencybusters.lbm.LBMSourceStatistics.typeName(), and com.latencybusters.lbm.LBMReceiverStatistics.typeName().
|
static |
Maximum UME store length.
|
static |
The source session ID field in the UME receiver recovery sequence number info object is valid.
|
static |
UMQIndexInfo flag. Index is a 64-bit integer.
Referenced by com.latencybusters.lbm.UMQIndexInfo.index(), com.latencybusters.lbm.UMQIndexInfo.indexLength(), com.latencybusters.lbm.LBMWildcardReceiver.indexRelease(), com.latencybusters.lbm.UMQIndexInfo.numericIndex(), com.latencybusters.lbm.LBMMessage.queueIndexInfo(), com.latencybusters.lbm.UMQIndexInfo.setIndex(), and com.latencybusters.lbm.UMQIndexInfo.setNumericIndex().
|
static |
Maximum UMQ queue appset name length.
|
static |
Maximum UMQ index length.
Referenced by com.latencybusters.lbm.UMQIndexInfo.setIndex().
|
static |
Maximum UMQ queue length.
|
static |
Maximum UMQ queue topic name length.
|
static |
Queue message status; message is currently assigned to a receiver but not yet consumed.
|
static |
Queue message status; message has been fully consumed and is no longer present in the queue.
|
static |
Queue message status; message is waiting to be re-assigned to a different receiver.
|
static |
Queue message status; message is currently enqueued but not yet assigned.
|
static |
Queue message status; queue has no knowledge of the message.
|
static |
Maximum UMQ ULB receiver length.
|
static |
Wildcard receiver pattern type: callback
|
static |
Wildcard receiver pattern type: PCRE (Perl Compatible Regular Expressions)
|
static |
Wildcard receiver pattern type: POSIX regex
1.8.11