Chapter 8. Message delivery
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 .
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); 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);