Observe messages from consumer

47 views
Skip to first unread message

Vladimir Voloshin

unread,
Jun 16, 2016, 6:11:18 AM6/16/16
to masstransit-discuss
Hello,

how is possible to observe messages sent from consumers by Respond method ?


Sample code:
     public Task Consume(ConsumeContext<IDialogEndRejectMsg> context)
     {
            context.Respond(new ForecourtDialogEndRejectMsg()
            {
                CorrelationId = context.Message.CorrelationId
            } as IForecourtDialogEndRejectMsg);

            return Task.FromResult<object>(null);
        }

I've tried all types of observes but no one catch that messages

            bus.ConnectReceiveObserver(new ReceiveObserver());
            bus.ConnectConsumeObserver(new ConsumeObserver());
            bus.ConnectSendObserver(new SendObserver());
            bus.ConnectPublishObserver(new PublishObserver());

/Vladimir

Vladimir Voloshin

unread,
Jul 13, 2016, 6:36:35 AM7/13/16
to masstransit-discuss
Seems no one faced the previous problem...

But I have one more with observing messages. Observing published messages doesn't work for me
Simple code

bus.ConnectPublishObserver(new PublishObserver());

bus.Start();

and

public class PublishObserver : IPublishObserver
    {
        public async System.Threading.Tasks.Task PrePublish<T>(PublishContext<T> context)
            where T : class
        {
            ...
            _logger.Debug("PrePublish");
        }

        public async System.Threading.Tasks.Task PostPublish<T>(PublishContext<T> context)
            where T : class
        {
            ...
            _logger.Debug("PostPublish");
        }

        public async System.Threading.Tasks.Task PublishFault<T>(PublishContext<T> context, Exception exception)
            where T : class
        {
            ...
            _logger.Debug("PublishFault");
        }
    }

Observing consumed, received and sent messages works for sagas and producers but published no where.



Reply all
Reply to author
Forward
0 new messages