A few examples for testing per-queue ttl, especially over broker restarts

Author: Rob Harrop

test/src/com/rabbitmq/examples/PerQueueTTLGetter.java

@@ -0,0 +1,31 @@
+package com.rabbitmq.examples;
+
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.ConnectionFactory;
+import com.rabbitmq.client.GetResponse;
+
+/**
+ * @author robharrop
+ */
+public class PerQueueTTLGetter {
+
+    public static void main(String[] args) throws Exception {
+        ConnectionFactory factory = new ConnectionFactory();
+        Connection connection = factory.newConnection();
+        Channel channel = connection.createChannel();
+
+        String queue = "ttl.queue";
+
+        // exchange
+        GetResponse response = channel.basicGet(queue, false);
+        if(response == null) {
+            System.out.println("Got no message...");
+        } else {
+            System.out.println("Got message: " + new String(response.getBody()));
+            channel.basicAck(response.getEnvelope().getDeliveryTag(), false);
+        }
+        channel.close();
+        connection.close();
+    }
+}

test/src/com/rabbitmq/examples/PerQueueTTLPublisher.java

@@ -0,0 +1,41 @@
+package com.rabbitmq.examples;
+
+import com.rabbitmq.client.AMQP;
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.ConnectionFactory;
+
+import java.util.Collections;
+
+/**
+ * @author robharrop
+ */
+public class PerQueueTTLPublisher {
+
+    public static void main(String[] args) throws Exception {
+        ConnectionFactory factory = new ConnectionFactory();
+        Connection connection = factory.newConnection();
+        Channel channel = connection.createChannel();
+
+        String exchange = "ttl.exchange";
+        String queue = "ttl.queue";
+
+        // exchange
+        channel.exchangeDeclare(exchange, "direct");
+
+        // queue
+        channel.queueDeclare(queue, true, false, false, Collections.singletonMap("x-message-ttl", (Object) 30000L));
+        channel.queueBind(queue, exchange, queue, null);
+
+        // send a message
+        AMQP.BasicProperties props = new AMQP.BasicProperties();
+        props.setDeliveryMode(2);
+        for(int x = 0; x < 10; x++) {
+            channel.basicPublish(exchange, queue, props, ("Msg [" + x + "]").getBytes());
+        }
+
+        System.out.println("Done");
+        channel.close();
+        connection.close();
+    }
+}