documentation

Signed-off-by: Gabriele Santomaggio <[email protected]>

Author: Gsantomaggio

docs/examples/README.md

@@ -9,4 +9,5 @@
 - [Video](video) - From the YouTube tutorial [AMQP 1.0 with Golang](https://youtu.be/iR1JUFh3udI)
 - [TLS](tls) - An example of how to use TLS with the AMQP 1.0 client.
 - [Advanced Settings](advanced_settings) - An example of how to use the advanced connection settings of the AMQP 1.0 client.
-- [Broadcast](broadcast) - An example of how to use fanout to broadcast messages to multiple auto-deleted queues.
+- [Broadcast](broadcast) - An example of how to use fanout to broadcast messages to multiple auto-deleted queues.
+- [RPC Echo](rpc_echo_server) - An example of how to implement RPC with the AMQP 1.0 client.

docs/examples/rpc_echo_server/main.go

@@ -22,9 +22,12 @@ func (s *echoRpcServer) stop(ctx context.Context) {
 }
 
 func newEchoRpcServer(conn *rabbitmqamqp.AmqpConnection) *echoRpcServer {
-	conn.Management().DeclareQueue(context.TODO(), &rabbitmqamqp.QuorumQueueSpecification{
+	_, err := conn.Management().DeclareQueue(context.TODO(), &rabbitmqamqp.QuorumQueueSpecification{
 		Name: rpcServerQueueName,
 	})
+	if err != nil {
+		panic(err)
+	}
 	srv, err := conn.NewRpcServer(context.TODO(), rabbitmqamqp.RpcServerOptions{
 		RequestQueue: rpcServerQueueName,
 		Handler: func(ctx context.Context, request *amqp.Message) (*amqp.Message, error) {