Add direct reply to example

Author: cressie176

examples/direct_reply_to_client.js

@@ -0,0 +1,22 @@
+#!/usr/bin/env node
+
+const amqp = require('../');
+
+const queue = 'rpc_queue';
+
+(async () => {
+  const connection = await amqp.connect();
+  const channel = await connection.createChannel();
+
+  await channel.consume('amq.rabbitmq.reply-to', async (message) => {
+    console.log(message.content.toString());
+    await channel.close();
+    await connection.close();
+	}, { noAck: true });
+
+  await channel.assertQueue(queue, { durable: false });
+
+  channel.sendToQueue(queue, Buffer.from(' [X] ping'), {
+    replyTo: 'amq.rabbitmq.reply-to',
+  });
+})();

examples/direct_reply_to_server.js

@@ -0,0 +1,25 @@
+#!/usr/bin/env node
+
+const amqp = require('../');
+const { v4: uuid } = require('uuid');
+
+const queue = 'rpc_queue';
+
+(async () => {
+  const connection = await amqp.connect();
+  const channel = await connection.createChannel();
+
+  process.once('SIGINT', async () => {
+    await channel.close();
+    await connection.close();
+  });
+
+  await channel.assertQueue(queue, { durable: false });
+  await channel.consume(queue, (message) => {
+  	console.log(message.content.toString());
+    channel.sendToQueue(message.properties.replyTo, Buffer.from(' [.] pong'));
+	}, { noAck: true });
+
+  console.log(' [x] To exit press CTRL+C.');
+
+})();