Skip to content

AMQP 1.0 RequestReply emitter#3382

Open
ozangunalp wants to merge 6 commits intosmallrye:mainfrom
ozangunalp:amqp_request_reply_clean
Open

AMQP 1.0 RequestReply emitter#3382
ozangunalp wants to merge 6 commits intosmallrye:mainfrom
ozangunalp:amqp_request_reply_clean

Conversation

@ozangunalp
Copy link
Copy Markdown
Collaborator

No description provided.

Channels with the same container-id now share a single AMQP connection
Link pairing support allows sender/receiver pairs on the
same connection for request-reply routing.
@codecov
Copy link
Copy Markdown

codecov Bot commented Apr 24, 2026

Codecov Report

❌ Patch coverage is 79.92832% with 56 lines in your changes missing coverage. Please review.
✅ Project coverage is 77.77%. Comparing base (a96442f) to head (7b18e8c).
⚠️ Report is 1152 commits behind head on main.

Files with missing lines Patch % Lines
...lrye/reactive/messaging/amqp/ConnectionHolder.java 66.07% 13 Missing and 6 partials ⚠️
...ive/messaging/amqp/reply/AmqpRequestReplyImpl.java 84.69% 9 Missing and 6 partials ⚠️
...mallrye/reactive/messaging/amqp/AmqpConnector.java 83.33% 4 Missing ⚠️
.../messaging/amqp/reply/AmqpRequestReplyFactory.java 69.23% 1 Missing and 3 partials ⚠️
...ctive/messaging/amqp/reply/BytesCorrelationId.java 66.66% 2 Missing and 2 partials ⚠️
...tive/messaging/amqp/reply/StringCorrelationId.java 63.63% 2 Missing and 2 partials ⚠️
...lrye/reactive/messaging/amqp/AmqpClientHelper.java 88.23% 2 Missing ⚠️
...g/amqp/reply/AmqpRequestReplyTimeoutException.java 50.00% 2 Missing ⚠️
...reactive/messaging/amqp/AmqpCreditBasedSender.java 66.66% 0 Missing and 1 partial ⚠️
...e/reactive/messaging/amqp/IncomingAmqpChannel.java 92.30% 1 Missing ⚠️
Additional details and impacted files

Impacted file tree graph

@@             Coverage Diff              @@
##               main    #3382      +/-   ##
============================================
+ Coverage     77.47%   77.77%   +0.30%     
- Complexity     3778     5504    +1726     
============================================
  Files           306      474     +168     
  Lines         12673    18419    +5746     
  Branches       1648     2280     +632     
============================================
+ Hits           9818    14326    +4508     
- Misses         2116     2966     +850     
- Partials        739     1127     +388     
Files with missing lines Coverage Δ
...lrye/reactive/messaging/amqp/AmqpClientHolder.java 100.00% <100.00%> (ø)
.../reactive/messaging/amqp/AmqpMessageConverter.java 83.11% <100.00%> (+0.92%) ⬆️
...e/reactive/messaging/amqp/OutgoingAmqpChannel.java 73.13% <100.00%> (ø)
...e/reactive/messaging/amqp/i18n/AMQPExceptions.java 100.00% <ø> (ø)
...lrye/reactive/messaging/amqp/i18n/AMQPLogging.java 100.00% <ø> (ø)
...essaging/amqp/reply/BytesCorrelationIdHandler.java 100.00% <100.00%> (ø)
...e/reactive/messaging/amqp/reply/CorrelationId.java 100.00% <100.00%> (ø)
...messaging/amqp/reply/UUIDCorrelationIdHandler.java 100.00% <100.00%> (ø)
...reactive/messaging/amqp/AmqpCreditBasedSender.java 79.34% <66.66%> (+5.35%) ⬆️
...e/reactive/messaging/amqp/IncomingAmqpChannel.java 91.25% <92.30%> (ø)
... and 8 more

... and 249 files with indirect coverage changes

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

@ozangunalp ozangunalp force-pushed the amqp_request_reply_clean branch from 9eb85e2 to f319cdb Compare April 24, 2026 10:40
@ozangunalp ozangunalp force-pushed the amqp_request_reply_clean branch from f319cdb to 7b18e8c Compare April 24, 2026 10:57
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant