Skip to content

Commit 875f9a1

Browse files
committed
add version broker for filterning [skip ci]
Signed-off-by: Gabriele Santomaggio <[email protected]>
1 parent e0a0b1f commit 875f9a1

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

RabbitMQ.Stream.Client/RawConsumer.cs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,8 @@ internal void Validate()
8282

8383
if (IsFiltering && !AvailableFeaturesSingleton.Instance.PublishFilter)
8484
{
85-
throw new UnsupportedOperationException("Broker does not support filtering");
85+
throw new UnsupportedOperationException("Broker does not support filtering. You need " +
86+
"RabbitMQ 3.13.0 or later.");
8687
}
8788

8889
switch (ConsumerFilter)

RabbitMQ.Stream.Client/RawProducer.cs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,8 @@ internal void Validate()
4444
{
4545
if (Filter is { FilterValue: not null } && !AvailableFeaturesSingleton.Instance.PublishFilter)
4646
{
47-
throw new UnsupportedOperationException("Broker does not support filtering");
47+
throw new UnsupportedOperationException("Broker does not support filtering. " +
48+
"You need RabbitMQ 3.13.0 or later.");
4849
}
4950
}
5051
}

0 commit comments

Comments
 (0)