using Microsoft.ServiceBus.Messaging;

using System;

using System.Collections.Generic;

using System.Configuration;

using System.Diagnostics;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using StackifyLib;

namespace WindowsService1

{

class QueueProcessor

{

private QueueClient _QueueClient = null;

public void Start()

{

OnMessageOptions options = new OnMessageOptions

{

MaxConcurrentCalls = 5,

AutoComplete = false

};

try

{

_QueueClient = QueueClient.CreateFromConnectionString(ConfigurationManager.AppSettings["Microsoft.ServiceBus.ConnectionString"], "WindowsService1");

_QueueClient.OnMessageAsync(async m =>

{

bool shouldAbandon = false;

try

{

//Create a new ID for the operation for correlation

var tracer = ProfileTracer.CreateAsOperation("Queue.WindowsService1", Trace.CorrelationManager.ActivityId.ToString());

// asynchronouse processing of messages

await tracer.ExecAsync(() =>

{

return ProcessMessageAsync(m);

});

// complete if successful processing

await m.CompleteAsync();

}

catch (Exception ex)

{

shouldAbandon = true;

Console.WriteLine(ex);

}

if (shouldAbandon)

{

await m.AbandonAsync();

}

},

options);

}

catch (Exception ex)

{

Debug.Write(ex.ToString());

}

}

private async Task<bool> ProcessMessageAsync(BrokeredMessage message)

{

Debug.WriteLine("Recieved message " + message.MessageId);

Debug.WriteLine("Do some cool back end processing here");

return true;

}

public void Stop()

{

_QueueClient.Close();

}

}

}