libbmq
a5f8a06ba1d16cb5a65643e1fa7f1a1d6aadef40
|
Classes | |
struct | CompressionAlgorithmType |
This struct defines various types of compression algorithms. More... | |
class | CorrelationId |
struct | CorrelationIdLess |
struct | EncodingType |
Enumeration for message encoding types. More... | |
struct | HostHealthState |
Enumeration for host health states. More... | |
struct | MessageEventType |
Enumeration for the types of message events. More... | |
class | MessageGUID |
struct | MessageGUIDLess |
This struct provides a binary function for comparing 2 GUIDs. More... | |
class | MessageGUIDHashAlgo |
struct | PropertyType |
This enum represents the supported data types for a message property. More... | |
struct | QueueFlags |
This enum represents queue flags. More... | |
struct | QueueFlagsUtil |
class | QueueOptions |
Value-semantic type for options related to a queue. More... | |
struct | GenericResult |
This enum represents generic common status. More... | |
struct | OpenQueueResult |
This enum represents the result of an openQueue operation. More... | |
struct | ConfigureQueueResult |
This enum represents the result of a configureQueue operation. More... | |
struct | CloseQueueResult |
This enum represents the result of a closeQueue operation. More... | |
struct | EventBuilderResult |
struct | AckResult |
This enum represents the result code status of an ack message. More... | |
struct | PostResult |
This enum represents the result code status of a post message. More... | |
struct | SessionEventType |
Enumeration for the types of session events. More... | |
class | SessionOptions |
class | SubscriptionHandle |
Value-semantic type for unique Subscription id. More... | |
class | SubscriptionExpression |
Value-semantic type to carry Subscription criteria. More... | |
class | Subscription |
Value-semantic type to carry Subscription parameters. More... | |
class | Uri |
Value semantic type representing a URI. More... | |
struct | UriParser |
Utility namespace of methods for parsing URI strings into Uri objects. More... | |
class | UriBuilder |
class | Version |
A version consisting of a major and minor version number. More... | |
Functions | |
bsl::ostream & | operator<< (bsl::ostream &stream, CompressionAlgorithmType::Enum value) |
bsl::ostream & | operator<< (bsl::ostream &stream, const CorrelationId &rhs) |
bool | operator== (const CorrelationId &lhs, const CorrelationId &rhs) |
bool | operator!= (const CorrelationId &lhs, const CorrelationId &rhs) |
bool | operator< (const CorrelationId &lhs, const CorrelationId &rhs) |
template<class HASH_ALGORITHM > | |
void | hashAppend (HASH_ALGORITHM &hashAlgo, const CorrelationId &value) |
bsl::ostream & | operator<< (bsl::ostream &stream, EncodingType::Enum value) |
bsl::ostream & | operator<< (bsl::ostream &stream, HostHealthState::Enum value) |
bsl::ostream & | operator<< (bsl::ostream &stream, MessageEventType::Enum value) |
bsl::ostream & | operator<< (bsl::ostream &stream, const MessageGUID &rhs) |
bool | operator== (const MessageGUID &lhs, const MessageGUID &rhs) |
bool | operator!= (const MessageGUID &lhs, const MessageGUID &rhs) |
bool | operator< (const MessageGUID &lhs, const MessageGUID &rhs) |
template<class HASH_ALGORITHM > | |
void | hashAppend (HASH_ALGORITHM &hashAlgo, const MessageGUID &guid) |
bsl::ostream & | operator<< (bsl::ostream &stream, PropertyType::Enum value) |
bsl::ostream & | operator<< (bsl::ostream &stream, QueueFlags::Enum value) |
bool | operator== (const QueueOptions &lhs, const QueueOptions &rhs) |
bool | operator!= (const QueueOptions &lhs, const QueueOptions &rhs) |
bsl::ostream & | operator<< (bsl::ostream &stream, const QueueOptions &rhs) |
bsl::ostream & | operator<< (bsl::ostream &stream, GenericResult::Enum value) |
bsl::ostream & | operator<< (bsl::ostream &stream, OpenQueueResult::Enum value) |
bsl::ostream & | operator<< (bsl::ostream &stream, ConfigureQueueResult::Enum value) |
bsl::ostream & | operator<< (bsl::ostream &stream, CloseQueueResult::Enum value) |
bsl::ostream & | operator<< (bsl::ostream &stream, EventBuilderResult::Enum value) |
bsl::ostream & | operator<< (bsl::ostream &stream, AckResult::Enum value) |
bsl::ostream & | operator<< (bsl::ostream &stream, PostResult::Enum value) |
bsl::ostream & | operator<< (bsl::ostream &stream, SessionEventType::Enum value) |
bool | operator== (const SessionOptions &lhs, const SessionOptions &rhs) |
bool | operator!= (const SessionOptions &lhs, const SessionOptions &rhs) |
bsl::ostream & | operator<< (bsl::ostream &stream, const SessionOptions &rhs) |
bsl::ostream & | operator<< (bsl::ostream &stream, const SubscriptionHandle &rhs) |
bsl::ostream & | operator<< (bsl::ostream &stream, const Subscription &rhs) |
template<class HASH_ALGORITHM > | |
void | hashAppend (HASH_ALGORITHM &hashAlgo, const SubscriptionHandle &id) |
Apply the specified hashAlgo to the specified id . More... | |
bool | operator< (const SubscriptionHandle &lhs, const SubscriptionHandle &rhs) |
bool | operator== (const SubscriptionHandle &lhs, const SubscriptionHandle &rhs) |
bool | operator!= (const SubscriptionHandle &lhs, const SubscriptionHandle &rhs) |
bool | operator== (const Uri &lhs, const Uri &rhs) |
bool | operator!= (const Uri &lhs, const Uri &rhs) |
bool | operator< (const Uri &lhs, const Uri &rhs) |
bsl::ostream & | operator<< (bsl::ostream &stream, const Uri &rhs) |
template<class HASH_ALGORITHM > | |
void | hashAppend (HASH_ALGORITHM &hashAlgo, const Uri &uri) |
bsl::ostream & | operator<< (bsl::ostream &stream, const Version &rhs) |
bool | operator== (const Version &lhs, const Version &rhs) |
bool | operator!= (const Version &lhs, const Version &rhs) |
bool | operator< (const Version &lhs, const Version &rhs) |
|
inline |
Format the specified value
to the specified output stream
and return a reference to the modifiable stream
.
References BloombergLP::bmqt::CompressionAlgorithmType::print().
|
inline |
Format the specified rhs
to the specified output stream
and return a reference to the modifiable stream
.
References BloombergLP::bmqt::CorrelationId::print().
|
inline |
Return true
if rhs
object contains the value of the same type as contained in lhs
object and the value itself is the same in both objects, return false otherwise.
|
inline |
Return false
if rhs
object contains the value of the same type as contained in lhs
object and the value itself is the same in both objects, return true
otherwise.
|
inline |
Operator used to allow comparison between the specified lhs
and rhs
CorrelationId objects so that CorrelationId can be used as key in a map.
void BloombergLP::bmqt::hashAppend | ( | HASH_ALGORITHM & | hashAlgo, |
const CorrelationId & | value | ||
) |
|
inline |
Format the specified value
to the specified output stream
and return a reference to the modifiable stream
.
|
inline |
Format the specified value
to the specified output stream
and return a reference to the modifiable stream
.
|
inline |
Format the specified value
to the specified output stream
and return a reference to the modifiable stream
.
|
inline |
Write the value of the specified rhs
object to the specified output stream
in a human-readable format, and return a reference to stream
. Note that this human-readable format is not fully specified, and can change without notice. Applications relying on a fixed length format must use toHex
method.
References BloombergLP::bmqt::MessageGUID::print().
|
inline |
Return true
if rhs
object contains the value of the same type as contained in lhs
object and the value itself is the same in both objects, return false otherwise.
|
inline |
Return false
if rhs
object contains the value of the same type as contained in lhs
object and the value itself is the same in both objects, return true
otherwise.
|
inline |
Return true if the specified lhs
instance is smaller than the specified rhs
instance, false otherwise. Note that criteria for comparison is implementation defined, and result of this routine does not in any way signify the order of creation/arrival/delivery of messages to which lhs
and rhs
instances belong. Note that this operator is provided so that MessageGUID can be used as a key in associative containers (map, set, etc).
void BloombergLP::bmqt::hashAppend | ( | HASH_ALGORITHM & | hashAlgo, |
const MessageGUID & | guid | ||
) |
|
inline |
Format the specified value
to the specified output stream
and return a reference to the modifiable stream
.
References BloombergLP::bmqt::PropertyType::print().
|
inline |
Format the specified value
to the specified output stream
and return a reference to the modifiable stream
.
References BloombergLP::bmqt::QueueFlags::print().
|
inline |
Return true
if the specified rhs
object contains the value of the same type as contained in the specified lhs
object and the value itself is the same in both objects, return false otherwise.
References BloombergLP::bmqt::QueueOptions::consumerPriority(), BloombergLP::bmqt::QueueOptions::maxUnconfirmedBytes(), BloombergLP::bmqt::QueueOptions::maxUnconfirmedMessages(), and BloombergLP::bmqt::QueueOptions::suspendsOnBadHostHealth().
|
inline |
Return false
if the specified rhs
object contains the value of the same type as contained in the specified lhs
object and the value itself is the same in both objects, return true
otherwise.
References BloombergLP::bmqt::QueueOptions::consumerPriority(), BloombergLP::bmqt::QueueOptions::maxUnconfirmedBytes(), BloombergLP::bmqt::QueueOptions::maxUnconfirmedMessages(), and BloombergLP::bmqt::QueueOptions::suspendsOnBadHostHealth().
|
inline |
Format the specified rhs
to the specified output stream
and return a reference to the modifiable stream
.
References BloombergLP::bmqt::QueueOptions::print().
|
inline |
Format the specified value
to the specified output stream
and return a reference to the modifiable stream
.
References BloombergLP::bmqt::GenericResult::print().
|
inline |
Format the specified value
to the specified output stream
and return a reference to the modifiable stream
.
References BloombergLP::bmqt::OpenQueueResult::print().
|
inline |
Format the specified value
to the specified output stream
and return a reference to the modifiable stream
.
References BloombergLP::bmqt::ConfigureQueueResult::print().
|
inline |
Format the specified value
to the specified output stream
and return a reference to the modifiable stream
.
References BloombergLP::bmqt::CloseQueueResult::print().
|
inline |
Format the specified value
to the specified output stream
and return a reference to the modifiable stream
.
References BloombergLP::bmqt::EventBuilderResult::print().
|
inline |
Format the specified value
to the specified output stream
and return a reference to the modifiable stream
.
References BloombergLP::bmqt::AckResult::print().
|
inline |
Format the specified value
to the specified output stream
and return a reference to the modifiable stream
.
References BloombergLP::bmqt::PostResult::print().
|
inline |
Format the specified value
to the specified output stream
and return a reference to the modifiable stream
.
|
inline |
Return true
if the specified rhs
object contains the value of the same type as contained in the specified lhs
object and the value itself is the same in both objects, return false otherwise.
References BloombergLP::bmqt::SessionOptions::blobBufferSize(), BloombergLP::bmqt::SessionOptions::brokerUri(), BloombergLP::bmqt::SessionOptions::channelHighWatermark(), BloombergLP::bmqt::SessionOptions::closeQueueTimeout(), BloombergLP::bmqt::SessionOptions::configureQueueTimeout(), BloombergLP::bmqt::SessionOptions::connectTimeout(), BloombergLP::bmqt::SessionOptions::eventQueueHighWatermark(), BloombergLP::bmqt::SessionOptions::eventQueueLowWatermark(), BloombergLP::bmqt::SessionOptions::hostHealthMonitor(), BloombergLP::bmqt::SessionOptions::numProcessingThreads(), BloombergLP::bmqt::SessionOptions::openQueueTimeout(), BloombergLP::bmqt::SessionOptions::statsDumpInterval(), BloombergLP::bmqt::SessionOptions::traceContext(), and BloombergLP::bmqt::SessionOptions::tracer().
|
inline |
Return false
if the specified rhs
object contains the value of the same type as contained in the specified lhs
object and the value itself is the same in both objects, return true
otherwise.
References BloombergLP::bmqt::SessionOptions::blobBufferSize(), BloombergLP::bmqt::SessionOptions::brokerUri(), BloombergLP::bmqt::SessionOptions::channelHighWatermark(), BloombergLP::bmqt::SessionOptions::closeQueueTimeout(), BloombergLP::bmqt::SessionOptions::configureQueueTimeout(), BloombergLP::bmqt::SessionOptions::connectTimeout(), BloombergLP::bmqt::SessionOptions::eventQueueHighWatermark(), BloombergLP::bmqt::SessionOptions::eventQueueLowWatermark(), BloombergLP::bmqt::SessionOptions::hostHealthMonitor(), BloombergLP::bmqt::SessionOptions::numProcessingThreads(), BloombergLP::bmqt::SessionOptions::openQueueTimeout(), BloombergLP::bmqt::SessionOptions::statsDumpInterval(), BloombergLP::bmqt::SessionOptions::traceContext(), and BloombergLP::bmqt::SessionOptions::tracer().
|
inline |
Format the specified rhs
to the specified output stream
and return a reference to the modifiable stream
.
References BloombergLP::bmqt::SessionOptions::print().
|
inline |
Format the specified rhs
to the specified output stream
and return a reference to the modifiable stream
.
References BloombergLP::bmqt::SubscriptionHandle::print().
|
inline |
References BloombergLP::bmqt::Subscription::print().
void BloombergLP::bmqt::hashAppend | ( | HASH_ALGORITHM & | hashAlgo, |
const SubscriptionHandle & | id | ||
) |
|
inline |
|
inline |
|
inline |
Return true
if the specified rhs
object contains the value of the same type as contained in the specified lhs
object and the value itself is the same in both objects, return false otherwise.
References BloombergLP::bmqt::Uri::asString().
Return false
if the specified rhs
object contains the value of the same type as contained in the specified lhs
object and the value itself is the same in both objects, return true
otherwise.
References BloombergLP::bmqt::Uri::asString().
Return true
if the specified lhs
object compares less than the specified rhs
object.
References BloombergLP::bmqt::Uri::asString().
|
inline |
Format the specified rhs
to the specified output stream
and return a reference to the modifiable stream
.
References BloombergLP::bmqt::Uri::print().
void BloombergLP::bmqt::hashAppend | ( | HASH_ALGORITHM & | hashAlgo, |
const Uri & | uri | ||
) |
|
inline |
Format the specified rhs
to the specified output stream
and return a reference to the modifiable stream
.
References BloombergLP::bmqt::Version::print().
Return true
if the object in the specified lhs
represents the same version as the one in the specified rhs
, return false otherwise.
References BloombergLP::bmqt::Version::major(), and BloombergLP::bmqt::Version::minor().
Return true
if the object in the specified lhs
represents a different version than the one in the specified rhs
, return false otherwise.
References BloombergLP::bmqt::Version::major(), and BloombergLP::bmqt::Version::minor().
Return true
if the version represented by the specified lhs
is less than the version represented by the specified rhs
.
References BloombergLP::bmqt::Version::major(), and BloombergLP::bmqt::Version::minor().