foreach (var argument in arguments.Items)
{
var messageDto = new MessageDto
{
Timestamp = DateTimeOffset.Now,
Title = "", // think about this
Content = argument.Event.ToJsonString(), // fix this
Behavior = argument.Behavior,
To = await GetSubjectsAddresses(
channelName: argument.ChannelName,
subjects: subjectsQueryResponse
.Where(subjectDto => argument.SubjectIds
.Contains(subjectDto.Id)),
channelSettings: channelSettings)
};
await _messagingChannelsClient.MessagesSend(new(argument.ChannelName, new[] { messageDto }) );
foreach (var argument in arguments.Items)
{
var messageDto = new MessageDto
{
Timestamp = DateTimeOffset.Now,
Title = "", // think about this
Content = argument.Event.ToJsonString(), // fix this
Behavior = argument.Behavior,
To = await GetSubjectsAddresses(
channelName: argument.ChannelName,
subjects: subjectsQueryResponse
.Where(subjectDto => argument.SubjectIds
.Contains(subjectDto.Id)),
channelSettings: channelSettings)
};
await _messagingChannelsClient.MessagesSend(new(argument.ChannelName, new[] { messageDto }) );