|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.latencybusters.lbm.LBM
public class LBM
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.
Field Summary | |
---|---|
static int |
ASYNC_OP_INFO_FLAG_FIRST
Asynchronous operation info flag. |
static int |
ASYNC_OP_INFO_FLAG_INLINE
Asynchronous operation info flag. |
static int |
ASYNC_OP_INFO_FLAG_LAST
Asynchronous operation info status flag. |
static int |
ASYNC_OP_INFO_FLAG_ONLY
Asynchronous operation info flag. |
static long |
ASYNC_OP_INVALID_HANDLE
Invalid asynchronous operation handle. |
static int |
ASYNC_OP_STATUS_CANCELED
Asynchronous operation status code. |
static int |
ASYNC_OP_STATUS_COMPLETE
Asynchronous operation status code. |
static int |
ASYNC_OP_STATUS_ERROR
Asynchronous operation status code. |
static int |
ASYNC_OP_STATUS_IN_PROGRESS
Asynchronous operation status code. |
static int |
ASYNC_OP_TYPE_CTX_UMQ_QUEUE_TOPIC_LIST
Asynchronous operation type. |
static int |
ASYNC_OP_TYPE_RCV_UMQ_QUEUE_MSG_LIST
Asynchronous operation type. |
static int |
ASYNC_OP_TYPE_RCV_UMQ_QUEUE_MSG_RETRIEVE
Asynchronous operation type. |
static int |
ASYNC_OPERATION_CANCEL_FLAG_NONBLOCK
Asynchronous operation cancel flag. |
static int |
ASYNC_OPERATION_STATUS_FLAG_NONBLOCK
Asynchronous operation status flag. |
static byte |
CHAIN_ELEM_USER_DATA
Application header type representing user data. |
static int |
CONTEXT_EVENT_UMQ_INSTANCE_LIST_NOTIFICATION
Indicates that the queue instance list has changed. |
static int |
CONTEXT_EVENT_UMQ_REGISTRATION_COMPLETE_EX
Indicates context registration is complete. |
static int |
CONTEXT_EVENT_UMQ_REGISTRATION_COMPLETE_EX_FLAG_QUORUM
Flag indicating that registration completed with only quorum reached. |
static int |
CONTEXT_EVENT_UMQ_REGISTRATION_ERROR
Indicates context registration failed with an error. |
static int |
CONTEXT_EVENT_UMQ_REGISTRATION_SUCCESS_EX
Indicates context registration with a single queue instance was successful. |
static int |
CTX_ATTR_OP_DAEMON
Context operational mode: Daemon |
static int |
CTX_ATTR_OP_EMBEDDED
Context operational mode: Embedded |
static int |
CTX_ATTR_OP_SEQUENTIAL
Context operational mode: Sequential |
static int |
EAPPERR
LBM error: Application Error . |
static int |
EDAEMONCONN
LBM error: LBM daemon connection not connected. |
static int |
EINVAL
LBM error: An invalid argument was passed. |
static int |
EMSG_SELECTOR
LBM error: Error parsing message selector. |
static int |
ENO_QUEUE_REG
LBM error: The store is not fully registered. |
static int |
ENO_STORE_REG
LBM error: The queue is not fully registered. |
static int |
ENOMEM
LBM error: Operation could not be completed due to memory allocation error. |
static int |
EOP
LBM error: Operation was invalid due to error in internal processing. |
static int |
EOS
LBM error: Operation failed due to unrecoverable OS system call error. |
static int |
ETIMEDOUT
LBM error: Operation timed out waiting to complete. |
static int |
EUMENOREG
LBM error: UME registration not completed. |
static long |
EVENT_QUEUE_BLOCK
Infinite blocking time for running event queue |
static int |
EVENT_QUEUE_DELAY_WARNING
Event queue monitor event type: Warning of excessive delay for event. |
static int |
EVENT_QUEUE_ENQUEUE_NOTIFICATION
Event queue monitor event type: Notification of something being added to queue. |
static long |
EVENT_QUEUE_POLL
Poll and dispatch a single event when running the event queue |
static int |
EVENT_QUEUE_SIZE_WARNING
Event queue monitor event type: Warning of event queue size. |
static int |
EWOULDBLOCK
LBM error: Function would block, but object is set to be nonblocking. |
static int |
FLIGHT_SIZE_TYPE_ULB
Specify a ULB flight size |
static int |
FLIGHT_SIZE_TYPE_UME
Specify a UME flight size |
static int |
FLIGHT_SIZE_TYPE_UMQ
Specify a UMQ flight size |
static int |
LBM_BYTEMESSAGE
|
static java.lang.String |
LBM_JMSCorrelationID
|
static java.lang.String |
LBM_JMSDeliveryMode
|
static java.lang.String |
LBM_JMSExpiration
|
static java.lang.String |
LBM_JMSMessageID
|
static java.lang.String |
LBM_JMSPriority
|
static java.lang.String |
LBM_JMSRedelivered
|
static java.lang.String |
LBM_JMSReplyToName
|
static java.lang.String |
LBM_JMSReplyToType
|
static java.lang.String |
LBM_JMSReplyToWildcard
|
static java.lang.String |
LBM_JMSTimestamp
|
static java.lang.String |
LBM_JMSTopicType
|
static java.lang.String |
LBM_JMSType
|
static java.lang.String |
LBM_LBMMessageType
|
static int |
LBM_MAPMESSAGE
|
static int |
LBM_MESSAGE
|
static int |
LBM_OBJECTMESSAGE
|
static long |
LBM_SRC_COST_FUNCTION_REJECT
Source cost function return value to indicate this source should be permanently rejected. |
static int |
LBM_STREAMMESSAGE
|
static int |
LBM_TEXTMESSAGE
|
static int |
LBM_UME_LIVENESS_RECEIVER_UNRESPONSIVE_FLAG_EOF
UME Receiver Liveness Deletion EOF |
static int |
LBM_UME_LIVENESS_RECEIVER_UNRESPONSIVE_FLAG_TMO
UME Receiver Liveness Deletion TIMEOUT |
static long |
LBM_UMM_INFO_FLAGS_USE_SSL
Use SSL for all umm connections |
static long |
LBM_UMM_NUM_SERVERS_MAX
Max allowed number of failover UMM Daemons |
static int |
LOG_ALERT
Logging level: Alert |
static int |
LOG_CRIT
Logging level: Critical |
static int |
LOG_DEBUG
Logging level: Debug |
static int |
LOG_EMERG
Logging level: Emergency |
static int |
LOG_ERR
Logging level: Error |
static int |
LOG_INFO
Logging level: Informational |
static int |
LOG_NOTICE
Logging level: Notice |
static int |
LOG_WARNING
Logging level: Warning |
static int |
MSG_BOS
LBM message type: Beginning of Transport Session from source. |
static int |
MSG_COMPLETE_BATCH
Sending/receiving flag: Message is complete batch (Batch should be sent ASAP) |
static int |
MSG_DATA
LBM message type: Data message. |
static int |
MSG_END_BATCH
Sending/receiving flag: End batch (Batch should be sent ASAP) |
static int |
MSG_EOS
LBM message type: End of Transport Session from source. |
static int |
MSG_FLAG_DELIVERY_LATENCY
|
static int |
MSG_FLAG_END_BATCH
Receiving flag: End batch |
static int |
MSG_FLAG_HF_32
Receiving flag: The message contains a 32 bit hot failover sequence number |
static int |
MSG_FLAG_HF_64
Receiving flag: The message contains a 64 bit hot failover sequence number. |
static int |
MSG_FLAG_HF_DUPLICATE
Receiving flag: Hot failover duplicate message |
static int |
MSG_FLAG_HF_OPTIONAL
Receiving flag: Hot Failover optional message |
static int |
MSG_FLAG_HF_PASS_THROUGH
Receiving flag: Non-HF message |
static int |
MSG_FLAG_IMMEDIATE
Receiving flag: Immediate message |
static int |
MSG_FLAG_NUMBERED_CHANNEL
Channel flag: Numbered channel message |
static int |
MSG_FLAG_OTR
Receiving flag: The message was recovered via OTR |
static int |
MSG_FLAG_RETRANSMIT
Receiving flag: Retransmitted message |
static int |
MSG_FLAG_START_BATCH
Receiving flag: Start batch |
static int |
MSG_FLAG_TOPICLESS
Receiving flag; Message has no topic. |
static int |
MSG_FLAG_UME_RETRANSMIT
Receiving flag: Retransmitted message |
static int |
MSG_FLAG_UMQ_REASSIGNED
Receiving flag: Reassigned UMQ message |
static int |
MSG_FLAG_UMQ_RESUBMITTED
Receiving flag; Resubmitted UMQ message |
static int |
MSG_FLUSH
Sending flag: Flush messages. |
static int |
MSG_HF_RESET
LBM message type: Hot failover notification that the expected sequence number has been reset via a source send reset. |
static int |
MSG_MAX_SOURCE_LEN
Maximum source name length |
static int |
MSG_MAX_TOPIC_LEN
Maximum topic name length |
static int |
MSG_NO_SOURCE_NOTIFICATION
Notification that no source has been found for topic. |
static int |
MSG_PROPERTY_BOOLEAN
Message property type: boolean |
static int |
MSG_PROPERTY_BYTE
Message property type: byte |
static int |
MSG_PROPERTY_DOUBLE
Message property type: double |
static int |
MSG_PROPERTY_FLOAT
Message property type: float |
static int |
MSG_PROPERTY_INT
Message property type: int |
static int |
MSG_PROPERTY_LONG
Message property type: long |
static int |
MSG_PROPERTY_SHORT
Message property type: short |
static int |
MSG_PROPERTY_STRING
Message property type: string |
static int |
MSG_REQUEST
LBM message type: Request message from source. |
static int |
MSG_RESPONSE
LBM message type: Response message from requestee. |
static int |
MSG_START_BATCH
Sending/receiving flag: Start batch |
static int |
MSG_UME_DEREGISTRATION_COMPLETE_EX
UME receiver notification of deregistration completion. |
static int |
MSG_UME_DEREGISTRATION_SUCCESS_EX
UME receiver deregistration successful (extended version). |
static int |
MSG_UME_DEREGISTRATION_SUCCESS_EX_FLAG_RPP
Deregistration was flagged as coming from a RPP store |
static int |
MSG_UME_REGISTRATION_CHANGE
UME receiver notification of source registration change. |
static int |
MSG_UME_REGISTRATION_COMPLETE_EX
UME receiver notification of registration completion. |
static int |
MSG_UME_REGISTRATION_COMPLETE_EX_FLAG_QUORUM
Registration completed with only quorum reached. |
static int |
MSG_UME_REGISTRATION_COMPLETE_EX_FLAG_RXREQMAX
Registration completed with RX REQ maximum used. |
static int |
MSG_UME_REGISTRATION_ERROR
UME receiver registration encountered an error. |
static int |
MSG_UME_REGISTRATION_SUCCESS
UME receiver registration successful. |
static int |
MSG_UME_REGISTRATION_SUCCESS_EX
UME receiver registration successful (extended version). |
static int |
MSG_UME_REGISTRATION_SUCCESS_EX_FLAG_NOCACHE
Registration was flagged as coming from a store that is configured to not cache data. |
static int |
MSG_UME_REGISTRATION_SUCCESS_EX_FLAG_OLD
Registration was flagged as an old receiver by the store. |
static int |
MSG_UME_REGISTRATION_SUCCESS_EX_FLAG_RPP
Registration was flagged as coming from a store that has allowed a RPP receiver.. |
static int |
MSG_UMQ_DEREGISTRATION_COMPLETE_EX
UMQ receiver notification of deregistration completion. |
static int |
MSG_UMQ_DEREGISTRATION_COMPLETE_EX_FLAG_ULB
Deregistration completed with ULB source. |
static int |
MSG_UMQ_INDEX_ASSIGNED_EX
LBM message type: UMQ receiver notification of assignment of a particular index from a particular queue or ULB source. |
static int |
MSG_UMQ_INDEX_ASSIGNED_FLAG_ULB
Index assignment was from a ULB source. |
static int |
MSG_UMQ_INDEX_ASSIGNMENT_ELIGIBILITY_ERROR
LBM message type: UMQ receiver index assignment eligibility start/stop encountered an error. |
static int |
MSG_UMQ_INDEX_ASSIGNMENT_ELIGIBILITY_START_COMPLETE_EX
LBM message type: UMQ receiver notification of beginning of index assignment eligibility. |
static int |
MSG_UMQ_INDEX_ASSIGNMENT_ELIGIBILITY_START_COMPLETE_EX_FLAG_ULB
Index assignment eligibility start completed at a ULB source. |
static int |
MSG_UMQ_INDEX_ASSIGNMENT_ELIGIBILITY_STOP_COMPLETE_EX
LBM message type: UMQ receiver notification of end of index assignment eligibility. |
static int |
MSG_UMQ_INDEX_ASSIGNMENT_ELIGIBILITY_STOP_COMPLETE_EX_FLAG_ULB
Index assignment eligibility stop completed at a ULB source. |
static int |
MSG_UMQ_INDEX_RELEASED_EX
LBM message type: UMQ receiver notification of end of assignment of a particular index from a particular queue or ULB source. |
static int |
MSG_UMQ_INDEX_RELEASED_FLAG_ULB
Index released from a ULB source. |
static int |
MSG_UMQ_REASSIGN_FLAG_DISCARD
Instead of requesting reassignment, request the message be discarded. |
static int |
MSG_UMQ_REGISTRATION_COMPLETE_EX
UMQ receiver notification of registration completion. |
static int |
MSG_UMQ_REGISTRATION_COMPLETE_EX_FLAG_QUORUM
Registration completed with only quorum reached. |
static int |
MSG_UMQ_REGISTRATION_COMPLETE_EX_FLAG_ULB
Registration completed with ULB source. |
static int |
MSG_UMQ_REGISTRATION_ERROR
UMQ receiver notification of registration error. |
static int |
MSG_UNRECOVERABLE_LOSS
LBM message type: Missing message detected and not recovered in given time. |
static int |
MSG_UNRECOVERABLE_LOSS_BURST
LBM message type: Missing burst of messages detected and not recovered. |
static int |
SRC_BLOCK
Block the caller indefinitely until the message is sent. |
static int |
SRC_EVENT_CONNECT
Source event: For unicast transport, means receiver has connected. |
static int |
SRC_EVENT_DAEMON_CONFIRM
Source event: For LBM daemon usage only, means daemon has confirmed src created |
static int |
SRC_EVENT_DISCONNECT
Source event: For unicast transport, means receiver has disconnected. |
static int |
SRC_EVENT_FLIGHT_SIZE_NOTIFICATION
Source event: flight size notification. |
static int |
SRC_EVENT_FLIGHT_SIZE_NOTIFICATION_STATE_OVER
Messages in flight has exceeded the threshold. |
static int |
SRC_EVENT_FLIGHT_SIZE_NOTIFICATION_STATE_UNDER
Messages in flight is now below the threshold. |
static int |
SRC_EVENT_FLIGHT_SIZE_NOTIFICATION_TYPE_ULB
Specifies a ULB flight size. |
static int |
SRC_EVENT_FLIGHT_SIZE_NOTIFICATION_TYPE_UME
Specifies a UME flight size. |
static int |
SRC_EVENT_FLIGHT_SIZE_NOTIFICATION_TYPE_UMQ
Specifies a UMQ flight size. |
static int |
SRC_EVENT_SEQUENCE_NUMBER_INFO
Source event: Informs the application of the sequence numbers used with a message. |
static int |
SRC_EVENT_UME_DELIVERY_CONFIRMATION
Source event: (UME only) UME Confirmed Delivery of Message from a receiver. |
static int |
SRC_EVENT_UME_DELIVERY_CONFIRMATION_EX
Source event: For UME only, means UME Confirmed Delivery of Message from receiver (extended form). |
static int |
SRC_EVENT_UME_DELIVERY_CONFIRMATION_EX_FLAG_EXACK
Confirmation received with Explicit ACK (EXACK) flagged. |
static int |
SRC_EVENT_UME_DELIVERY_CONFIRMATION_EX_FLAG_OOD
Confirmation received with Out-of-Order Delivery (OOD) flagged. |
static int |
SRC_EVENT_UME_DELIVERY_CONFIRMATION_EX_FLAG_UNIQUEACKS
Confirmation received for specified number of unique ACKs. |
static int |
SRC_EVENT_UME_DELIVERY_CONFIRMATION_EX_FLAG_UREGID
Confirmation received with User Specified Rcv Registration ID flagged. |
static int |
SRC_EVENT_UME_DEREGISTRATION_COMPLETE_EX
UME source notification of deregistration completion. |
static int |
SRC_EVENT_UME_DEREGISTRATION_SUCCESS_EX
UME source deregistration successful (extended version). |
static int |
SRC_EVENT_UME_MESSAGE_RECLAIMED
Source event: (UME only) Indicates that a message has been reclaimed. |
static int |
SRC_EVENT_UME_MESSAGE_RECLAIMED_EX
Source event: Indicates that a message has been reclaimed (extended version). |
static int |
SRC_EVENT_UME_MESSAGE_RECLAIMED_EX_FLAG_FORCED
Reclaim notification is the result of a forced reclaim |
static int |
SRC_EVENT_UME_MESSAGE_STABLE
Source event: (UME only) UME ACK from store indicates message is stable. |
static int |
SRC_EVENT_UME_MESSAGE_STABLE_EX
Source event: For UME only, means UME ACK from store indicates message is stable (extended form). |
static int |
SRC_EVENT_UME_MESSAGE_STABLE_EX_FLAG_INTERGROUP_STABLE
Message stable for intergroup stability |
static int |
SRC_EVENT_UME_MESSAGE_STABLE_EX_FLAG_INTRAGROUP_STABLE
Message stable for intragroup stability |
static int |
SRC_EVENT_UME_MESSAGE_STABLE_EX_FLAG_STABLE
Message is stable according to behavior desired |
static int |
SRC_EVENT_UME_MESSAGE_STABLE_EX_FLAG_STORE
Message stable information has active store information |
static int |
SRC_EVENT_UME_MESSAGE_STABLE_EX_FLAG_USER
Message stabilized via the setUMEMessageStable API |
static int |
SRC_EVENT_UME_MESSAGE_STABLE_EX_FLAG_WHOLE_MESSAGE_STABLE
Whole message (each fragment) is stable |
static int |
SRC_EVENT_UME_REGISTRATION_COMPLETE_EX
Source event: (UME only) Registration of source complete. |
static int |
SRC_EVENT_UME_REGISTRATION_COMPLETE_EX_FLAG_QUORUM
Registration completed with only quorum reached. |
static int |
SRC_EVENT_UME_REGISTRATION_ERROR
Source event: (UME only) Registration of source failed with an error. |
static int |
SRC_EVENT_UME_REGISTRATION_SUCCESS
Source event: (UME only) Registration of source successful. |
static int |
SRC_EVENT_UME_REGISTRATION_SUCCESS_EX
Source event: (UME only) Registration of source successful (extended version). |
static int |
SRC_EVENT_UME_REGISTRATION_SUCCESS_EX_FLAG_NOACKS
Registration was flagged as coming from a store that is configured to not send ACKs for stability (no-cache store). |
static int |
SRC_EVENT_UME_REGISTRATION_SUCCESS_EX_FLAG_OLD
Registration was flagged as an old source by the store. |
static int |
SRC_EVENT_UME_REGISTRATION_SUCCESS_EX_FLAG_RPP
Registration was flagged as coming from a store that allows and has accepted RPP persistent topics |
static int |
SRC_EVENT_UME_STORE_UNRESPONSIVE
Source event: (UME only) Store has not been active within timeout. |
static int |
SRC_EVENT_UMQ_MESSAGE_ID_INFO
Source event: For UMQ only, informs the application of the Message ID assigned with a message. |
static int |
SRC_EVENT_UMQ_MESSAGE_STABLE_EX
Source event: For UMQ only, means a message is stable with the a queue instance. |
static int |
SRC_EVENT_UMQ_MESSAGE_STABLE_EX_FLAG_INTERGROUP_STABLE
Flag indicating that a message is stable across groups according to behavior desired. |
static int |
SRC_EVENT_UMQ_MESSAGE_STABLE_EX_FLAG_INTRAGROUP_STABLE
Flag indicating that a message is stable within a group. |
static int |
SRC_EVENT_UMQ_MESSAGE_STABLE_EX_FLAG_STABLE
Flag indicating that a message is stable according to behavior desired. |
static int |
SRC_EVENT_UMQ_MESSAGE_STABLE_EX_FLAG_USER
Message stabilized via the setUMQMessageStable API |
static int |
SRC_EVENT_UMQ_REGISTRATION_COMPLETE_EX
Source event: For UMQ only, means registration of source complete. |
static int |
SRC_EVENT_UMQ_REGISTRATION_COMPLETE_EX_FLAG_QUORUM
Flag indicating that registration completed with only quorum reached. |
static int |
SRC_EVENT_UMQ_REGISTRATION_ERROR
Source event: For UMQ only, means registration of source failed with an error. |
static int |
SRC_EVENT_UMQ_ULB_MESSAGE_ASSIGNED_EX
Source event: For UMQ only, means a ULB message has been assigned to a receiver. |
static int |
SRC_EVENT_UMQ_ULB_MESSAGE_COMPLETE_EX
Source event: For UMQ only, means a ULB message has been consumed or discarded from all application sets. |
static int |
SRC_EVENT_UMQ_ULB_MESSAGE_CONSUMED_EX
Source event: For UMQ only, means a ULB message has been consumed by a receiver. |
static int |
SRC_EVENT_UMQ_ULB_MESSAGE_REASSIGNED_EX
Source event: For UMQ only, means a ULB message has been reassigned from a receiver. |
static int |
SRC_EVENT_UMQ_ULB_MESSAGE_TIMEOUT_EX
Source event: For UMQ only, means a ULB message has been reached end-of-life. |
static int |
SRC_EVENT_UMQ_ULB_MESSAGE_TIMEOUT_EX_FLAG_DISCARD
Timeout is the result of the reassign API being called with the DISCARD flag set |
static int |
SRC_EVENT_UMQ_ULB_MESSAGE_TIMEOUT_EX_FLAG_EXPLICIT
Timeout is the result of the reassign API being called by a receiver |
static int |
SRC_EVENT_UMQ_ULB_MESSAGE_TIMEOUT_EX_FLAG_MAX_REASSIGNS
Timeout is the result of hitting the umq_ulb_application_set_message_max_reassignments number of assignments |
static int |
SRC_EVENT_UMQ_ULB_MESSAGE_TIMEOUT_EX_FLAG_TOTAL_LIFETIME_EXPIRED
Timeout is the result of the total lifetime expiring |
static int |
SRC_EVENT_UMQ_ULB_RECEIVER_DEREGISTRATION_EX
Source event: For UMQ only, means a receiver has deregistered from the source. |
static int |
SRC_EVENT_UMQ_ULB_RECEIVER_READY_EX
Source event: For UMQ only, means a receiver has signalled it is ready for messages to be assigned to it. |
static int |
SRC_EVENT_UMQ_ULB_RECEIVER_REGISTRATION_EX
Source event: For UMQ only, means a receiver has registered with the source. |
static int |
SRC_EVENT_UMQ_ULB_RECEIVER_TIMEOUT_EX
Source event: For UMQ only, means a receiver has reached end-of-life. |
static int |
SRC_EVENT_WAKEUP
Source event: Following earlier LBMEWouldBlockException, this event means that the source is ready for more sends. |
static int |
SRC_EVENT_WAKEUP_FLAG_MIM
Source wakeup event flag: Unblocked source is a context-level multicast immediate mode source. |
static int |
SRC_EVENT_WAKEUP_FLAG_NORMAL
Source wakeup event flag: Unblocked source is a normal (or hot failover) source. |
static int |
SRC_EVENT_WAKEUP_FLAG_REQUEST
Source wakeup event flag: Unblocked source is a context-level request source. |
static int |
SRC_EVENT_WAKEUP_FLAG_RESPONSE
Source wakeup event flag: Unblocked source is a context-level response source. |
static int |
SRC_EVENT_WAKEUP_FLAG_UIM
Source wakeup event flag: Unblocked source is a context-level unicast immediate mode source. |
static int |
SRC_NONBLOCK
If message could not be sent immediately, throw LBMEWouldBlockException |
static int |
SRC_SEND_EX_FLAG_APPHDR_CHAIN
Send message with included application header chain. |
static int |
SRC_SEND_EX_FLAG_CHANNEL
Send message with included channel information. |
static int |
SRC_SEND_EX_FLAG_HF_32
Send message with a 64 bit hot failover sequence number. |
static int |
SRC_SEND_EX_FLAG_HF_64
Send message with a 32 bit hot failover sequence number. |
static int |
SRC_SEND_EX_FLAG_HF_OPTIONAL
Send message marked as an optional message for Hot Failover |
static int |
SRC_SEND_EX_FLAG_PROPERTIES
Send message with supplied properties |
static int |
SRC_SEND_EX_FLAG_SEQUENCE_NUMBER_INFO
Inform application of the sequence numbers used for message. |
static int |
SRC_SEND_EX_FLAG_SEQUENCE_NUMBER_INFO_FRAGONLY
Inform application of the sequence numbers used for message (fragmented messages only). |
static int |
SRC_SEND_EX_FLAG_UMQ_INDEX
Send messages associating them with the supplied UMQ index |
static int |
SRC_SEND_EX_FLAG_UMQ_MESSAGE_ID_INFO
Inform application of the UMQ Message ID used for the message. |
static int |
SRC_SEND_EX_FLAG_UMQ_TOTAL_LIFETIME
Send message with supplied total lifetime |
static int |
SRC_TOPIC_ATTR_UME_STORE_BEHAVIOR_QC
Quorum and Consensus store behaviour |
static int |
SRC_TOPIC_ATTR_UME_STORE_BEHAVIOR_RR
Round Robin store behaviour |
static int |
TOPIC_RES_REQUEST_ADVERTISEMENT
Request advertisements from quiescent sources. |
static int |
TOPIC_RES_REQUEST_QUERY
Request queries from quiescent receivers. |
static int |
TOPIC_RES_REQUEST_WILDCARD_QUERY
Request queries from quiescent wildcard receivers |
static int |
TRANSPORT_STAT_DAEMON
Transport statistics type: Daemon is being used. |
static int |
TRANSPORT_STAT_LBTIPC
Transport statistics type: LBT-IPC transport. |
static int |
TRANSPORT_STAT_LBTRDMA
Transport statistics type: LBT-RDMA transport. |
static int |
TRANSPORT_STAT_LBTRM
Transport statistics type: LBT-RM transport. |
static int |
TRANSPORT_STAT_LBTRU
Transport statistics type: LBT-RU transport. |
static int |
TRANSPORT_STAT_TCP
Transport statistics type: TCP transport. |
static int |
UME_MAX_STORE_STRLEN
Maximum UME store length. |
static int |
UMQ_INDEX_FLAG_NUMERIC
UMQIndexInfo flag. |
static int |
UMQ_MAX_APPSET_STRLEN
Maximum UMQ queue appset name length. |
static int |
UMQ_MAX_INDEX_LEN
Maximum UMQ index length. |
static int |
UMQ_MAX_QUEUE_STRLEN
Maximum UMQ queue length. |
static int |
UMQ_MAX_TOPIC_STRLEN
Maximum UMQ queue topic name length. |
static int |
UMQ_QUEUE_MSG_STATUS_ASSIGNED
Queue message status; message is currently assigned to a receiver but not yet consumed. |
static int |
UMQ_QUEUE_MSG_STATUS_CONSUMED
Queue message status; message has been fully consumed and is no longer present in the queue. |
static int |
UMQ_QUEUE_MSG_STATUS_REASSIGNING
Queue message status; message is waiting to be re-assigned to a different receiver. |
static int |
UMQ_QUEUE_MSG_STATUS_UNASSIGNED
Queue message status; message is currently enqueued but not yet assigned. |
static int |
UMQ_QUEUE_MSG_STATUS_UNKNOWN
Queue message status; queue has no knowledge of the message. |
static int |
UMQ_ULB_MAX_RECEIVER_STRLEN
Maximum UMQ ULB receiver length. |
static int |
WILDCARD_RCV_PATTERN_TYPE_APP_CB
Wildcard receiver pattern type: callback |
static int |
WILDCARD_RCV_PATTERN_TYPE_PCRE
Wildcard receiver pattern type: PCRE (Perl Compatible Regular Expressions) |
static int |
WILDCARD_RCV_PATTERN_TYPE_REGEX
Wildcard receiver pattern type: POSIX regex |
Constructor Summary | |
---|---|
LBM()
Instantiate LBM utility class (initializes log) |
Method Summary | |
---|---|
static void |
asyncOperationCancel(long handle)
Cancel the asynchronous operation referred to by the given handle. |
static void |
asyncOperationCancel(long handle,
int flags)
Cancel the asynchronous operation referred to by the given handle. |
static void |
asyncOperationStatus(long handle)
Query the status of the asynchronous operation referred to by the given handle. |
static void |
asyncOperationStatus(long handle,
int flags)
Query the status of the asynchronous operation referred to by the given handle. |
static void |
dumpDebugLog(java.lang.String filename,
boolean append)
Dump the in-memory LBM debug log to a specified file. |
protected void |
finalize()
|
protected void |
log(int level,
java.lang.String message)
Logging callback. |
static void |
setConfiguration(java.lang.String fileName)
Configure LBM attributes from a file, tftp or http URL. |
static void |
setConfigurationXml(java.lang.String fileName,
java.lang.String applicationName)
Configure LBM attributes from a file, tftp or http URL. |
static void |
setConfigurationXmlString(java.lang.String xmlString,
java.lang.String applicationName)
Configure LBM attributes from a String |
static void |
setDebugFilename(java.lang.String filename)
Set the LBM debug filename. |
static void |
setDebugMask(long mask)
Set the LBM debug mask, as suggested by the support team. |
static void |
setLicenseFile(java.lang.String licenseFile)
Initialize the LBM license from the contents of a disk file. |
static void |
setLicenseString(java.lang.String licenseString)
Initialize the LBM license from a string. |
void |
setLogger(LBMLogging logger)
Inform LBM to use a specific logger for logging |
static void |
setUmmInfo(LBMUMMInfo info)
Connect to and retrieve configuration from a UMM daemon. |
static java.lang.String |
version()
Get LBM version information. |
Methods inherited from class java.lang.Object |
---|
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final int EINVAL
public static final int EWOULDBLOCK
public static final int ENOMEM
public static final int EOP
public static final int EOS
public static final int ETIMEDOUT
public static final int EDAEMONCONN
public static final int EUMENOREG
public static final int EAPPERR
public static final int ENO_QUEUE_REG
public static final int ENO_STORE_REG
public static final int EMSG_SELECTOR
public static final int MSG_DATA
public static final int MSG_EOS
public static final int MSG_REQUEST
public static final int MSG_RESPONSE
public static final int MSG_UNRECOVERABLE_LOSS
public static final int MSG_UNRECOVERABLE_LOSS_BURST
public static final int MSG_NO_SOURCE_NOTIFICATION
public static final int MSG_UME_REGISTRATION_ERROR
public static final int MSG_UME_REGISTRATION_SUCCESS
LBMMessage.sourceRegistrationId()
,
LBMMessage.receiverRegistrationId()
,
Constant Field Valuespublic static final int MSG_UME_REGISTRATION_CHANGE
public static final int MSG_UME_REGISTRATION_SUCCESS_EX
UMERegistrationSuccessInfo
object) can be retrieved with the LBMMessage.registrationSuccessInfo()
method.
UMERegistrationSuccessInfo
,
LBMMessage.registrationSuccessInfo()
,
Constant Field Valuespublic static final int MSG_UME_REGISTRATION_COMPLETE_EX
UMERegistrationCompleteInfo
object) can be retrieved with the LBMMessage.registrationCompleteInfo()
method.
UMERegistrationCompleteInfo
,
LBMMessage.registrationCompleteInfo()
,
Constant Field Valuespublic static final int MSG_UME_DEREGISTRATION_SUCCESS_EX
UMEDeregistrationSuccessInfo
object) can be retrieved with the LBMMessage.deregistrationSuccessInfo()
method.
UMEDeregistrationSuccessInfo
,
LBMMessage.deregistrationSuccessInfo()
,
Constant Field Valuespublic static final int MSG_UME_DEREGISTRATION_COMPLETE_EX
UMEDeregistrationCompleteInfo
object) can be retrieved with the LBMMessage.deregistrationCompleteInfo()
method.
UMEDeregistrationCompleteInfo
,
LBMMessage.deregistrationCompleteInfo()
,
Constant Field Valuespublic static final int MSG_UMQ_REGISTRATION_ERROR
LBMMessage.dataString()
method.
LBMMessage.dataString()
,
Constant Field Valuespublic static final int MSG_UMQ_REGISTRATION_COMPLETE_EX
UMQRegistrationCompleteInfo
object) can be retrieved with the LBMMessage.queueRegistrationCompleteInfo()
method.
UMQRegistrationCompleteInfo
,
LBMMessage.queueRegistrationCompleteInfo()
,
Constant Field Valuespublic static final int MSG_UMQ_DEREGISTRATION_COMPLETE_EX
UMQDeregistrationCompleteInfo
object) can be retrieved with the LBMMessage.queueDeregistrationCompleteInfo()
method.
UMQDeregistrationCompleteInfo
,
LBMMessage.queueDeregistrationCompleteInfo()
,
Constant Field Valuespublic static final int MSG_BOS
public static final int MSG_UMQ_INDEX_ASSIGNMENT_ELIGIBILITY_ERROR
public static final int MSG_UMQ_INDEX_ASSIGNMENT_ELIGIBILITY_START_COMPLETE_EX
UMQIndexAssignmentEligibilityStartCompleteInfo
object) can be retrieved with the LBMMessage#indexAssignmentEligibilityStartCompleteInfo()
method.
UMQIndexAssignmentEligibilityStartCompleteInfo
,
LBMMessage#indexAssignmentEligibilityStartCompleteInfo()
,
Constant Field Valuespublic static final int MSG_UMQ_INDEX_ASSIGNMENT_ELIGIBILITY_STOP_COMPLETE_EX
UMQIndexAssignmentEligibilityStopCompleteInfo
object) can be retrieved with the LBMMessage#indexAssignmentEligibilityStopCompleteInfo()
method.
UMQIndexAssignmentEligibilityStopCompleteInfo
,
LBMMessage#indexAssignmentEligibilityStopCompleteInfo()
,
Constant Field Valuespublic static final int MSG_UMQ_INDEX_ASSIGNED_EX
UMQIndexAssignedInfo
object) can be retrieved with the LBMMessage#indexAssignedInfo()
method.
UMQIndexAssignedInfo
,
LBMMessage#indexAssignedInfo()
,
Constant Field Valuespublic static final int MSG_UMQ_INDEX_RELEASED_EX
UMQIndexReleasedInfo
object) can be retrieved with the LBMMessage#indexReleasedInfo()
method.
UMQIndexReleasedInfo
,
LBMMessage#indexReleasedInfo()
,
Constant Field Valuespublic static final int MSG_HF_RESET
LBMMessage.hfSequenceNumber()
,
MSG_FLAG_HF_32
,
MSG_FLAG_HF_64
,
Constant Field Valuespublic static final int SRC_EVENT_UME_DEREGISTRATION_SUCCESS_EX
UMESourceEventDeregistrationSuccessInfo
object) can be retrieved with the LBMMessage#SourceEventderegistrationSuccessInfo()
method.
UMESourceEventDeregistrationSuccessInfo
,
LBMMessage#SourceEventderegistrationSuccessInfo()
,
Constant Field Valuespublic static final int SRC_EVENT_UME_DEREGISTRATION_COMPLETE_EX
UMESourceEventDeregistrationCompleteInfo
object) can be retrieved with the LBMMessage#SourceEventderegistrationCompleteInfo()
method.
UMESourceEventDeregistrationCompleteInfo
,
LBMMessage#SourceEventderegistrationCompleteInfo()
,
Constant Field Valuespublic static final int MSG_UME_REGISTRATION_SUCCESS_EX_FLAG_OLD
MSG_UME_REGISTRATION_SUCCESS_EX
,
UMERegistrationSuccessInfo.flags()
,
Constant Field Valuespublic static final int MSG_UME_REGISTRATION_SUCCESS_EX_FLAG_NOCACHE
MSG_UME_REGISTRATION_SUCCESS_EX
,
UMERegistrationSuccessInfo.flags()
,
Constant Field Valuespublic static final int MSG_UME_REGISTRATION_SUCCESS_EX_FLAG_RPP
MSG_UME_REGISTRATION_COMPLETE_EX
,
UMERegistrationCompleteInfo.flags()
,
Constant Field Valuespublic static final int MSG_UME_REGISTRATION_COMPLETE_EX_FLAG_QUORUM
MSG_UME_REGISTRATION_COMPLETE_EX
,
UMERegistrationCompleteInfo.flags()
,
Constant Field Valuespublic static final int MSG_UME_REGISTRATION_COMPLETE_EX_FLAG_RXREQMAX
MSG_UME_REGISTRATION_COMPLETE_EX
,
UMERegistrationCompleteInfo.flags()
,
Constant Field Valuespublic static final int MSG_UME_DEREGISTRATION_SUCCESS_EX_FLAG_RPP
UMEDeregistrationCompleteInfo.flags()
,
Constant Field Valuespublic static final int MSG_UMQ_REGISTRATION_COMPLETE_EX_FLAG_QUORUM
MSG_UMQ_REGISTRATION_COMPLETE_EX
,
UMQQueueInfo.flags()
,
Constant Field Valuespublic static final int MSG_UMQ_REGISTRATION_COMPLETE_EX_FLAG_ULB
MSG_UMQ_REGISTRATION_COMPLETE_EX
,
UMQQueueInfo.flags()
,
Constant Field Valuespublic static final int MSG_UMQ_DEREGISTRATION_COMPLETE_EX_FLAG_ULB
MSG_UMQ_DEREGISTRATION_COMPLETE_EX
,
UMQQueueInfo.flags()
,
Constant Field Valuespublic static final int MSG_UMQ_INDEX_ASSIGNED_FLAG_ULB
MSG_UMQ_INDEX_ASSIGNED_EX
,
UMQQueueInfo.flags()
,
Constant Field Valuespublic static final int MSG_UMQ_INDEX_RELEASED_FLAG_ULB
MSG_UMQ_INDEX_RELEASED_EX
,
UMQQueueInfo.flags()
,
Constant Field Valuespublic static final int MSG_UMQ_INDEX_ASSIGNMENT_ELIGIBILITY_STOP_COMPLETE_EX_FLAG_ULB
MSG_UMQ_INDEX_ASSIGNMENT_ELIGIBILITY_STOP_COMPLETE_EX
,
UMQQueueInfo.flags()
,
Constant Field Valuespublic static final int MSG_UMQ_INDEX_ASSIGNMENT_ELIGIBILITY_START_COMPLETE_EX_FLAG_ULB
MSG_UMQ_INDEX_ASSIGNMENT_ELIGIBILITY_START_COMPLETE_EX
,
UMQQueueInfo.flags()
,
Constant Field Valuespublic static final byte CHAIN_ELEM_USER_DATA
public static final int MSG_START_BATCH
public static final int MSG_END_BATCH
public static final int MSG_COMPLETE_BATCH
public static final int MSG_FLUSH
public static final int SRC_NONBLOCK
LBMEWouldBlockException
,
Constant Field Valuespublic static final int SRC_BLOCK
public static final int MSG_FLAG_START_BATCH
public static final int MSG_FLAG_END_BATCH
public static final int MSG_FLAG_HF_PASS_THROUGH
public static final int MSG_FLAG_UME_RETRANSMIT
public static final int MSG_FLAG_RETRANSMIT
public static final int MSG_FLAG_IMMEDIATE
public static final int MSG_FLAG_HF_DUPLICATE
public static final int MSG_FLAG_UMQ_REASSIGNED
public static final int MSG_FLAG_UMQ_RESUBMITTED
public static final int MSG_FLAG_TOPICLESS
public static final int MSG_FLAG_DELIVERY_LATENCY
public static final int MSG_FLAG_HF_OPTIONAL
public static final int MSG_FLAG_HF_32
public static final int MSG_FLAG_HF_64
public static final int MSG_FLAG_OTR
public static final int MSG_FLAG_NUMBERED_CHANNEL
public static final int MSG_PROPERTY_BOOLEAN
public static final int MSG_PROPERTY_BYTE
public static final int MSG_PROPERTY_SHORT
public static final int MSG_PROPERTY_INT
public static final int MSG_PROPERTY_LONG
public static final int MSG_PROPERTY_FLOAT
public static final int MSG_PROPERTY_DOUBLE
public static final int MSG_PROPERTY_STRING
public static final int SRC_EVENT_CONNECT
public static final int SRC_EVENT_DISCONNECT
public static final int SRC_EVENT_WAKEUP
LBMEWouldBlockException
,
Constant Field Valuespublic static final int SRC_EVENT_WAKEUP_FLAG_NORMAL
LBMSourceEventWakeupInfo
,
Constant Field Valuespublic static final int SRC_EVENT_WAKEUP_FLAG_MIM
LBMSourceEventWakeupInfo
,
Constant Field Valuespublic static final int SRC_EVENT_WAKEUP_FLAG_UIM
LBMSourceEventWakeupInfo
,
Constant Field Valuespublic static final int SRC_EVENT_WAKEUP_FLAG_REQUEST
LBMSourceEventWakeupInfo
,
Constant Field Valuespublic static final int SRC_EVENT_WAKEUP_FLAG_RESPONSE
LBMSourceEventWakeupInfo
,
Constant Field Valuespublic static final int SRC_EVENT_DAEMON_CONFIRM
public static final int SRC_EVENT_UME_REGISTRATION_ERROR
public static final int SRC_EVENT_UME_REGISTRATION_SUCCESS
public static final int SRC_EVENT_UME_MESSAGE_STABLE
LBMSource.send(byte[],int,int,Object)
,
Constant Field Valuespublic static final int SRC_EVENT_UME_DELIVERY_CONFIRMATION
LBMSource.send(byte[],int,int,Object)
,
Constant Field Valuespublic static final int SRC_EVENT_UME_STORE_UNRESPONSIVE
public static final int SRC_EVENT_UME_MESSAGE_RECLAIMED
LBMSource.send(byte[],int,int,Object)
,
Constant Field Valuespublic static final int SRC_EVENT_UME_REGISTRATION_SUCCESS_EX
UMESourceEventRegistrationSuccessInfo
object) can be retrieved with the LBMSourceEvent.registrationSuccessInfo()
method.
UMESourceEventRegistrationSuccessInfo
,
LBMSourceEvent.registrationSuccessInfo()
,
Constant Field Valuespublic static final int SRC_EVENT_UME_REGISTRATION_COMPLETE_EX
UMESourceEventRegistrationCompleteInfo
object) can be retrieved with the LBMSourceEvent.registrationCompleteInfo()
method.
UMESourceEventRegistrationCompleteInfo
,
LBMSourceEvent.registrationCompleteInfo()
,
Constant Field Valuespublic static final int SRC_EVENT_UME_MESSAGE_STABLE_EX
UMESourceEventMessageStableInfo
,
LBMSourceEvent#messageStableInfo()
,
Constant Field Valuespublic static final int SRC_EVENT_UME_DELIVERY_CONFIRMATION_EX
UMESourceEventDeliveryConfirmationInfo
,
LBMSourceEvent#deliveryConfirmationInfo()
,
Constant Field Valuespublic static final int SRC_EVENT_SEQUENCE_NUMBER_INFO
LBMSourceEventSequenceNumberInfo
,
LBMSourceEvent.sequenceNumberInfo()
,
Constant Field Valuespublic static final int SRC_EVENT_UMQ_REGISTRATION_ERROR
LBMSourceEvent.dataString()
,
Constant Field Valuespublic static final int SRC_EVENT_UMQ_MESSAGE_ID_INFO
LBMSourceEvent#messageIdInfo)
,
Constant Field Valuespublic static final int SRC_EVENT_UMQ_REGISTRATION_COMPLETE_EX
LBMSourceEvent.queueRegistrationCompleteInfo()
,
Constant Field Valuespublic static final int SRC_EVENT_UMQ_MESSAGE_STABLE_EX
LBMSourceEvent.queueAckInfo()
,
Constant Field Valuespublic static final int SRC_EVENT_UMQ_ULB_MESSAGE_ASSIGNED_EX
LBMSourceEvent.ulbMessageInfo()
,
Constant Field Valuespublic static final int SRC_EVENT_UMQ_ULB_MESSAGE_REASSIGNED_EX
LBMSourceEvent.ulbMessageInfo()
,
Constant Field Valuespublic static final int SRC_EVENT_UMQ_ULB_MESSAGE_TIMEOUT_EX
LBMSourceEvent.ulbMessageInfo()
,
Constant Field Valuespublic static final int SRC_EVENT_UMQ_ULB_MESSAGE_COMPLETE_EX
LBMSourceEvent.ulbMessageInfo()
,
Constant Field Valuespublic static final int SRC_EVENT_UMQ_ULB_MESSAGE_CONSUMED_EX
LBMSourceEvent.ulbMessageInfo()
,
Constant Field Valuespublic static final int SRC_EVENT_UMQ_ULB_RECEIVER_REGISTRATION_EX
LBMSourceEvent.ulbReceiverInfo()
,
Constant Field Valuespublic static final int SRC_EVENT_UMQ_ULB_RECEIVER_DEREGISTRATION_EX
LBMSourceEvent.ulbReceiverInfo()
,
Constant Field Valuespublic static final int SRC_EVENT_UMQ_ULB_RECEIVER_READY_EX
LBMSourceEvent.ulbReceiverInfo()
,
Constant Field Valuespublic static final int SRC_EVENT_UMQ_ULB_RECEIVER_TIMEOUT_EX
LBMSourceEvent.ulbReceiverInfo()
,
Constant Field Valuespublic static final int SRC_EVENT_FLIGHT_SIZE_NOTIFICATION
LBMSourceEvent.flightSizeNotification()
,
Constant Field Valuespublic static final int SRC_EVENT_UME_MESSAGE_RECLAIMED_EX
LBMSource.send(byte[],int,int,Object)
,
Constant Field Valuespublic static final int SRC_EVENT_UME_REGISTRATION_SUCCESS_EX_FLAG_OLD
SRC_EVENT_UME_REGISTRATION_SUCCESS_EX
,
UMESourceEventRegistrationSuccessInfo.flags()
,
Constant Field Valuespublic static final int SRC_EVENT_UME_REGISTRATION_SUCCESS_EX_FLAG_NOACKS
SRC_EVENT_UME_REGISTRATION_SUCCESS_EX
,
UMESourceEventRegistrationSuccessInfo.flags()
,
Constant Field Valuespublic static final int SRC_EVENT_UME_REGISTRATION_SUCCESS_EX_FLAG_RPP
SRC_EVENT_UME_REGISTRATION_SUCCESS_EX
,
UMESourceEventRegistrationSuccessInfo.flags()
,
Constant Field Valuespublic static final int SRC_EVENT_UME_REGISTRATION_COMPLETE_EX_FLAG_QUORUM
SRC_EVENT_UME_REGISTRATION_COMPLETE_EX
,
UMESourceEventRegistrationCompleteInfo.flags()
,
Constant Field Valuespublic static final int SRC_EVENT_UME_DELIVERY_CONFIRMATION_EX_FLAG_UNIQUEACKS
public static final int SRC_EVENT_UME_DELIVERY_CONFIRMATION_EX_FLAG_UREGID
public static final int SRC_EVENT_UME_DELIVERY_CONFIRMATION_EX_FLAG_OOD
public static final int SRC_EVENT_UME_DELIVERY_CONFIRMATION_EX_FLAG_EXACK
public static final int SRC_EVENT_UME_MESSAGE_STABLE_EX_FLAG_INTRAGROUP_STABLE
public static final int SRC_EVENT_UME_MESSAGE_STABLE_EX_FLAG_INTERGROUP_STABLE
public static final int SRC_EVENT_UME_MESSAGE_STABLE_EX_FLAG_STABLE
public static final int SRC_EVENT_UME_MESSAGE_STABLE_EX_FLAG_STORE
public static final int SRC_EVENT_UME_MESSAGE_STABLE_EX_FLAG_WHOLE_MESSAGE_STABLE
public static final int SRC_EVENT_UME_MESSAGE_STABLE_EX_FLAG_USER
public static final int SRC_EVENT_UME_MESSAGE_RECLAIMED_EX_FLAG_FORCED
public static final int SRC_EVENT_UMQ_REGISTRATION_COMPLETE_EX_FLAG_QUORUM
public static final int SRC_EVENT_UMQ_MESSAGE_STABLE_EX_FLAG_INTRAGROUP_STABLE
public static final int SRC_EVENT_UMQ_MESSAGE_STABLE_EX_FLAG_INTERGROUP_STABLE
public static final int SRC_EVENT_UMQ_MESSAGE_STABLE_EX_FLAG_STABLE
public static final int SRC_EVENT_UMQ_MESSAGE_STABLE_EX_FLAG_USER
public static final int SRC_EVENT_FLIGHT_SIZE_NOTIFICATION_TYPE_UME
public static final int SRC_EVENT_FLIGHT_SIZE_NOTIFICATION_TYPE_ULB
public static final int SRC_EVENT_FLIGHT_SIZE_NOTIFICATION_TYPE_UMQ
public static final int SRC_EVENT_FLIGHT_SIZE_NOTIFICATION_STATE_OVER
public static final int SRC_EVENT_FLIGHT_SIZE_NOTIFICATION_STATE_UNDER
public static final int FLIGHT_SIZE_TYPE_UME
public static final int FLIGHT_SIZE_TYPE_ULB
public static final int FLIGHT_SIZE_TYPE_UMQ
public static final int SRC_EVENT_UMQ_ULB_MESSAGE_TIMEOUT_EX_FLAG_TOTAL_LIFETIME_EXPIRED
public static final int SRC_EVENT_UMQ_ULB_MESSAGE_TIMEOUT_EX_FLAG_EXPLICIT
public static final int SRC_EVENT_UMQ_ULB_MESSAGE_TIMEOUT_EX_FLAG_DISCARD
public static final int SRC_EVENT_UMQ_ULB_MESSAGE_TIMEOUT_EX_FLAG_MAX_REASSIGNS
public static final int CONTEXT_EVENT_UMQ_REGISTRATION_COMPLETE_EX
public static final int CONTEXT_EVENT_UMQ_REGISTRATION_SUCCESS_EX
public static final int CONTEXT_EVENT_UMQ_REGISTRATION_ERROR
public static final int CONTEXT_EVENT_UMQ_INSTANCE_LIST_NOTIFICATION
public static final int CONTEXT_EVENT_UMQ_REGISTRATION_COMPLETE_EX_FLAG_QUORUM
public static final int SRC_SEND_EX_FLAG_SEQUENCE_NUMBER_INFO
LBMSource.send(byte[], int, int, LBMSourceSendExInfo)
,
Constant Field Valuespublic static final int SRC_SEND_EX_FLAG_SEQUENCE_NUMBER_INFO_FRAGONLY
LBMSource.send(byte[], int, int, LBMSourceSendExInfo)
,
Constant Field Valuespublic static final int SRC_SEND_EX_FLAG_APPHDR_CHAIN
LBMSource.send(byte[], int, int, LBMSourceSendExInfo)
,
Constant Field Valuespublic static final int SRC_SEND_EX_FLAG_UMQ_MESSAGE_ID_INFO
LBMSource.send(byte[], int, int, LBMSourceSendExInfo)
,
Constant Field Valuespublic static final int SRC_SEND_EX_FLAG_CHANNEL
LBMSource.send(byte[], int, int, LBMSourceSendExInfo)
,
Constant Field Valuespublic static final int SRC_SEND_EX_FLAG_UMQ_INDEX
LBMSource.send(byte[], int, int, LBMSourceSendExInfo)
,
Constant Field Valuespublic static final int SRC_SEND_EX_FLAG_UMQ_TOTAL_LIFETIME
LBMSource.send(byte[], int, int, LBMSourceSendExInfo)
,
Constant Field Valuespublic static final int SRC_SEND_EX_FLAG_HF_OPTIONAL
LBMSource.send(byte[], int, int, LBMSourceSendExInfo)
,
Constant Field Valuespublic static final int SRC_SEND_EX_FLAG_PROPERTIES
LBMSource.send(byte[], int, int, LBMSourceSendExInfo)
,
Constant Field Valuespublic static final int SRC_SEND_EX_FLAG_HF_32
public static final int SRC_SEND_EX_FLAG_HF_64
public static final int UMQ_INDEX_FLAG_NUMERIC
UMQIndexInfo
,
UMQIndexInfo.flags()
,
UMQIndexInfo#setFlags(int flags)
,
Constant Field Valuespublic static final int SRC_TOPIC_ATTR_UME_STORE_BEHAVIOR_RR
public static final int SRC_TOPIC_ATTR_UME_STORE_BEHAVIOR_QC
public static final int MSG_UMQ_REASSIGN_FLAG_DISCARD
LBMMessage#reassign()
,
Constant Field Valuespublic static final int CTX_ATTR_OP_EMBEDDED
public static final int CTX_ATTR_OP_DAEMON
public static final int CTX_ATTR_OP_SEQUENTIAL
public static final int MSG_MAX_SOURCE_LEN
public static final int MSG_MAX_TOPIC_LEN
public static final int UMQ_MAX_INDEX_LEN
public static final int UME_MAX_STORE_STRLEN
public static final int UMQ_MAX_QUEUE_STRLEN
public static final int UMQ_ULB_MAX_RECEIVER_STRLEN
public static final int UMQ_MAX_TOPIC_STRLEN
public static final int UMQ_MAX_APPSET_STRLEN
public static final long EVENT_QUEUE_BLOCK
public static final long EVENT_QUEUE_POLL
public static final int EVENT_QUEUE_SIZE_WARNING
public static final int EVENT_QUEUE_DELAY_WARNING
public static final int EVENT_QUEUE_ENQUEUE_NOTIFICATION
public static final int LOG_EMERG
public static final int LOG_ALERT
public static final int LOG_CRIT
public static final int LOG_ERR
public static final int LOG_WARNING
public static final int LOG_NOTICE
public static final int LOG_INFO
public static final int LOG_DEBUG
public static final int TRANSPORT_STAT_TCP
public static final int TRANSPORT_STAT_LBTRM
public static final int TRANSPORT_STAT_LBTRU
public static final int TRANSPORT_STAT_LBTIPC
public static final int TRANSPORT_STAT_LBTRDMA
public static final int TRANSPORT_STAT_DAEMON
public static final int WILDCARD_RCV_PATTERN_TYPE_PCRE
public static final int WILDCARD_RCV_PATTERN_TYPE_REGEX
public static final int WILDCARD_RCV_PATTERN_TYPE_APP_CB
public static final int TOPIC_RES_REQUEST_ADVERTISEMENT
public static final int TOPIC_RES_REQUEST_QUERY
public static final int TOPIC_RES_REQUEST_WILDCARD_QUERY
public static final long LBM_SRC_COST_FUNCTION_REJECT
public static final long LBM_UMM_INFO_FLAGS_USE_SSL
LBMUMMInfo.LBMUMMInfo(String, String, String, String[])
,
Constant Field Valuespublic static final long LBM_UMM_NUM_SERVERS_MAX
public static final int LBM_UME_LIVENESS_RECEIVER_UNRESPONSIVE_FLAG_TMO
public static final int LBM_UME_LIVENESS_RECEIVER_UNRESPONSIVE_FLAG_EOF
public static final int ASYNC_OP_TYPE_CTX_UMQ_QUEUE_TOPIC_LIST
public static final int ASYNC_OP_TYPE_RCV_UMQ_QUEUE_MSG_LIST
public static final int ASYNC_OP_TYPE_RCV_UMQ_QUEUE_MSG_RETRIEVE
public static final int ASYNC_OP_STATUS_IN_PROGRESS
public static final int ASYNC_OP_STATUS_COMPLETE
public static final int ASYNC_OP_STATUS_ERROR
public static final int ASYNC_OP_STATUS_CANCELED
public static final long ASYNC_OP_INVALID_HANDLE
public static final int ASYNC_OPERATION_CANCEL_FLAG_NONBLOCK
public static final int ASYNC_OPERATION_STATUS_FLAG_NONBLOCK
public static final int ASYNC_OP_INFO_FLAG_INLINE
public static final int ASYNC_OP_INFO_FLAG_FIRST
public static final int ASYNC_OP_INFO_FLAG_LAST
public static final int ASYNC_OP_INFO_FLAG_ONLY
public static final int UMQ_QUEUE_MSG_STATUS_UNKNOWN
public static final int UMQ_QUEUE_MSG_STATUS_UNASSIGNED
public static final int UMQ_QUEUE_MSG_STATUS_ASSIGNED
public static final int UMQ_QUEUE_MSG_STATUS_REASSIGNING
public static final int UMQ_QUEUE_MSG_STATUS_CONSUMED
public static final int LBM_TEXTMESSAGE
public static final int LBM_BYTEMESSAGE
public static final int LBM_MAPMESSAGE
public static final int LBM_MESSAGE
public static final int LBM_OBJECTMESSAGE
public static final int LBM_STREAMMESSAGE
public static final java.lang.String LBM_JMSDeliveryMode
public static final java.lang.String LBM_JMSExpiration
public static final java.lang.String LBM_JMSPriority
public static final java.lang.String LBM_JMSMessageID
public static final java.lang.String LBM_JMSTimestamp
public static final java.lang.String LBM_JMSCorrelationID
public static final java.lang.String LBM_JMSType
public static final java.lang.String LBM_JMSRedelivered
public static final java.lang.String LBM_LBMMessageType
public static final java.lang.String LBM_JMSTopicType
public static final java.lang.String LBM_JMSReplyToName
public static final java.lang.String LBM_JMSReplyToWildcard
public static final java.lang.String LBM_JMSReplyToType
Constructor Detail |
---|
public LBM() throws LBMException
LBMException
- if any initialization error occurs.Method Detail |
---|
protected void finalize()
finalize
in class java.lang.Object
public static void setLicenseFile(java.lang.String licenseFile) throws LBMException
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.public static void setLicenseString(java.lang.String licenseString) throws LBMException
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.public static void setConfiguration(java.lang.String fileName) throws LBMException
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.public static void setConfigurationXml(java.lang.String fileName, java.lang.String applicationName) throws LBMException
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.public static void setConfigurationXmlString(java.lang.String xmlString, java.lang.String applicationName) throws LBMException
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.public static void setUmmInfo(LBMUMMInfo info) throws LBMException
info
- UMM daemon connection options
LBMException
- if UMM info has already been loaded, or if some other error was encountered.public static java.lang.String version()
protected void log(int level, java.lang.String message) throws LBMException
level
- Log level of messagemessage
- Log message
LBMException
- When an error occurs while calling the log callbacksetLogger(LBMLogging)
public void setLogger(LBMLogging logger)
logger
- Logging object implementing the LBMLogging interfacepublic static void setDebugFilename(java.lang.String filename) throws LBMException
filename
- The name of the file to be written with debug data.
LBMException
- if out of memory.public static void setDebugMask(long mask)
mask
- The mask used for debugging purposes.public static void dumpDebugLog(java.lang.String filename, boolean append) throws LBMException
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.
LBMException
public static void asyncOperationCancel(long handle) throws LBMException
handle
- The handle to the asynchronous operation.
LBMException
- if the operation could not be canceled.public static void asyncOperationCancel(long handle, int flags) throws LBMEWouldBlockException, LBMException
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.ASYNC_OPERATION_CANCEL_FLAG_NONBLOCK
public static void asyncOperationStatus(long handle) throws LBMException
handle
- The handle to the asynchronous operation.
LBMException
- if the operation could not be found.public static void asyncOperationStatus(long handle, int flags) throws LBMEWouldBlockException, LBMException
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.ASYNC_OPERATION_STATUS_FLAG_NONBLOCK
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |