| | |
| | | static bool Send(SharedMemory &shm, const MQId &remote_id, const MsgI &msg, const int timeout_ms, OnSend const &onsend); |
| | | static bool Send(SharedMemory &shm, const MQId &remote_id, const MsgI &msg, const int timeout_ms); |
| | | |
| | | template <class... Extra> |
| | | bool Send(const MQId &remote_id, const MsgI &msg, const int timeout_ms, Extra const &...extra) |
| | | { |
| | | return Send(shm(), remote_id, msg, timeout_ms, extra...); |
| | | } |
| | | template <class Body, class... Extra> |
| | | bool Send(const MQId &remote_id, const BHMsgHead &head, const Body &body, const int timeout_ms, Extra const &...extra) |
| | | { |
| | | MsgI msg; |
| | | if (msg.Make(shm(), head, body)) { |
| | | if (Send(shm(), remote_id, msg, timeout_ms, extra...)) { |
| | | return true; |
| | | } else { |
| | | msg.Release(shm()); |
| | | } |
| | | } |
| | | return false; |
| | | } |
| | | |
| | | template <class... Rest> |
| | | bool Send(const MQId &remote_id, Rest const &...rest) { return Send(shm(), remote_id, rest...); } |
| | | size_t Pending() const { return data()->size(); } |
| | | }; |
| | | |