ramonsmits

using System;
using System.ComponentModel;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using NServiceBus;
using NServiceBus.Pipeline;

[Description("Create a logger scope for every incoming message with incoming message processing attemps meta data so this is logged with every log statement")]

ramonsmits

Queues used by the various Particular Platform instances

Queue	Error	Audit	Monitoring
audit		CR
error	CR
particular.monitoring			CR
particular.servicecontrol	CR	W
particular.servicecontrol.errors	CW

ramonsmits

Create

sudo btrfs subvolume snapshot / /.snapshots/$(date +%F_%T)

Delete

sudo btrfs subvolume delete /.snapshots/2024-05-19_14:22:31

List

sudo btrfs subvolume list /

ramonsmits

using System;
using Microsoft.Extensions.Hosting;

class UnsubscribeHostedService(IMessageSession messageSession : BackgroundService
{
	protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        await messageSession.Unsubscribe<MyEvent>();
    }
}

ramonsmits

<?xml version="1.0" encoding="utf-8" ?>
<!--
ServiceControl audit trace logging but excluding very chatty loggers which should use Trace/Verbose log level but
that log level is not available in NServiceBus.Logging....

Also uses UTC as time reference

See https://docs.particular.net/servicecontrol/logging#customize-logging
-->
<nlog xmlns="http://www.nlog-project.org/schemas/NLog.xsd" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">

ramonsmits

Steps to run ServiceControl RavenDB external

Install RavenDB Server

1. Download latest 6.x RavenDB Server: https://ravendb.net/download
2. Install as Windows service
3. Open RavenDB Studio http://localhost:8080/studio/index.html
4. Add the RavenLicense.json

Configure instance

ramonsmits

Drive	Storage type	Size (GiB)	Max IOPS	Max throughput (MBps)	Encryption	Host caching
C:	Premium SSD LRS	127	500	100	SSE with PMK	Read/Write
E:	Premium SSD LRS	2048	7500	250	SSE with PMK	Read-only
F:	Premium SSD v2 LRS	2048	3000	125	SSE with PMK	None
G:	Ultra disk LRS	2048	7500	240	SSE with PMK	None

ramonsmits

namespace NServiceBus.Logging;

using System;

public static class LogExtensions
{
    public static void ErrorFormat(this ILog log, Exception exception, string format, params object[] args)
    {
        if (log.IsErrorEnabled)
        {

ramonsmits

using MessagePack;
using MQTTnet;
using MQTTnet.Client;

public static class MqttExtensions
{
    static readonly HashSet<ushort> topicAliases = new();

    /// <summary>
    /// Publish a message pack serialized message with optional topic alias.

ramonsmits

static void DumpHex(byte[] data, int bytesPerLine = 16)
{
    if (data == null) throw new ArgumentNullException(nameof(data));

    var sb = new StringBuilder();
    for (int offset = 0; offset < data.Length; offset += bytesPerLine)
    {
        sb.Clear();
        sb.AppendFormat("{0:X8}  ", offset);