ramonsmits

<?xml version="1.0" encoding="utf-8"?>
<log4net>

  <!-- Buffer 128 entries except with log level severity is WARN or higher. -->
  <appender name="buffer" type="log4net.Appender.BufferingForwardingAppender">
    <bufferSize value="128" />
    <appender-ref ref="console" />
    <!--<lossy value="false" />-->
    <!--<OnlyFixPartialEventData value="true"/>-->
    <evaluator type="log4net.Core.LevelEvaluator">

ramonsmits

//
// Run this before anything NServiceBus related. If using
// the host, put this in the constructor of the endpoint
// configuration class.
//
log4net.Config.XmlConfigurator.Configure();
NServiceBus.Logging.LogManager.Use<NServiceBus.Log4Net.Log4NetFactory>();

ramonsmits

using System;
using System.Globalization;
using log4net.Util;

namespace log4net
{
    public static class LogExtentions
    {
        private static readonly Type ThisDeclaringType = typeof(LogExtentions);

ramonsmits

public class CustomerNotificationHandler
	: IHandleMessage<CustomerOrderNotification>
	, IHandleMessage<CustomerOrderStatusNotification>
{
	public IBus Bus {get;set;}

	INotificationService GetClientForCustomer(string customerId)
	{
		return null; // Create a api client for your customer

ramonsmits

class Program
{
    static Mutex SingleInstanceMutex = AcquireGlobalMutex("Receiver");

    static Mutex AcquireGlobalMutex(string id, int durationInSeconds = 1)
    {
        var m = new Mutex(true, @"Global\" + id);
        var maxWaitDuration = TimeSpan.FromSeconds(durationInSeconds);
        if (!m.WaitOne(maxWaitDuration)) throw new InvalidOperationException("Failed to acquire mutex.");
        return m;

ramonsmits

public class SendDoSomethingTask : IWantToRunWhenEndpointStartsAndStops
{
    ILog log = LogManager.GetLogger<SendDoSomethingTask>();
    Task loop;
    CancellationTokenSource cancellationTokenSource;

    public Task Start(IMessageSession session)
    {
        cancellationTokenSource = new CancellationTokenSource();
        loop = Task.Run(async () =>

ramonsmits

var uptimeInSeconds = Stopwatch.GetTimestamp() / Stopwatch.Frequency;
var uptime = TimeSpan.FromSeconds(uptimeInSeconds);
Console.WriteLine(uptime);

ramonsmits

using System;
using System.Threading.Tasks;
using NServiceBus.Logging;
using NServiceBus.Pipeline;

/// <code>
/// endpointConfiguration.Pipeline.Register(behavior: new LogDispatchedMessageIdBehavior(), description: LogDispatchedMessageIdBehavior.Description);
/// </code>
class LogDispatchedMessageIdBehavior : Behavior<IBatchDispatchContext>
{

ramonsmits

using System;
using System.Diagnostics;
using System.Linq;

interface IMetrics
{
    void UpdateDuration(Stopwatch value);
}

class MetricsViaPerformanceCounters : IDisposable, IMetrics

ramonsmits

using System;
using NServiceBus;
using NServiceBus.Transport;

class ExponentialBackoffPolicy
{
    static Random random = new Random();

    public static RecoverabilityAction Process(RecoverabilityConfig config, ErrorContext context)
    {