View sendlocal.cs
using System; | |
using System.Threading.Tasks; | |
using NServiceBus; | |
namespace AuditSendLocalTest | |
{ | |
class Program | |
{ | |
static void Main(string[] args) | |
{ |
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 | |
{ |
NewerOlder