We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent db7727f commit 1f25949Copy full SHA for 1f25949
tests/test_streams.py
@@ -572,7 +572,7 @@ def test_stream_filter_mixing_different(
572
connection_consumer.dial()
573
consumer = connection_consumer.consumer(
574
addr_queue,
575
- message_handler=MyMessageHandlerApplicationPropertiesFilter(),
+ message_handler=MyMessageHandlerMixingDifferentFilters(),
576
stream_consumer_options=StreamConsumerOptions(
577
filter_options=StreamFilterOptions(
578
values=["my_value"],
0 commit comments