private async Task OnMessagesSend(
IDeliveryHandlerContext context,
MessagesSendArguments arguments )
{
foreach (var message in arguments.Items)
{
switch (message.Behavior)
{
case BehaviorType.Simple:
foreach (var operatorName in message.To)
{
var endpoint = await _operatorEndpointCache.EndpointGet(operatorName);
await endpoint.EventEmit(new NotificationsReceivedEvent(
new NotificationDto
{
Id = Guid.NewGuid(),
Message = message
}));
}
break;
}
private async Task OnMessagesSend(
IDeliveryHandlerContext context,
MessagesSendArguments arguments )
{
foreach (var message in arguments.Items)
{
switch (message.Behavior)
{
case BehaviorType.Simple:
foreach (var operatorName in message.To)
{
var endpoint = await _operatorEndpointCache.EndpointGet(operatorName);
await endpoint.EventEmit(new NotificationsReceivedEvent(
new NotificationDto
{
Id = Guid.NewGuid(),
Message = message
}));
}
break;
}