File tree Expand file tree Collapse file tree
openmessaging-api/src/main/java/io/openmessaging/consumer Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -197,7 +197,7 @@ public interface Consumer extends ServiceLifecycle, Client {
197197 *
198198 * @return the queues this consumer is bind, or null if the consumer is not bind queue.
199199 */
200- String getBindQueues ();
200+ List < String > getBindQueues ();
201201
202202 /**
203203 * Adds a {@code ConsumerInterceptor} instance to this consumer.
@@ -234,15 +234,15 @@ public interface Consumer extends ServiceLifecycle, Client {
234234 * is shut down.
235235 *
236236 * @param queueName receive message from which queueName in Message Queue.
237- * @param partition receive message from which partition in Message Queue.
237+ * @param partitionId receive message from which partition in Message Queue.
238238 * @param offset receive message from which offset in Message Queue.
239239 * @param timeout receive message will blocked at most <code>timeout</code> milliseconds.
240240 * @return the next message received from the bind queues, or null if the consumer is concurrently shut down.
241241 * @throws OMSSecurityException when have no authority to receive messages from this queue.
242242 * @throws OMSTimeOutException when the given timeout elapses before the send operation completes.
243243 * @throws OMSRuntimeException when the {@code Producer} fails to send the message due to some internal error.
244244 */
245- Message receive (String queueName , String partition , long offset , long timeout );
245+ Message receive (String queueName , int partitionId , long offset , long timeout );
246246
247247
248248
You can’t perform that action at this time.
0 commit comments