-
Notifications
You must be signed in to change notification settings - Fork 626
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add support for consumer batching #1032
Milestone
Comments
garyrussell
added a commit
to garyrussell/spring-amqp
that referenced
this issue
Jun 24, 2019
garyrussell
added a commit
to garyrussell/spring-amqp
that referenced
this issue
Jun 24, 2019
artembilan
pushed a commit
that referenced
this issue
Jun 26, 2019
Resolves #1032 * Missing Javadocs * Still De-Batch producer batches if so configured * Polishing; detect incorrect configuration. * Revert to generic message for incorrect configuration.
Still needs work for |
garyrussell
added a commit
to garyrussell/spring-amqp
that referenced
this issue
Jun 27, 2019
Resolves spring-projects#1032 Add basic consumer batching support to the `@RabbitListener` infrastructure.
garyrussell
added a commit
to garyrussell/spring-amqp
that referenced
this issue
Jun 27, 2019
Resolves spring-projects#1032 Add basic consumer batching support to the `@RabbitListener` infrastructure.
garyrussell
added a commit
to garyrussell/spring-amqp
that referenced
this issue
Jun 28, 2019
Resolves spring-projects#1032 Add basic consumer batching support to the `@RabbitListener` infrastructure.
artembilan
pushed a commit
that referenced
this issue
Jun 28, 2019
Resolves #1032 Add basic consumer batching support to the `@RabbitListener` infrastructure. * * Polishing - simplify batch configuration in container factories * Add a test to ensure producer debatching works for DMLC too * * Add more tests * * Fix javadoc; add one more test * * Fix type in test name
garyrussell
added a commit
that referenced
this issue
Jul 1, 2019
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Currently, consumer batching (providing the listener with the complete batch in one call) only applies when the producer creates the batch.
With the
SimpleMessageListenerContainer
, it should be relatively easy with its existing infrastructure to support presenting the listener with a batch of discrete messages.txSize
in favor ofbatchSize
enableConsumerBatching
receiveTimeout
.MessageListener
isBatchConsumer()
andonMessageBatch()
The text was updated successfully, but these errors were encountered: