Skip to content

Conversation

@Gsantomaggio
Copy link
Member

@Gsantomaggio Gsantomaggio commented Sep 12, 2025

This PR implements application properties filtering for AMQP streams, enabling consumers to filter messages based on their application-level properties. This completes the feature request tracked in issue #42.

Adds support for filtering messages by application properties in stream consumers
Updates the example to demonstrate both message properties and application properties filtering
Extends the StreamConsumerOptions class with application properties filter handling

complete: #42
Signed-off-by: Gabriele Santomaggio <[email protected]>
@Gsantomaggio Gsantomaggio added this to the 0.2.0 milestone Sep 12, 2025
Signed-off-by: Gabriele Santomaggio <[email protected]>
@Gsantomaggio Gsantomaggio marked this pull request as ready for review September 12, 2025 13:20
Copy link
Contributor

Copilot AI left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Pull Request Overview

This PR implements application properties filtering for AMQP streams, enabling consumers to filter messages based on their application-level properties. This completes the feature request tracked in issue #42.

  • Adds support for filtering messages by application properties in stream consumers
  • Updates the example to demonstrate both message properties and application properties filtering
  • Extends the StreamConsumerOptions class with application properties filter handling

Reviewed Changes

Copilot reviewed 2 out of 2 changed files in this pull request and generated 2 comments.

File Description
rabbitmq_amqp_python_client/entities.py Adds constant for application properties filter spec and implements the filtering logic in StreamConsumerOptions
examples/streams_with_filters/example_streams_with_filters.py Updates example to showcase application properties filtering alongside existing filters

Tip: Customize your code reviews with copilot-instructions.md. Create the file or learn how to get started.

@Gsantomaggio Gsantomaggio self-assigned this Sep 12, 2025
@Gsantomaggio Gsantomaggio added the enhancement New feature or request label Sep 12, 2025
@Gsantomaggio Gsantomaggio merged commit a4d9e85 into main Sep 12, 2025
1 of 2 checks passed
@Gsantomaggio Gsantomaggio deleted the feat/application_properties_filters branch September 12, 2025 13:29
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

enhancement New feature or request

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant