Namespace Silverback.Messaging.Subscribers

Classes

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.

SubscribedMethod

A subscribed method that can process certain messages.

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.

Interfaces

IMessageFilter

Filters the messages to be processed.

ISubscribedMethodsCache

Stores the map of the subscribed methods for each message type.