Inheritance diagram for BloombergLP::rmqa::ConnectionMonitor:
Collaboration diagram for BloombergLP::rmqa::ConnectionMonitor:
Classes | |
| struct | AliveConnectionInfo |
Public Types | |
| typedef bsl::function< void(const rmqamqp::MessageStore< rmqt::Message >::Entry &)> | HungMessageCallback |
Public Member Functions | |
| ConnectionMonitor (const bsls::TimeInterval &messageProcessingTimeout, const HungMessageCallback &callback=HungMessageCallback()) | |
| void | addConnection (const bsl::weak_ptr< rmqamqp::ChannelContainer > &connection) BSLS_KEYWORD_OVERRIDE |
| void | run () BSLS_KEYWORD_OVERRIDE |
| bsl::shared_ptr< AliveConnectionInfo > | fetchAliveConnectionInfo () |
Member Function Documentation
◆ fetchAliveConnectionInfo()
| bsl::shared_ptr< ConnectionMonitor::AliveConnectionInfo > BloombergLP::rmqa::ConnectionMonitor::fetchAliveConnectionInfo | ( | ) |
Fetch information about every connection which we have valid weak_ptr. This is useful for debugging leaked connection handles.
The documentation for this class was generated from the following files:
- src/rmq/rmqa/rmqa_connectionmonitor.h
- src/rmq/rmqa/rmqa_connectionmonitor.cpp
