andreasohlund

    class MessageUpConverter : IBehavior<ReceiveLogicalMessageContext>
    {
        public MessageMetadataRegistry MessageMetadataRegistry { get; set; }

        public void Invoke(ReceiveLogicalMessageContext context, Action next)
        {
            Console.Out.WriteLine("Upconverter invoked");

            var meta = MessageMetadataRegistry.GetMessageDefinition(typeof (V2Message));

andreasohlund

<configuration>
  <config>
    <add key="DependencyVersion" value="HighestMinor" />
  </config>
</configuration>

andreasohlund

using System;
using NServiceBus.Pipeline;
using NServiceBus.Pipeline.Contexts;

namespace TTBRDemo
{
    using NServiceBus;

	class EndpointConfig : IConfigureThisEndpoint, AsA_Server

andreasohlund

namespace MsmqAsyncSpike
{
    using System;
    using System.Messaging;
    using System.Threading;
    using System.Threading.Tasks;

    class Program
    {
        static void Main(string[] args)

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;

andreasohlund

 public class EndpointConfig : AsA_Server, IConfigureThisEndpoint,IWantCustomInitialization
    {
        public void Init()
        {
            Configure.With()
                .Log4Net()
                .UsingContainer<SpringObjectBuilder>()

                
        }

andreasohlund

    public class SSSBMessageForwarder  : IWantToRunAtStartup
    {
        readonly IBus _bus;
        readonly ITransport _transport;

        public SSSBMessageForwarder(IBus bus, ISSSBTransportFactory transportFactory)
        {
            _bus = bus;
            _transport = transportFactory.GetTransport();

andreasohlund

CREATE PROCEDURE [dbo].[SendNServiceBusMessage] 
 @TargetService NVARCHAR(200),
 @MessageName NVARCHAR(200),
 @MessageContent NVARCHAR(4000)
AS

BEGIN

-- Sending a Service Broker Message
DECLARE @InitDlgHandle UNIQUEIDENTIFIER;

andreasohlund

using NServiceBus.ObjectBuilder.Common.Config;
using NServiceBus.ObjectBuilder.Spring;
using Spring.Context.Support;
using NServiceBus;

namespace CoreOnly
{
    class Program
    {
        static void Main(string[] args)

andreasohlund

using System;
using System.Linq.Expressions;
using NServiceBus;
using Rhino.Mocks;
using Rhino.Mocks.Interfaces;
using NSB = NServiceBus;

namespace NullReference.NServiceBus
{
    public static class BusTestExtensions