logic to create Rabbit MQ Uris for MassTransit

src/Jasper.RabbitMQ.Tests/Internals/RabbitMqEndpointTester.cs → src/Jasper.RabbitMQ.Tests/Internals/RabbitMqEndpointTests.cs

@@ -7,7 +7,7 @@
 
 namespace Jasper.RabbitMQ.Tests.Internals
 {
- public class RabbitMqEndpointTester
+ public class RabbitMqEndpointTests
  {
 
  [Fact]
@@ -179,5 +179,46 @@ public void generate_reply_uri_for_durable()
  }
 
 
+ [Fact]
+ public void map_to_rabbit_mq_uri_with_queue()
+ {
+ var transport = new RabbitMqTransport();
+ transport.ConnectionFactory.HostName = "rabbitserver";
+
+ var endpoint = new RabbitMqEndpoint(transport);
+ endpoint.QueueName = "foo";
+
+ // No virtual host
+
+ endpoint.ToMassTransitUri().ShouldBe("rabbitmq:https://rabbitserver/foo".ToUri());
+
+ // With virtual host
+
+ transport.ConnectionFactory.VirtualHost = "v1";
+
+ endpoint.ToMassTransitUri().ShouldBe("rabbitmq:https://rabbitserver/v1/foo".ToUri());
+ }
+
+ [Fact]
+ public void map_to_rabbit_mq_uri_with_exchange()
+ {
+ var transport = new RabbitMqTransport();
+ transport.ConnectionFactory.HostName = "rabbitserver";
+
+ var endpoint = new RabbitMqEndpoint(transport);
+ endpoint.ExchangeName = "bar";
+
+ // No virtual host
+
+ endpoint.ToMassTransitUri().ShouldBe("rabbitmq:https://rabbitserver/bar".ToUri());
+
+ // With virtual host
+
+ transport.ConnectionFactory.VirtualHost = "v1";
+
+ endpoint.ToMassTransitUri().ShouldBe("rabbitmq:https://rabbitserver/v1/bar".ToUri());
+ }
+
+
  }
 }

src/Jasper.RabbitMQ/Internal/RabbitMqEndpoint.cs

@@ -5,14 +5,15 @@
 using Baseline;
 using Jasper.Configuration;
 using Jasper.Runtime;
+using Jasper.Runtime.Interop.MassTransit;
 using Jasper.Transports;
 using Jasper.Transports.Sending;
 using Jasper.Util;
 using RabbitMQ.Client;
 
 namespace Jasper.RabbitMQ.Internal
 {
- public class RabbitMqEndpoint : TransportEndpoint<IBasicProperties>
+ public class RabbitMqEndpoint : TransportEndpoint<IBasicProperties>, IMassTransitInteropEndpoint
  {
  public const string QueueSegment = "queue";
  public const string ExchangeSegment = "exchange";
@@ -221,5 +222,30 @@ protected override void writeIncomingHeaders(IBasicProperties incoming, Envelope
  envelope.Headers[pair.Key] =
  pair.Value is byte[] b ? Encoding.Default.GetString(b) : pair.Value?.ToString();
  }
+
+ public Uri? ToMassTransitUri()
+ {
+ var segments = new List<string>();
+ var virtualHost = _parent.ConnectionFactory.VirtualHost;
+ if (virtualHost.IsNotEmpty() && virtualHost != "/")
+ {
+ segments.Add(virtualHost);
+ }
+
+ if (QueueName.IsNotEmpty())
+ {
+ segments.Add(QueueName);
+ }
+ else if (ExchangeName.IsNotEmpty())
+ {
+ segments.Add(ExchangeName);
+ }
+ else
+ {
+ return null;
+ }
+
+ return $"rabbitmq:https://{_parent.ConnectionFactory.HostName}/{segments.Join("/")}".ToUri();
+ }
  }
 }

src/Jasper/Runtime/Interop/MassTransit/IMassTransitInteropEndpoint.cs

@@ -0,0 +1,8 @@
+using System;
+
+namespace Jasper.Runtime.Interop.MassTransit;
+
+public interface IMassTransitInteropEndpoint
+{
+ Uri? ToMassTransitUri();
+}