此内容没有您所选择的语言版本。
Chapter 8. Message delivery
8.1. Sending messages
To send a message, create a connection, session, and sender link, then call the Sender.Send()
method with a Message
object.
Example: Sending messages
Connection connection = new Connection(new Address("amqp://example.com")); Session session = new Session(connection); SenderLink sender = new SenderLink(session, "sender-1", "jobs"); Message message = new Message("job-content"); sender.Send(message);
For more information, see the Send.cs example.
8.2. Receiving messages
To receive a message, create a connection, session, and receiver link, then call the Receiver.Receive()
method and use the returned Message
object.
Example: Receiving messages
Connection connection = new Connection(new Address("amqp://example.com")); Session session = new Session(connection); ReceiverLink receiver = new ReceiverLink(session, "receiver-1", "jobs"); Message message = receiver.Receive(); receiver.Accept(message);
The Receiver.Accept()
call tells the remote peer that the message was received and processed.
For more information, see the Receive.cs example.