Add code samples for website documentation

References rabbitmq/rabbitmq-server#2059

Author: acogoluegnes

src/test/java/com/rabbitmq/client/amqp/docs/WebsiteDocumentation.java

@@ -0,0 +1,231 @@
+package com.rabbitmq.client.amqp.docs;
+
+import com.rabbitmq.client.amqp.*;
+import com.rabbitmq.client.amqp.impl.AmqpEnvironmentBuilder;
+
+import java.nio.charset.StandardCharsets;
+import java.time.Duration;
+
+public class WebsiteDocumentation {
+
+  void environment() {
+    Environment environment = new AmqpEnvironmentBuilder()
+        .build();
+    // ...
+    // close the environment when the application stops
+    environment.close();
+  }
+
+  void connection() {
+    Environment environment = null;
+
+    // open a connection from the environment
+    Connection connection = environment.connectionBuilder()
+        .uri("amqp://admin:admin@localhost:5672/%2f")
+        .build();
+    // ...
+    // close the connection when it is no longer necessary
+    connection.close();
+  }
+
+  void publishing() {
+    Connection connection = null;
+
+    Publisher publisher = connection.publisherBuilder()
+        .exchange("foo").key("bar")
+        .build();
+    // ...
+    // close the publisher when it is no longer necessary
+    publisher.close();
+
+    // create the message
+    Message message = publisher
+        .message("hello".getBytes(StandardCharsets.UTF_8))
+        .messageId(1L);
+
+    // publish the message and deal with broker feedback
+    publisher.publish(message, context -> {
+      // the broker confirmation
+      if (context.status() == Publisher.Status.ACCEPTED) {
+        // the broker accepted (confirmed) the message
+      } else {
+        // deal with possible failure
+      }
+    });
+  }
+
+  void publisherAddressFormat() {
+    Connection connection = null;
+
+    // publish to an exchange with a routing key
+    Publisher publisher1 = connection.publisherBuilder()
+        .exchange("foo").key("bar") // /exchanges/foo/bar
+        .build();
+
+    // publish to an exchange without a routing key
+    Publisher publisher2 = connection.publisherBuilder()
+        .exchange("foo") // /exchanges/foo
+        .build();
+
+    // publish to a queue
+    Publisher publisher3 = connection.publisherBuilder()
+        .queue("some-queue") // /queues/some-queue
+        .build();
+  }
+
+  void publishAddressFormatInMessages() {
+    Connection connection = null;
+
+    // no target defined on publisher creation
+    Publisher publisher = connection.publisherBuilder()
+        .build();
+
+    // publish to an exchange with a routing key
+    Message message1 = publisher.message()
+        .toAddress().exchange("foo").key("bar")
+        .message();
+
+    // publish to an exchange without a routing key
+    Message message2 = publisher.message()
+        .toAddress().exchange("foo")
+        .message();
+
+    // publish to a queue
+    Message message3 = publisher.message()
+        .toAddress().queue("my-queue")
+        .message();
+  }
+
+  void consuming() {
+    Connection connection = null;
+    Consumer consumer = connection.consumerBuilder()
+        .queue("some-queue")
+        .messageHandler((context, message) -> {
+          byte[] body = message.body();
+          // ...
+          context.accept(); // settle the message
+        })
+        .build(); // do not forget to build the instance!
+
+    // pause the delivery of messages
+    consumer.pause();
+    // ensure the number of unsettled messages reaches 0
+    long unsettledMessageCount = consumer.unsettledMessageCount();
+    // close the consumer
+    consumer.close();
+
+  }
+
+  void consumingSupportForStreams() {
+    Connection connection = null;
+
+    Consumer consumer = connection.consumerBuilder()
+        .queue("some-stream")
+        .stream()
+            .offset(ConsumerBuilder.StreamOffsetSpecification.FIRST)
+        .builder()
+        .messageHandler((context, message) -> {
+          // message processing
+        })
+        .build();
+  }
+
+  void consumingStreamFiltering() {
+    Connection connection = null;
+
+    Consumer consumer = connection.consumerBuilder()
+        .queue("some-stream")
+        .stream()
+        .filterValues("invoices", "orders")
+        .filterMatchUnfiltered(true)
+        .builder()
+        .messageHandler((context, message) -> {
+          // message processing
+        })
+        .build();
+
+  }
+
+  void management() {
+    Connection connection = null;
+
+    Management management = connection.management();
+    // ...
+    // close the management instance when it is no longer needed
+    management.close();
+  }
+
+  void managementExchange() {
+    Management management = null;
+
+    management.exchange()
+        .name("my-exchange")
+        .type(Management.ExchangeType.FANOUT) // enum for built-in type
+        .declare();
+
+    management.exchange()
+        .name("my-exchange")
+        .type("x-delayed-message") // non-built-in type
+        .autoDelete(false)
+        .argument("x-delayed-type", "direct")
+        .declare();
+
+    management.exchangeDeletion().delete("my-exchange");
+  }
+
+  void managementQueues() {
+    Management management = null;
+
+    management.queue()
+        .name("my-queue")
+        .exclusive(true)
+        .autoDelete(false)
+        .declare();
+
+    management
+        .queue()
+        .name("my-queue")
+        .type(Management.QueueType.CLASSIC)
+        .messageTtl(Duration.ofMinutes(10))
+        .maxLengthBytes(ByteCapacity.MB(100))
+        .declare();
+
+    management
+        .queue()
+        .name("my-quorum-queue")
+        .quorum() // set queue type to 'quorum'
+          .quorumInitialGroupSize(3) // specific to quorum queues
+          .deliveryLimit(3) // specific to quorum queues
+        .queue()
+        .declare();
+
+    Management.QueueInfo info = management.queueInfo("my-queue");
+    long messageCount = info.messageCount();
+    int consumerCount = info.consumerCount();
+    String leaderNode = info.leader();
+
+    management.queueDeletion().delete("my-queue");
+  }
+
+  void binding() {
+    Management management = null;
+
+    management.binding()
+        .sourceExchange("my-exchange")
+        .destinationQueue("my-queue")
+        .key("foo")
+        .bind();
+
+    management.binding()
+        .sourceExchange("my-exchange")
+        .destinationExchange("my-other-exchange")
+        .key("foo")
+        .bind();
+
+    management.unbind()
+        .sourceExchange("my-exchange")
+        .destinationQueue("my-queue")
+        .key("foo")
+        .unbind();
+  }
+}