Welcome to ForkCan.com

ForkCan is all about sharing code in a social way.

Discuss, debate or argue with other devs about their or your own code.

Give other devs feedback or make a Fork (Make a better version of a shared code).

Rate the code, if you use the code mark it as used so others can see if the shared code is used by someone.

Help each other to be better devs and to be more productive.

Features not working yet:

Flag a post

QR Code

Tiny Url

http://4kcan.com/s/MTIxMA==

Related Code

public abstract class MessageHandler : DelegatingHandler
{
    protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
    {
        var corrId =string.Format("{0}{1}", DateTime.Now.Ticks, Thread.CurrentThread.ManagedThreadId);

        return request.Content.ReadAsByteArrayAsync()
            .ContinueWith(t => IncommingMessageAsync(corrId, t.Result)
            .ContinueWith(t2 => base.SendAsync(request, cancellationToken)
            .ContinueWith(task =>
            {
                 task.Result.Content.ReadAsByteArrayAsync()
                     .ContinueWith(t3 => OutgoingMessageAsync(corrId, t3.Result),cancellationToken);

                return task.Result;

            },cancellationToken),
            cancellationToken)
            .Unwrap())
            .Unwrap();
    }


    protected abstract Task IncommingMessageAsync(string correlationId, byte[] message);
    protected abstract Task OutgoingMessageAsync(string correlationId, byte[] message);
}


public class MessageLoggingHandler : MessageHandler
{
    protected override Task IncommingMessageAsync(string correlationId, byte[] message)
    {
        var tcs = new TaskCompletionSource<object>();

        Debug.WriteLine(string.Format("{0} - Incomming messages: {1}", correlationId, Encoding.UTF8.GetString(message)));

        tcs.SetResult(null);

        return tcs.Task;
    }


    protected override Task OutgoingMessageAsync(string correlationId, byte[] message)
    {
        var tcs = new TaskCompletionSource<object>();

        Debug.WriteLine(string.Format("{0} - Outgoing messages: {1}", correlationId, Encoding.UTF8.GetString(message)));

        tcs.SetResult(null);

        return tcs.Task;
    }
}

The MessageHandler need to be registered to be used, it can be done in the global.asax:

GlobalConfiguration.Configuration.MessageHandlers.Add(new MessageLoggingHandler());

Note: Because the messages is read into a buffer, there will be two compy of the data, so be carefull when it comes to large messages.

Share: twitter | facebook   Action: used | fork | flag