AMPS C/C++ Client Class Reference
AMPS C/C++ Client Version 5.3.4.3
AMPS::HAClient Member List

This is the complete list of members for AMPS::HAClient, including all inherited members.

ack(Field &topic_, Field &bookmark_, const char *options_=NULL)AMPS::Clientinline
ack(Message &message_, const char *options_=NULL)AMPS::Clientinline
ack(const std::string &topic_, const std::string &bookmark_, const char *options_=NULL)AMPS::Clientinline
addConnectionStateListener(ConnectionStateListener *listener)AMPS::Clientinline
addMessageHandler(const Field &commandId_, const AMPS::MessageHandler &messageHandler_, unsigned requestedAcks_, bool isSubscribe_)AMPS::Clientinline
addMessageHandler(const Field &commandId_, const AMPS::MessageHandler &messageHandler_, unsigned requestedAcks_, Message::Command::Type commandType_)AMPS::Clientinline
BOOKMARK_EPOCH()AMPS::Clientinlinestatic
BOOKMARK_MOST_RECENT()AMPS::Clientinlinestatic
BOOKMARK_NOW()AMPS::Clientinlinestatic
BOOKMARK_RECENT()AMPS::Clientinlinestatic
bookmarkSubscribe(const MessageHandler &messageHandler_, const std::string &topic_, long timeout_, const std::string &bookmark_, const std::string &filter_="", const std::string &options_="", const std::string &subId_="")AMPS::Clientinline
bookmarkSubscribe(const std::string &topic_, long timeout_, const std::string &bookmark_, const std::string &filter_="", const std::string &options_="", const std::string &subId_="")AMPS::Clientinline
bookmarkSubscribe(const char *topic_, long timeout_, const std::string &bookmark_, const std::string &filter_="", const std::string &options_="", const std::string &subId_="")AMPS::Clientinline
clearConnectionStateListeners()AMPS::Clientinline
Client(const std::string &clientName="")AMPS::Clientinline
connect(const std::string &uri)AMPS::Clientinline
connectAndLogon()AMPS::HAClientinline
convertVersionToNumber(const std::string &version_)AMPS::Clientinlinestatic
convertVersionToNumber(const char *data_, size_t len_)AMPS::Clientinlinestatic
createFileBacked(const std::string &name_, const std::string &publishLogName_, const std::string &subscribeLogName_)AMPS::HAClientinlinestatic
createMemoryBacked(const std::string &name_)AMPS::HAClientinlinestatic
deltaPublish(const std::string &topic_, const std::string &data_)AMPS::Clientinline
deltaPublish(const char *topic_, size_t topicLength_, const char *data_, size_t dataLength_)AMPS::Clientinline
deltaPublish(const std::string &topic_, const std::string &data_, unsigned long expiration_)AMPS::Clientinline
deltaPublish(const char *topic_, size_t topicLength_, const char *data_, size_t dataLength_, unsigned long expiration_)AMPS::Clientinline
deltaSubscribe(const MessageHandler &messageHandler_, const std::string &topic_, long timeout_, const std::string &filter_="", const std::string &options_="", const std::string &subId_="")AMPS::Clientinline
deltaSubscribe(const std::string &topic_, long timeout_, const std::string &filter_="", const std::string &options_="", const std::string &subId_="")AMPS::Clientinline
deltaSubscribe(const char *topic_, long timeout_, const std::string &filter_="", const std::string &options_="", const std::string &subId_="")AMPS::Clientinline
disconnect()AMPS::Clientinline
disconnected() const AMPS::HAClientinline
EPOCH()AMPS::Clientinlinestatic
execute(Command &command_)AMPS::Clientinline
executeAsync(Command &command_, MessageHandler handler_)AMPS::Clientinline
executeAsyncNoResubscribe(Command &command_, MessageHandler handler_)AMPS::Clientinline
flushAcks(void)AMPS::Clientinline
gatherConnectionInfo() const AMPS::HAClientinline
getAckBatchSize(void) const AMPS::Clientinline
getAckTimeout(void) const AMPS::Clientinline
getAutoAck(void) const AMPS::Clientinline
getBookmarkStore()AMPS::Clientinline
getConnectionInfo() const AMPS::HAClientinlinevirtual
getDefaultMaxDepth(void) const AMPS::Clientinline
getDisconnectHandler(void) const AMPS::Clientinline
getDuplicateMessageHandler(void)AMPS::Clientinline
getExceptionListener(void) const AMPS::Clientinline
getFailedWriteHandler()AMPS::Clientinline
getHandle()AMPS::Clientinline
getLogonCorrelationData() const AMPS::Clientinline
getLogonOptions(void) const AMPS::HAClientinline
getName() const AMPS::Clientinline
getNameHash() const AMPS::Clientinline
getNameHashValue() const AMPS::Clientinline
getPublishStore()AMPS::Clientinline
getReconnectDelay() const AMPS::HAClientinline
getReconnectDelayStrategy(void) const AMPS::HAClientinline
getRetryOnDisconnect(void) const AMPS::Clientinline
getServerChooser() const AMPS::HAClientinline
getServerVersion() const AMPS::Clientinline
getServerVersionInfo() const AMPS::Clientinline
getSubscriptionManager()AMPS::Clientinline
getTimeout() const AMPS::HAClientinline
getURI() const AMPS::Clientinline
HAClient()AMPS::HAClientinline
HAClient(const std::string &name_)AMPS::HAClientinline
HAClient(HAClientImpl *body_)AMPS::HAClientinline
HAClient(const HAClient &rhs)AMPS::HAClientinline
logon(int timeout_=0, Authenticator &authenticator_=DefaultAuthenticator::instance(), const char *options_=NULL)AMPS::Clientinline
logon(const char *options_, int timeout_=0)AMPS::Clientinline
logon(const std::string &options_, int timeout_=0)AMPS::Clientinline
MOST_RECENT()AMPS::Clientinlinestatic
NOW()AMPS::Clientinlinestatic
operator=(const HAClient &rhs)AMPS::HAClientinline
publish(const std::string &topic_, const std::string &data_)AMPS::Clientinline
publish(const char *topic_, size_t topicLength_, const char *data_, size_t dataLength_)AMPS::Clientinline
publish(const std::string &topic_, const std::string &data_, unsigned long expiration_)AMPS::Clientinline
publish(const char *topic_, size_t topicLength_, const char *data_, size_t dataLength_, unsigned long expiration_)AMPS::Clientinline
publishFlush(long timeout_=0, unsigned ackType_=Message::AckType::Processed)AMPS::Clientinline
removeConnectionStateListener(ConnectionStateListener *listener)AMPS::Clientinline
removeMessageHandler(const Field &commandId_)AMPS::Clientinline
send(const Message &message)AMPS::Clientinline
send(const MessageHandler &messageHandler, Message &message, int timeout=0)AMPS::Clientinline
setAckBatchSize(const unsigned ackBatchSize_)AMPS::Clientinline
setAckTimeout(const int ackTimeout_)AMPS::Clientinline
setAutoAck(bool isAutoAckEnabled_)AMPS::Clientinline
setBookmarkStore(const BookmarkStore &bookmarkStore_)AMPS::Clientinline
setDefaultMaxDepth(unsigned maxDepth_)AMPS::Clientinline
setDisconnectHandler(const DisconnectHandler &disconnectHandler)AMPS::Clientinline
setDuplicateMessageHandler(const MessageHandler &duplicateMessageHandler_)AMPS::Clientinline
setExceptionListener(const std::shared_ptr< const ExceptionListener > &pListener_)AMPS::Clientinline
setExceptionListener(const ExceptionListener &listener_)AMPS::Clientinline
setFailedWriteHandler(FailedWriteHandler *handler_)AMPS::Clientinline
setGlobalCommandTypeMessageHandler(const std::string &command_, const MessageHandler &handler_)AMPS::Clientinline
setGlobalCommandTypeMessageHandler(const Message::Command::Type command_, const MessageHandler &handler_)AMPS::Clientinline
setHeartbeat(unsigned heartbeatTime_, unsigned readTimeout_)AMPS::Clientinline
setHeartbeat(unsigned heartbeatTime_)AMPS::Clientinline
setLastChanceMessageHandler(const AMPS::MessageHandler &messageHandler)AMPS::Clientinline
setLogonCorrelationData(const std::string &logonCorrelationData_)AMPS::Clientinline
setLogonOptions(const char *logonOptions_)AMPS::HAClientinline
setLogonOptions(const std::string &logonOptions_)AMPS::HAClientinline
setName(const std::string &name)AMPS::Clientinline
setPublishStore(const Store &publishStore_)AMPS::Clientinline
setReconnectDelay(int reconnectDelay_)AMPS::HAClientinline
setReconnectDelayStrategy(const ReconnectDelayStrategy &strategy_)AMPS::HAClientinline
setRetryOnDisconnect(bool isRetryOnDisconnect_)AMPS::Clientinline
setServerChooser(const ServerChooser &serverChooser_)AMPS::HAClientinline
setSubscriptionManager(SubscriptionManager *subscriptionManager_)AMPS::Clientinline
setThreadCreatedCallback(amps_thread_created_callback callback_, void *userData_)AMPS::Clientinline
setTimeout(int timeout_)AMPS::HAClientinline
setTransportFilterFunction(amps_transport_filter_function filter_, void *userData_)AMPS::Clientinline
setUnhandledMessageHandler(const AMPS::MessageHandler &messageHandler)AMPS::Clientinline
sow(const MessageHandler &messageHandler_, const std::string &topic_, const std::string &filter_="", const std::string &orderBy_="", const std::string &bookmark_="", int batchSize_=DEFAULT_BATCH_SIZE, int topN_=DEFAULT_TOP_N, const std::string &options_="", long timeout_=DEFAULT_COMMAND_TIMEOUT)AMPS::Clientinline
sow(const std::string &topic_, const std::string &filter_="", const std::string &orderBy_="", const std::string &bookmark_="", int batchSize_=DEFAULT_BATCH_SIZE, int topN_=DEFAULT_TOP_N, const std::string &options_="", long timeout_=DEFAULT_COMMAND_TIMEOUT)AMPS::Clientinline
sow(const char *topic_, const std::string &filter_="", const std::string &orderBy_="", const std::string &bookmark_="", int batchSize_=DEFAULT_BATCH_SIZE, int topN_=DEFAULT_TOP_N, const std::string &options_="", long timeout_=DEFAULT_COMMAND_TIMEOUT)AMPS::Clientinline
sow(const MessageHandler &messageHandler_, const std::string &topic_, long timeout_, const std::string &filter_="", int batchSize_=DEFAULT_BATCH_SIZE, int topN_=DEFAULT_TOP_N)AMPS::Clientinline
sowAndDeltaSubscribe(const MessageHandler &messageHandler_, const std::string &topic_, const std::string &filter_="", const std::string &orderBy_="", int batchSize_=DEFAULT_BATCH_SIZE, int topN_=DEFAULT_TOP_N, const std::string &options_="", long timeout_=DEFAULT_COMMAND_TIMEOUT)AMPS::Clientinline
sowAndDeltaSubscribe(const std::string &topic_, const std::string &filter_="", const std::string &orderBy_="", int batchSize_=DEFAULT_BATCH_SIZE, int topN_=DEFAULT_TOP_N, const std::string &options_="", long timeout_=DEFAULT_COMMAND_TIMEOUT)AMPS::Clientinline
sowAndDeltaSubscribe(const char *topic_, const std::string &filter_="", const std::string &orderBy_="", int batchSize_=DEFAULT_BATCH_SIZE, int topN_=DEFAULT_TOP_N, const std::string &options_="", long timeout_=DEFAULT_COMMAND_TIMEOUT)AMPS::Clientinline
sowAndDeltaSubscribe(const MessageHandler &messageHandler_, const std::string &topic_, long timeout_, const std::string &filter_="", int batchSize_=DEFAULT_BATCH_SIZE, bool oofEnabled_=false, bool sendEmpties_=false, int topN_=DEFAULT_TOP_N)AMPS::Clientinline
sowAndDeltaSubscribe(const std::string &topic_, long timeout_, const std::string &filter_="", int batchSize_=DEFAULT_BATCH_SIZE, bool oofEnabled_=false, bool sendEmpties_=false, int topN_=DEFAULT_TOP_N)AMPS::Clientinline
sowAndDeltaSubscribe(const char *topic_, long timeout_, const std::string &filter_="", int batchSize_=DEFAULT_BATCH_SIZE, bool oofEnabled_=false, bool sendEmpties_=false, int topN_=DEFAULT_TOP_N)AMPS::Clientinline
sowAndSubscribe(const MessageHandler &messageHandler_, const std::string &topic_, long timeout_, const std::string &filter_="", int batchSize_=DEFAULT_BATCH_SIZE, bool oofEnabled_=false, int topN_=DEFAULT_TOP_N)AMPS::Clientinline
sowAndSubscribe(const std::string &topic_, long timeout_, const std::string &filter_="", int batchSize_=DEFAULT_BATCH_SIZE, bool oofEnabled_=false, int topN_=DEFAULT_TOP_N)AMPS::Clientinline
sowAndSubscribe(const char *topic_, long timeout_, const std::string &filter_="", int batchSize_=DEFAULT_BATCH_SIZE, bool oofEnabled_=false, int topN_=DEFAULT_TOP_N)AMPS::Clientinline
sowAndSubscribe(const MessageHandler &messageHandler_, const std::string &topic_, const std::string &filter_="", const std::string &orderBy_="", const std::string &bookmark_="", int batchSize_=DEFAULT_BATCH_SIZE, int topN_=DEFAULT_TOP_N, const std::string &options_="", long timeout_=DEFAULT_COMMAND_TIMEOUT)AMPS::Clientinline
sowAndSubscribe(const std::string &topic_, const std::string &filter_="", const std::string &orderBy_="", const std::string &bookmark_="", int batchSize_=DEFAULT_BATCH_SIZE, int topN_=DEFAULT_TOP_N, const std::string &options_="", long timeout_=DEFAULT_COMMAND_TIMEOUT)AMPS::Clientinline
sowAndSubscribe(const char *topic_, const std::string &filter_="", const std::string &orderBy_="", const std::string &bookmark_="", int batchSize_=DEFAULT_BATCH_SIZE, int topN_=DEFAULT_TOP_N, const std::string &options_="", long timeout_=DEFAULT_COMMAND_TIMEOUT)AMPS::Clientinline
sowDelete(const MessageHandler &messageHandler, const std::string &topic, const std::string &filter, long timeout)AMPS::Clientinline
sowDelete(const std::string &topic, const std::string &filter, long timeout=0)AMPS::Clientinline
sowDeleteByData(const MessageHandler &messageHandler_, const std::string &topic_, const std::string &data_, long timeout_=0)AMPS::Clientinline
sowDeleteByData(const std::string &topic_, const std::string &data_, long timeout_=0)AMPS::Clientinline
sowDeleteByKeys(const MessageHandler &messageHandler_, const std::string &topic_, const std::string &keys_, long timeout_=0)AMPS::Clientinline
sowDeleteByKeys(const std::string &topic_, const std::string &keys_, long timeout_=0)AMPS::Clientinline
startTimer()AMPS::Clientinline
stopTimer(const MessageHandler &messageHandler)AMPS::Clientinline
subscribe(const MessageHandler &messageHandler_, const std::string &topic_, long timeout_=0, const std::string &filter_="", const std::string &options_="", const std::string &subId_="")AMPS::Clientinline
subscribe(const std::string &topic_, long timeout_=0, const std::string &filter_="", const std::string &options_="", const std::string &subId_="")AMPS::Clientinline
subscribe(const char *topic_, long timeout_=0, const std::string &filter_="", const std::string &options_="", const std::string &subId_="")AMPS::Clientinline
unsubscribe(const std::string &commandId)AMPS::Clientinline
unsubscribe()AMPS::Clientinline