Add lambda-based methods to consume messages

src/main/java/com/rabbitmq/client/CancelCallback.java

@@ -0,0 +1,45 @@
+// Copyright (c) 2017 Pivotal Software, Inc.  All rights reserved.
+//
+// This software, the RabbitMQ Java client library, is triple-licensed under the
+// Mozilla Public License 1.1 ("MPL"), the GNU General Public License version 2
+// ("GPL") and the Apache License version 2 ("ASL"). For the MPL, please see
+// LICENSE-MPL-RabbitMQ. For the GPL, please see LICENSE-GPL2.  For the ASL,
+// please see LICENSE-APACHE2.
+//
+// This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY KIND,
+// either express or implied. See the LICENSE file for specific language governing
+// rights and limitations of this software.
+//
+// If you have any questions regarding licensing, please contact us at
+// [email protected].
+
+package com.rabbitmq.client;
+
+import java.io.IOException;
+import java.util.Map;
+
+/**
+ * Callback interface to be notified of the cancellation of a consumer.
+ * Prefer it over {@link Consumer} for a lambda-oriented syntax,
+ * if you don't need to implement all the application callbacks.
+ * @see DeliverCallback
+ * @see ConsumerShutdownSignalCallback
+ * @see Channel#basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, CancelCallback)
+ * @see Channel#basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, ConsumerShutdownSignalCallback)
+ * @see Channel#basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback)
+ * @since 5.0
+ */
+@FunctionalInterface
+public interface CancelCallback {
+
+    /**
+     * Called when the consumer is cancelled for reasons <i>other than</i> by a call to
+     * {@link Channel#basicCancel}. For example, the queue has been deleted.
+     * See {@link Consumer#handleCancelOk} for notification of consumer
+     * cancellation due to {@link Channel#basicCancel}.
+     * @param consumerTag the <i>consumer tag</i> associated with the consumer
+     * @throws IOException
+     */
+    void handle(String consumerTag) throws IOException;
+
+}

src/main/java/com/rabbitmq/client/Consumer.java

@@ -33,6 +33,9 @@
  * because this will delay dispatch of messages to other {@link Consumer}s on the same
  * {@link Channel}.
  *
+ * For a lambda-oriented syntax, use {@link DeliverCallback},
+ * {@link CancelCallback}, and {@link ConsumerShutdownSignalCallback}.
+ *
  * @see Channel#basicConsume(String, boolean, String, boolean, boolean, java.util.Map, Consumer)
  * @see Channel#basicCancel
  */

src/main/java/com/rabbitmq/client/ConsumerShutdownSignalCallback.java

@@ -0,0 +1,42 @@
+// Copyright (c) 2017 Pivotal Software, Inc.  All rights reserved.
+//
+// This software, the RabbitMQ Java client library, is triple-licensed under the
+// Mozilla Public License 1.1 ("MPL"), the GNU General Public License version 2
+// ("GPL") and the Apache License version 2 ("ASL"). For the MPL, please see
+// LICENSE-MPL-RabbitMQ. For the GPL, please see LICENSE-GPL2.  For the ASL,
+// please see LICENSE-APACHE2.
+//
+// This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY KIND,
+// either express or implied. See the LICENSE file for specific language governing
+// rights and limitations of this software.
+//
+// If you have any questions regarding licensing, please contact us at
+// [email protected].
+
+package com.rabbitmq.client;
+
+import java.util.Map;
+
+/**
+ * Callback interface to be notified when either the consumer channel
+ * or the underlying connection has been shut down.
+ * Prefer it over {@link Consumer} for a lambda-oriented syntax,
+ * if you don't need to implement all the application callbacks.
+ * @see CancelCallback
+ * @see DeliverCallback
+ * @see Channel#basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, CancelCallback)
+ * @see Channel#basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, ConsumerShutdownSignalCallback)
+ * @see Channel#basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback)
+ * @since 5.0
+ */
+@FunctionalInterface
+public interface ConsumerShutdownSignalCallback {
+
+    /**
+     * Called when either the channel or the underlying connection has been shut down.
+     * @param consumerTag the <i>consumer tag</i> associated with the consumer
+     * @param sig a {@link ShutdownSignalException} indicating the reason for the shut down
+     */
+    void handleShutdownSignal(String consumerTag, ShutdownSignalException sig);
+
+}

src/main/java/com/rabbitmq/client/DeliverCallback.java

