第 9 章 消息交付
9.1. 发送消息 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
若要发送消息,可覆盖 on_sendable 事件处理程序,并调用 sender::send () 方法。当 proton::sender 有足够信的信用来发送至少一条消息时,可 发送的事件将触发。
示例:发送消息
struct example_handler : public proton::messaging_handler {
void on_container_start(proton::container& cont) override {
proton::connection conn = cont.connect("amqp://example.com");
conn.open_sender("jobs");
}
void on_sendable(proton::sender& snd) override {
proton::message msg {"job-1"};
snd.send(msg);
}
};