search

onebeyond / rascal

A config driven wrapper for amqp.node supporting multi-host connections, automatic error recovery, redelivery flood protection, transparent encryption / decryption and channel pooling.
MIT License
451 stars 69 forks source link

Is x-priority argument supported for consumers? #145

Closed matte0080 closed 3 years ago

matte0080 commented 3 years ago

Hi,

I have 4 consumer from an unique queue, every consumer is a standalone server. Two server have good performance, otherwirse have bad performance. I want set x-proprity to consumer because default round robin strategy is not good. I want send more message to fastest server and only if these are busy send message to the slower servers.

Is x-proprity supported?

In index.d.ts file i can't find this property.

Consumer proprity

matte0080 commented 3 years ago

Ok, i found it in SubscriptionConfig --> options: Options.Consume --> proprity