DelegateMQ
Loading...
Searching...
No Matches
Class List
Here are the classes, structs, unions and interfaces with brief descriptions:
[detail level 123]
 NdmqThe delegate library namespace
 Nserialize_traits
 CAllocator
 CAllocatorPool
 CDispatcherDispatcher sends data to the transport for transmission to the endpoint
 CDmqHeaderHeader for remote delegate messages. Handles endinesses byte swaps as necessary.
 CIMqttReceiveHandler
 CITransportDelegateMQ transport interface
 CITransportMonitorDelegateMQ transport monitor interface
 CMqttTransportMQTT transport example
 CNngTransportNNG transport class. NNG socket instances must only be called by a single thread of control. Each transport instance has its own internal thread of control and all transport APIs are asynchronous. Each instance is an "active object" with a private internal thread of control and async public APIs
 CserializeBinary serializes and deserializes C++ objects
 CSerializer
 CSerializer< RetType(Args...)>
 Cstl_allocator
 Cstl_allocator< void >
 CThreadCross-platform thread for any system supporting C++11 std::thread (e.g. Windows, Linux)
 CThreadMsgA class to hold a platform-specific thread messsage that will be passed through the OS message queue.
 CThreadMsgComparator
 CTimerA timer class provides periodic timer callbacks on the client's thread of control. Timer is thread safe
 CTransportMonitorMonitors remote delegate send message timeouts. Class is thread safe. Call TransportMonitor::Process() periodically for timeout handling. Depending on the transport implementation, the message might still be delivered event if the monitor SendStatusCb callback is invoked. A timeout expiring just means that an ack was not received within the time specified
 CUdpTransportWin32 UDP transport example
 CWin32PipeTransportWin32 data pipe transport example
 CZeroMqTransportZeroMQ transport class. ZeroMQ socket instances must only be called by a single thread of control. Each transport instance has its own internal thread of control and all transport APIs are asynchronous. Each instances is an "active object" with a private internal thread of control and async public APIs