Skip to content

Instantly share code, notes, and snippets.

🏠
Working from home

Szymon Pobiega SzymonPobiega

🏠
Working from home
Block or report user

Report or block SzymonPobiega

Hide content and notifications from this user.

Learn more about blocking users

Contact Support about this user’s behavior.

Learn more about reporting abuse

Report abuse
View GitHub Profile
View polymorphic-collections.cs
namespace NServiceBus.AcceptanceTests.Sagas
{
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using EndpointTemplates;
using AcceptanceTesting;
using global::NHibernate.Cfg;
using global::NHibernate.Dialect;
View enable-router.cs
var routerConfiguation = new RouterConfiguration("Router");
routerConfiguation.AddInterface<MsmqTransport>("MSMQ", t => {}).DisableMessageDrivenPublishSubscribe();
routerConfiguation.AddInterface<SqlServerTransport>("SQL", t => t.ConnectionString(myConnectionString)).DisableMessageDrivenPublishSubscribe();
routerConfiguation.Chains.AddRule(c => new MetricsPreroutingTerminator("MSMQ", "Particular.Monitoring@some-machine"));
routerConfiguation.UseStaticRoutingProtocol();
var router = Router.Create(routerConfiguation);
await router.Start().ConfigureAwait(false);
View Repro.cs
using System;
using System.Threading.Tasks;
using NServiceBus;
using NServiceBus.Persistence;
namespace Backend
{
class Program
{
static void Main(string[] args)
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();
You can’t perform that action at this time.