How to filter messages

[evarrica]

Good morning
In the Artemis MQ documentation you can filter the message by consumer thought filter expression Address filter Artemis where the java code is:

MessageConsumer redConsumer = redSession.createConsumer(queue, "color='red'");

What is the corresponding .net code?

[Havret]

Hi @evarrica,

To filter messages you need to specify the FilterExpression:

await using IConnection connection = await CreateConnection();
var address = Guid.NewGuid().ToString();

await using IConsumer redMessageConsumer = await connection.CreateConsumerAsync(new ConsumerConfiguration
{
    Address = address,
    RoutingType = RoutingType.Anycast,
    FilterExpression = "color = 'red'"
});
await using IConsumer blueMessageConsumer = await connection.CreateConsumerAsync(new ConsumerConfiguration
{
    Address = address,
    RoutingType = RoutingType.Anycast,
    FilterExpression = "color = 'blue'"
});

You can find more examples here.

Best,
Havret