Skip to content
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 RabbitMQ Stream Java Client #1352

Closed
garyrussell opened this issue Jun 10, 2021 · 2 comments · Fixed by #1369
Closed

Add Support for RabbitMQ Stream Java Client #1352

garyrussell opened this issue Jun 10, 2021 · 2 comments · Fixed by #1369
Assignees
Milestone

Comments

@garyrussell
Copy link
Contributor

New listener container for the stream API to support invoking @RabbitListener etc.

https://github.com/rabbitmq/rabbitmq-stream-java-client

@garyrussell garyrussell added this to the 2.4 M1 milestone Jun 10, 2021
@garyrussell garyrussell self-assigned this Jun 10, 2021
garyrussell added a commit to garyrussell/spring-amqp that referenced this issue Jun 11, 2021
See https://rabbitmq.github.io/rabbitmq-stream-java-client/snapshot/htmlsingle/

Basic `@RabbitListener` support.

Required a higher level abstraction for listener container factories.
garyrussell added a commit to garyrussell/spring-amqp that referenced this issue Jun 11, 2021
See https://rabbitmq.github.io/rabbitmq-stream-java-client/snapshot/htmlsingle/

Basic `@RabbitListener` support.

Required a higher level abstraction for listener container factories.
artembilan pushed a commit that referenced this issue Jun 17, 2021
See https://rabbitmq.github.io/rabbitmq-stream-java-client/snapshot/htmlsingle/

Basic `@RabbitListener` support.

Required a higher level abstraction for listener container factories.

* Address more PR review comments.

* Remove unnecessary `destroyMethod` property from test.
garyrussell added a commit that referenced this issue Jun 18, 2021
garyrussell added a commit that referenced this issue Jun 21, 2021
garyrussell added a commit that referenced this issue Jun 21, 2021
garyrussell added a commit to garyrussell/spring-amqp that referenced this issue Jun 22, 2021
garyrussell added a commit to garyrussell/spring-amqp that referenced this issue Jun 22, 2021
garyrussell added a commit to garyrussell/spring-amqp that referenced this issue Jun 23, 2021
garyrussell added a commit that referenced this issue Jun 23, 2021
AMLC override of `afterPropertiesSet()` does not `throw Exception` so
MLC does not have to either.
garyrussell added a commit that referenced this issue Jun 23, 2021
Refactoring to allow Spring Integration 5.5 to be used with both
2.3.x and 2.4.x.
garyrussell added a commit that referenced this issue Jun 23, 2021
garyrussell added a commit that referenced this issue Jun 24, 2021
garyrussell added a commit that referenced this issue Jun 24, 2021
Generated `equals()`.
garyrussell added a commit that referenced this issue Jul 6, 2021
garyrussell added a commit that referenced this issue Jul 20, 2021
garyrussell added a commit to garyrussell/spring-amqp that referenced this issue Jul 22, 2021
- pass in the listener id, if available
- narrow to a specific interface to aid Boot auto configuration
garyrussell added a commit to garyrussell/spring-amqp that referenced this issue Jul 22, 2021
- pass in the listener id, if available
- narrow to a specific interface to aid Boot auto configuration
- add null check
artembilan pushed a commit that referenced this issue Jul 22, 2021
- pass in the listener id, if available
- narrow to a specific interface to aid Boot auto configuration
- add null check

* Apply Suggestion to add @FuntionalInterface
@welsh
Copy link

welsh commented Sep 7, 2021

Is there a tentative date for 2.4 being release with this being present? I see the last Milestone was 25 days ago.

@garyrussell
Copy link
Contributor Author

Next milestone is Sept 20; with release candidate in October and GA in November, aligned with the Boot 2.6 RC and GA.

https://calendar.spring.io/

garyrussell added a commit to garyrussell/spring-amqp that referenced this issue Sep 7, 2021
See spring-projects#1352

Initial commit of Stream Producer support.
artembilan pushed a commit that referenced this issue Sep 7, 2021
See #1352

Initial commit of Stream Producer support.

* Resolve PR Comments.

* Make TestContainers Optional

* Add test for null-returning MPP - send skipped.

* Fix latch for additional messages sent.

* Remove queues after test.
garyrussell added a commit that referenced this issue Sep 8, 2021
@garyrussell garyrussell modified the milestones: 2.4 M1, 2.4.0-M3 Sep 9, 2021
garyrussell added a commit to garyrussell/spring-amqp that referenced this issue Sep 14, 2021
Support for SI `RabbitStreamMessageHandler`, which will live in
the SCSt RabbitMQ binder until SI 6.0 due to versioning.

- expose converters
- use producer message builder if no stream converter provided
artembilan pushed a commit that referenced this issue Sep 14, 2021
Support for SI `RabbitStreamMessageHandler`, which will live in
the SCSt RabbitMQ binder until SI 6.0 due to versioning.

- expose converters
- use producer message builder if no stream converter provided

* Remove streams before tests; AfterAll has a timing problem.
garyrussell added a commit that referenced this issue Sep 15, 2021
garyrussell added a commit to garyrussell/spring-amqp that referenced this issue Sep 16, 2021
artembilan pushed a commit that referenced this issue Sep 17, 2021
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging a pull request may close this issue.

2 participants