[ISSUE #51]Consumer should support bulk subscription queue and poll message by offset .

Author: zongtanghu

openmessaging-api/src/main/java/io/openmessaging/consumer/Consumer.java

@@ -97,6 +97,20 @@ public interface Consumer extends ServiceLifecycle, Client {
      */
     void bindQueue(String queueName);
 
+    /**
+     * Bind the {@code Consumer} to a collection of queue in pull model, user can use {@link Consumer#receive(long)} to get
+     * messages from a collection of queue.
+     * <p>
+     * {@link MessageListener#onReceived(Message, MessageListener.Context)} will be called when new delivered message is
+     * coming.
+     *
+     * @param queueNames a collection of queues.
+     * @throws OMSSecurityException when have no authority to bind to this queue.
+     * @throws OMSDestinationException when have no given destination in the server.
+     * @throws OMSRuntimeException when the {@code Producer} fails to send the message due to some internal error.
+     */
+    void bindQueue(List<String> queueNames);
+
     /**
      * Bind the {@code Consumer} to a specified queue, with a {@code MessageListener}.
      * <p>
@@ -111,6 +125,20 @@ public interface Consumer extends ServiceLifecycle, Client {
      */
     void bindQueue(String queueName, MessageListener listener);
 
+    /**
+     * Bind the {@code Consumer} to a collection of queue, with a {@code MessageListener}.
+     * <p>
+     * {@link MessageListener#onReceived(Message, MessageListener.Context)} will be called when new delivered message is
+     * coming.
+     *
+     * @param queueNames a collection of queues.
+     * @param listener a specified listener to receive new message.
+     * @throws OMSSecurityException when have no authority to bind to this queue.
+     * @throws OMSDestinationException when have no given destination in the server.
+     * @throws OMSRuntimeException when the {@code Producer} fails to send the message due to some internal error.
+     */
+    void bindQueues(List<String> queueNames, MessageListener listener);
+
     /**
      * Bind the {@code Consumer} to a specified queue, with a {@code BatchMessageListener}.
      * <p>
@@ -125,6 +153,20 @@ public interface Consumer extends ServiceLifecycle, Client {
      */
     void bindQueue(String queueName, BatchMessageListener listener);
 
+    /**
+     * Bind the {@code Consumer} to a collection of queue, with a {@code BatchMessageListener}.
+     * <p>
+     * {@link BatchMessageListener#onReceived(List, BatchMessageListener.Context)} will be called when new delivered
+     * messages is coming.
+     *
+     * @param queueNames a collection of queues.
+     * @param listener a specified listener to receive new messages.
+     * @throws OMSSecurityException when have no authority to bind to this queue.
+     * @throws OMSDestinationException when have no given destination in the server.
+     * @throws OMSRuntimeException when the {@code Producer} fails to send the message due to some internal error.
+     */
+    void bindQueues(List<String> queueNames, BatchMessageListener listener);
+
     /**
      * Unbind the {@code Consumer} from a specified queue.
      * <p>
@@ -134,6 +176,15 @@ public interface Consumer extends ServiceLifecycle, Client {
      */
     void unbindQueue(String queueName);
 
+    /**
+     * Unbind the {@code Consumer} from a collection of queues.
+     * <p>
+     * After the success call, this consumer won't receive new message from the specified queue any more.
+     *
+     * @param queueNames a collection of queues.
+     */
+    void unbindQueues(List<String> queueNames);
+
     /**
      * This method is used to find out whether the {@code Consumer} in bind queue.
      *
@@ -142,11 +193,11 @@ public interface Consumer extends ServiceLifecycle, Client {
     boolean isBindQueue();
 
     /**
-     * This method is used to find out the queue bind to {@code Consumer}.
+     * This method is used to find out the collection of queues bind to {@code Consumer}.
      *
-     * @return the queue this consumer is bind, or null if the consumer is not bind queue.
+     * @return the queues this consumer is bind, or null if the consumer is not bind queue.
      */
-    String getBindQueue();
+    String getBindQueues();
 
     /**
      * Adds a {@code ConsumerInterceptor} instance to this consumer.
@@ -176,6 +227,25 @@ public interface Consumer extends ServiceLifecycle, Client {
      */
     Message receive(long timeout);
 
+    /**
+     * Receives the next message from the which bind queue,partition and offset of this consumer in pull model.
+     * <p>
+     * This call blocks indefinitely until a message is arrives, the timeout expires, or until this {@code PullConsumer}
+     * is shut down.
+     *
+     * @param queueName receive message from which queueName in Message Queue.
+     * @param partition receive message from which partition in Message Queue.
+     * @param offset  receive message from which offset in Message Queue.
+     * @param timeout receive message will blocked at most <code>timeout</code> milliseconds.
+     * @return the next message received from the bind queues, or null if the consumer is concurrently shut down.
+     * @throws OMSSecurityException when have no authority to receive messages from this queue.
+     * @throws OMSTimeOutException when the given timeout elapses before the send operation completes.
+     * @throws OMSRuntimeException when the {@code Producer} fails to send the message due to some internal error.
+     */
+    Message receive(String queueName, String partition, long offset, long timeout);
+
+
+
     /**
      * Receive message in asynchronous way. This call doesn't block user's thread, and user's message resolve logic
      * should implement in the {@link MessageListener}.