Exception raised if a sender or receiver is closed when trying to send/receive
| 63 | |
| 64 | // Exception raised if a sender or receiver is closed when trying to send/receive |
| 65 | class closed : public std::runtime_error { |
| 66 | public: |
| 67 | closed(const std::string& msg) : std::runtime_error(msg) {} |
| 68 | }; |
| 69 | |
| 70 | // A thread-safe sending connection that blocks sending threads when there |
| 71 | // is no AMQP credit to send messages. |