Namespace Silverback.Messaging.Subscribers

ConsumerNameFilterAttribute: Can be placed on a subscribed method to filter the messages to be processed according to the name of the consumer that consumed them. This is useful when having multiple consumers subscribed to the same topic.

KafkaGroupIdFilterAttribute: Can be placed on a subscribed method to filter the messages to be processed according to the group id that consumed them. This is used when having multiple consumer groups for the same topic running in the same process.

MessageFilterAttribute: Can be placed on a subscribed method to filter the messages to be processed.

MqttClientIdFilterAttribute: Can be placed on a subscribed method to filter the messages to be processed according to the client id that consumed them. This is used when having multiple clients for the same topic running in the same process.

SubscribeAttribute: Used to identify the methods that have to be subscribed to the messages stream. The first parameter of the subscriber method always correspond to the message and must be declared with a type compatible with the message to be received (the message type, a base type or an implemented interface) or a collection of items of that type. The methods can be either synchronous or asynchronous (returning a Task) and don't need to be publicly visible.

SubscribedMethodInvocationException: The exception that is thrown when a subscribed method cannot be invoked. This usually happens because no value can be resolved for one or more arguments.

SubscribedMethodsLoaderService: Resolves all the subscribers and build the types cache to boost the first publish performance.