@@ -0,0 +1,43 @@
+// Copyright (c) 2017 Pivotal Software, Inc.  All rights reserved.
+//
+// This software, the RabbitMQ Java client library, is triple-licensed under the
+// Mozilla Public License 1.1 ("MPL"), the GNU General Public License version 2
+// ("GPL") and the Apache License version 2 ("ASL"). For the MPL, please see
+// LICENSE-MPL-RabbitMQ. For the GPL, please see LICENSE-GPL2.  For the ASL,
+// please see LICENSE-APACHE2.
+//
+// This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY KIND,
+// either express or implied. See the LICENSE file for specific language governing
+// rights and limitations of this software.
+//
+// If you have any questions regarding licensing, please contact us at
+// [email protected].
+
+package com.rabbitmq.client;
+
+import java.io.IOException;
+import java.util.Map;
+
+/**
+ * Callback interface to be notified when a message is delivered.
+ * Prefer it over {@link Consumer} for a lambda-oriented syntax,
+ * if you don't need to implement all the application callbacks.
+ * @see CancelCallback
+ * @see ConsumerShutdownSignalCallback
+ * @see Channel#basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, CancelCallback)
+ * @see Channel#basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, ConsumerShutdownSignalCallback)
+ * @see Channel#basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback)
+ * @since 5.0
+ */
+@FunctionalInterface
+public interface DeliverCallback {
+
+    /**
+     * Called when a <code><b>basic.deliver</b></code> is received for this consumer.
+     * @param consumerTag the <i>consumer tag</i> associated with the consumer
+     * @param message the delivered message
+     * @throws IOException if the consumer encounters an I/O error while processing the message
+     */
+    void handle(String consumerTag, Delivery message) throws IOException;
+
+}

src/main/java/com/rabbitmq/client/Delivery.java

@@ -0,0 +1,55 @@
+// Copyright (c) 2017 Pivotal Software, Inc.  All rights reserved.
+//
+// This software, the RabbitMQ Java client library, is triple-licensed under the
+// Mozilla Public License 1.1 ("MPL"), the GNU General Public License version 2
+// ("GPL") and the Apache License version 2 ("ASL"). For the MPL, please see
+// LICENSE-MPL-RabbitMQ. For the GPL, please see LICENSE-GPL2.  For the ASL,
+// please see LICENSE-APACHE2.
+//
+// This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY KIND,
+// either express or implied. See the LICENSE file for specific language governing
+// rights and limitations of this software.
+//
+// If you have any questions regarding licensing, please contact us at
+// [email protected].
+
+package com.rabbitmq.client;
+
+/**
+ * Encapsulates an arbitrary message - simple "bean" holder structure.
+ */
+public class Delivery {
+    private final Envelope _envelope;
+    private final AMQP.BasicProperties _properties;
+    private final byte[] _body;
+
+    public Delivery(Envelope envelope, AMQP.BasicProperties properties, byte[] body) {
+        _envelope = envelope;
+        _properties = properties;
+        _body = body;
+    }
+
+    /**
+     * Retrieve the message envelope.
+     * @return the message envelope
+     */
+    public Envelope getEnvelope() {
+        return _envelope;
+    }
+
+    /**
+     * Retrieve the message properties.
+     * @return the message properties
+     */
+    public AMQP.BasicProperties getProperties() {
+        return _properties;
+    }
+
+    /**
+     * Retrieve the message body.
+     * @return the message body
+     */
+    public byte[] getBody() {
+        return _body;
+    }
+}

src/main/java/com/rabbitmq/client/RpcServer.java

@@ -235,45 +235,6 @@ public String getQueueName() {
         return _queueName;
     }
 
-    /**
-     * Encapsulates an arbitrary message - simple "bean" holder structure.
-     */
-    public static class Delivery {
-        private final Envelope _envelope;
-        private final AMQP.BasicProperties _properties;
-        private final byte[] _body;
-
-        public Delivery(Envelope envelope, AMQP.BasicProperties properties, byte[] body) {
-            _envelope = envelope;
-            _properties = properties;
-            _body = body;
-        }
-
-        /**
-         * Retrieve the message envelope.
-         * @return the message envelope
-         */
-        public Envelope getEnvelope() {
-            return _envelope;
-        }
-
-        /**
-         * Retrieve the message properties.
-         * @return the message properties
-         */
-        public AMQP.BasicProperties getProperties() {
-            return _properties;
-        }
-
-        /**
-         * Retrieve the message body.
-         * @return the message body
-         */
-        public byte[] getBody() {
-            return _body;
-        }
-    }
-
     public interface RpcConsumer extends Consumer {
 
         Delivery nextDelivery() throws InterruptedException, ShutdownSignalException, ConsumerCancelledException;