andreasohlund

• Have explicit dependencies passed in via Initialize
• Should be used for non optional core "things"
• Can provide public api via FeatureSetupContext
• Uses the SettingsHolder to hold onto settings
  • Provided via the ctor
  • Should be exposed as ReadOnlySettings internally
• Can be started and stopped

andreasohlund

var routerConfiguation = new RouterConfiguration("Router");

routerConfiguation.AddInterface<MsmqTransport>("MSMQ").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);

andreasohlund

using System;
using System.Collections.Generic;
using System.IO;
using System.Text;
using System.Threading.Tasks;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using NServiceBus;
using NServiceBus.MessageInterfaces;
using NServiceBus.Serialization;

andreasohlund

Projects ChangesAgents6Build Queue0
Andreas Öhlund  Administration
Run...
Actions 
Edit Configuration Settings  
NServiceBusNServiceBus.Gateway3.1 Test (.NET Framework on Windows)
#3.0.1-PullRequest0099.30 (28 Sep 18 11:20)
Overview

andreasohlund

//this is called to push messages onto ASQ from the browser
sendMessage(queueKey, message) {

        let json = this.orderedJsonStringify(message);
        let encodedMessage = btoa(json);
        let url = this.tokens[queueKey]; //this is the url for the queue including SAS token for auth. This is stored in a JWT token created at login

        this.fetch(url,
            {
                method: 'post',

andreasohlund

 public static async Task<InventoryStatusResponse> GetInventoryStatus(string id)
        {

            var numRetries = 0;
            var siteId = "228202-91B";
            do
            {
                try
                {
                    using (var client = new HttpClient())

andreasohlund

using System;
using MSMQ;

class Program
{
    static void Main(string[] args)
    {
        //add ref to mqoa30.tlb https://stackoverflow.com/a/8258952/236004
        var localMsmq = new MSMQApplication();

andreasohlund

class TimeoutHandlerIssueDetector : Feature
{
    public TimeoutHandlerIssueDetector()
    {
        EnableByDefault();
    }

    protected override void Setup(FeatureConfigurationContext context)
    {
        context.RegisterStartupTask(b => new DetectReusedMessages(b.Build<MessageHandlerRegistry>()));

andreasohlund

The following types are no longer available

NServiceBus.BinarySerializer

No upgrade instructions provided.

NServiceBus.BsonSerializer

No upgrade instructions provided.

NServiceBus.CircuitBreakers.RepeatedFailuresOverTimeCircuitBreaker

No upgrade instructions provided.

andreasohlund

using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Transactions;
using MassTransit.Util;

namespace MsmqAsyncSpike
{
    using System;