Skip to content

Instantly share code, notes, and snippets.

Avatar
🏠
Working from home

Szymon Pobiega SzymonPobiega

🏠
Working from home
View GitHub Profile
View MultiTenantSagas.cs
using System;
using System.Linq;
using System.Runtime.CompilerServices;
using System.Threading.Tasks;
using NServiceBus;
using NServiceBus.Features;
using NServiceBus.Pipeline;
using NServiceBus.Sagas;
class Program
View SeparateConnections.cs
using System;
using System.Data.SqlClient;
using System.Threading.Tasks;
using NServiceBus;
using NServiceBus.Persistence.Sql;
class Program
{
static void Main(string[] args)
View sql-transport-deadlock.cs
using System;
using System.Threading;
using System.Threading.Tasks;
using NServiceBus;
using NServiceBus.Satellites;
using NServiceBus.Transports;
using NServiceBus.Transports.SQLServer;
using NServiceBus.Unicast;
using NServiceBus.Unicast.Transport;
View header-mutation-between-retries.cs
using System;
using System.Threading.Tasks;
using NServiceBus;
using NServiceBus.Logging;
using NServiceBus.MessageMutator;
namespace RabbitMutatorTest
{
class Program
{
View ErrorRetryFilter.cs
using System;
using System.Collections.Concurrent;
using System.Threading.Tasks;
using NServiceBus;
using NServiceBus.Raw;
using NServiceBus.Routing;
using NServiceBus.Transport;
enum MessageState
{
View msmq-dlq.cs
using System;
using System.Collections.Generic;
using System.Linq;
using System.Messaging;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
namespace MsmqDeadLetterQueuePoC
{
View Mass send with outbox
using System;
using System.Threading.Tasks;
using NServiceBus;
using NServiceBus.Persistence;
class Program
{
static void Main(string[] args)
{
Start().GetAwaiter().GetResult();
View SagaIndirectReply.cs
using System;
using System.Threading.Tasks;
using NServiceBus;
namespace SagaIndirectReplySample
{
class Program
{
static void Main(string[] args)
{
View SagaConcurrency.cs
using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using NServiceBus;
using NServiceBus.Persistence.Sql;
namespace SqlPersistenceSagaConcurrencyTest
View Program.cs
using System;
using NServiceBus;
using NServiceBus.Features;
using NServiceBus.Settings;
namespace ServiceControlFailureCollapsing
{
class Program
{
static void Main(string[] args)