Skip to content

Implement AMQP 1.0 binding declaration - #238

Open
sharathb5 wants to merge 13 commits into
feature-amqp10from
192-provider-interface-implement-declarebindings
Open

sharathb5 wants to merge 13 commits into
feature-amqp10from
192-provider-interface-implement-declarebindings

Conversation

@sharathb5

@sharathb5 sharathb5 commented Oct 12, 2026 •

Copy link
Copy Markdown
Contributor

Implemented AMQP 1.0 binding declarations with AMQP 0.9.1 routing parity, ParentAddress support, and Bind error propagation. Add focused unit coverage and a live broker integration check for exchange-to-queue binding creation.

Signed-off-by: Sharath Bhattiprolu <sharathjb23@gmail.com>
Signed-off-by: Sharath Bhattiprolu <sharathjb23@gmail.com>
Signed-off-by: Sharath Bhattiprolu <sharathjb23@gmail.com>
Signed-off-by: Sharath Bhattiprolu <sharathjb23@gmail.com>
Signed-off-by: Sharath Bhattiprolu <sharathjb23@gmail.com>
@sharathb5 sharathb5 changed the title implemented declare bindings Implement AMQP 1.0 binding declaration Oct 12, 2026
@sharathb5
sharathb5 marked this pull request as ready for review October 12, 2026 15:21
Signed-off-by: Sharath Bhattiprolu <sharathjb23@gmail.com>
Signed-off-by: Sharath Bhattiprolu <sharathjb23@gmail.com>
Comment thread internal/provider/connectors/rabbitmq/amqp10/amqp10_provider.go Outdated
Comment thread internal/provider/connectors/rabbitmq/amqp10/amqp10_provider.go
…-provider-interface-implement-declarebindings

Signed-off-by: Sharath Bhattiprolu <142956525+sharathb5@users.noreply.github.com>
Comment thread internal/provider/connectors/rabbitmq/amqp10/amqp10_provider_test.go Outdated
Signed-off-by: Sharath Bhattiprolu <sharathjb23@gmail.com>
…-declarebindings' into 192-provider-interface-implement-declarebindings

Signed-off-by: Sharath Bhattiprolu <sharathjb23@gmail.com>

# Conflicts:
#	internal/provider/connectors/rabbitmq/amqp10/broker_details_test.go
Comment thread internal/provider/connectors/rabbitmq/amqp10/amqp10_conn.go Outdated
Comment thread internal/provider/connectors/rabbitmq/amqp10/amqp10_provider.go
Signed-off-by: Sharath Bhattiprolu <sharathjb23@gmail.com>
Comment thread internal/provider/connectors/rabbitmq/amqp10/amqp10_conn.go
Log queue binding errors and continue, matching AMQP 0.9.1. Keep the integration test context alive through cleanup.

Signed-off-by: Sharath Bhattiprolu <sharathjb23@gmail.com>
Comment thread internal/provider/connectors/rabbitmq/amqp10/amqp10_provider.go
Comment thread internal/provider/connectors/rabbitmq/amqp10/amqp10_provider.go
Base automatically changed from 190-provider-interface-implement-declarequeue to feature-amqp10 October 15, 2026 18:14
Signed-off-by: Sharath Bhattiprolu <sharathjb23@gmail.com>
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.

3 participants