This is the complete list of members for BusSession, including all inherited members.
| breakConnection() | Session | |
| breakConnectionAsync() | Session | |
| BusSession(const SessionSettings &settings, SessionListener *listener, SessionStorageType::Enum storageType=SessionStorageType::FileBased, SessionStorage *storage=nullptr, const std::string &customKey={}, const Utils::BuildInfo &=Utils::consumerBuildInfo()) | BusSession | inline |
| BusSession(SessionReactor &stack, const SessionSettings &settings, SessionListener *listener, SessionStorageType::Enum storageType=SessionStorageType::FileBased, SessionStorage *storage=nullptr, const std::string &customKey={}, const Utils::BuildInfo &=Utils::consumerBuildInfo()) | BusSession | inline |
| BusSession(ServiceFactory &service, const SessionSettings &settings, SessionListener *listener, SessionStorageType::Enum storageType=SessionStorageType::FileBased, SessionStorage *storage=nullptr, const std::string &customKey={}, const Utils::BuildInfo &=Utils::consumerBuildInfo()) | BusSession | inline |
| clientId() const noexcept | Session | |
| connect(const std::string &host, Port port) | BusSession | |
| OnixS::ICE::BOE::Session::connect(const std::string &host, Port port, const std::string &ipSessionToken={}) | Session | |
| connectAsync(const std::string &host, Port port) | BusSession | |
| OnixS::ICE::BOE::Session::connectAsync(const std::string &host, Port port, const std::string &ipSessionToken={}) | Session | |
| creationTime() const noexcept | Session | |
| customKey() const | Session | |
| disconnect(const std::string &reason={}) | Session | |
| disconnectAsync(const std::string &reason={}) | Session | |
| flushSessionStorage() | Session | |
| getBgwCredentialsAsync(const std::string &userId, bool forceRequest=0) final | BusSession | virtual |
| getTcpInfo(TcpInfo &) | Session | |
| id() const | Session | |
| incomingMessageGapQueueMaximumSize() const | Session | |
| incomingMessageGapQueueMaximumSize(size_t value) | Session | |
| inSeqNum() const | Session | |
| inSeqNum(SeqNumber nextExpectedInSeqNum) | Session | |
| InvalidSocketHandle | Session | static |
| licenseExpirationDate() const | Session | |
| localNetworkInterface() const | Session | |
| localNetworkInterface(const std::string &value) | Session | |
| localPort() const | Session | |
| localPortRange() const noexcept | Session | |
| localPortRange(std::pair< Port, Port > portRange) | Session | |
| localTimeUsage() const | Session | |
| localTimeUsage(bool useLocalTime) | Session | |
| log(const std::string &message) const | Session | |
| logBeforeSending() const | Session | |
| logBeforeSending(bool value) | Session | |
| MaxPacketSize | Session | static |
| messageGrouping() const noexcept | Session | |
| messageGrouping(unsigned numberOfMessagesToGroup) | Session | |
| messagingVersion() const noexcept | Session | |
| outboundQueueBytes() | Session | |
| outSeqNum() const noexcept | Session | |
| outSeqNum(SeqNumber nextOutSeqNum) | Session | |
| receiveSpinningTimeout() const noexcept | Session | |
| receiveSpinningTimeout(unsigned timeoutInUs) | Session | |
| receivingThreadAffinity(CpuIndex cpuIndex) | Session | |
| receivingThreadAffinity(const CpuIndexes &cpuIndexes) | Session | |
| receivingThreadAffinity() const | Session | |
| receivingThreadPolicy() const | Session | |
| receivingThreadPolicy(int policy) | Session | |
| receivingThreadPriority() const | Session | |
| receivingThreadPriority(int priority) | Session | |
| reconnectAttempts() const | Session | |
| reconnectAttempts(unsigned reconnectAttempts) | Session | |
| reconnectInterval() const | Session | |
| reconnectInterval(unsigned seconds) | Session | |
| remoteHost() const | Session | |
| remoteIpAddress() const | Session | |
| remotePort() const | Session | |
| reportNewMessagesWhileWaitingForMissedMessages() const | Session | |
| reportNewMessagesWhileWaitingForMissedMessages(bool value) | Session | |
| reset() | Session | |
| send(Messaging::MessageHolder< SbeMessageType, MaxMessageSize, MessageInitializer > &msg, Messaging::Timestamp sendingTime=UtcWatch::now()) | Session | |
| send(Messaging::MessageHolder< SbeMessageType, MaxMessageSize, MessageInitializer > &&msg, Messaging::Timestamp sendingTime=UtcWatch::now()) | Session | |
| send(MessageBatch< SbeMessageType, MaxMessageSize, MessageInitializer > &msgs, Messaging::Timestamp sendingTime=UtcWatch::now(), size_t maxPacketSize=MaxPacketSize) | Session | |
| send(MessageBatchCombiner &msgs, Messaging::Timestamp sendingTime=UtcWatch::now(), size_t maxPacketSize=MaxPacketSize) | Session | |
| send(NetworkMessage *begin, NetworkMessage *end, Messaging::Timestamp sendingTime=UtcWatch::now(), size_t maxPacketSize=MaxPacketSize) ONIXS_ICEBOE_NONULL | Session | |
| send(NetMessagesRange range, Messaging::Timestamp sendingTime=UtcWatch::now(), size_t maxPacketSize=MaxPacketSize) | Session | |
| sendingThreadAffinity(CpuIndex cpuIndex) | Session | |
| sendingThreadAffinity(const CpuIndexes &cpuIndexes) | Session | |
| sendingThreadAffinity() const | Session | |
| sendingThreadPolicy() const | Session | |
| sendingThreadPolicy(int policy) | Session | |
| sendingThreadPriority() const | Session | |
| sendingThreadPriority(int priority) | Session | |
| sendSequenceMessage() | Session | |
| sendSpinningTimeout() const noexcept | Session | |
| sendSpinningTimeout(unsigned timeoutInUs) | Session | |
| Session(SessionType::Enum sessionType, const SessionSettings &settings, SessionListener *listener, SessionStorageType::Enum storageType=SessionStorageType::FileBased, SessionStorage *storage=nullptr, const std::string &customKey={}, const Utils::BuildInfo &=Utils::consumerBuildInfo()) | Session | |
| Session(SessionReactor &stack, SessionType::Enum sessionType, const SessionSettings &settings, SessionListener *listener, SessionStorageType::Enum storageType=SessionStorageType::FileBased, SessionStorage *storage=nullptr, const std::string &customKey={}, const Utils::BuildInfo &=Utils::consumerBuildInfo()) | Session | |
| Session(ServiceFactory &service, SessionType::Enum sessionType, const SessionSettings &settings, SessionListener *listener, SessionStorageType::Enum storageType=SessionStorageType::FileBased, SessionStorage *storage=nullptr, const std::string &customKey={}, const Utils::BuildInfo &=Utils::consumerBuildInfo()) | Session | |
| socketHandle() | Session | |
| socketOptions() const | Session | |
| socketOptions(const SocketOptions &options) | Session | |
| state() const | Session | |
| storageDirectory() const | Session | |
| storageId() const noexcept | Session | |
| storageType() const noexcept | Session | |
| tcpNoDelayOption() const | Session | |
| tcpNoDelayOption(bool value) | Session | |
| throttle() | Session | |
| throttlingLimit(size_t messagesCount, size_t intervalInMs=1000) | Session | |
| toString() const | Session | |
| tryThrottle() | Session | |
| UndefinedAffinity | Session | static |
| userId() const noexcept | Session | |
| version() noexcept | Session | static |
| warmUp(Messaging::MessageHolder< SbeMessageType, MaxMessageSize > &msg, Messaging::Timestamp sendingTime=UtcWatch::now(), int warmupFlags=0) | Session | |
| warmUp(MessageBatch< SbeMessageType, MaxMessageSize, MessageInitializer > &msgs, Messaging::Timestamp sendingTime=UtcWatch::now(), size_t maxPacketSize=MaxPacketSize, int warmupFlags=0) | Session | |
| warmUp(MessageBatchCombiner &msgs, Messaging::Timestamp sendingTime=UtcWatch::now(), size_t maxPacketSize=MaxPacketSize, int warmupFlags=0) | Session | |
| warmUp(NetworkMessage *begin, NetworkMessage *end, Messaging::Timestamp sendingTime=UtcWatch::now(), size_t maxPacketSize=MaxPacketSize, int warmupFlags=0) ONIXS_ICEBOE_NONULL | Session | |
| warmUp(NetMessagesRange range, Messaging::Timestamp sendingTime=UtcWatch::now(), size_t maxPacketSize=MaxPacketSize, int warmupFlags=0) | Session | |
| ~IBgwCredentialsProvider()=default | IBgwCredentialsProvider | virtual |
| ~Session() | Session |
