move wrapper

Author: timbussmann

src/NServiceBus.AzureFunctions.InProcess.ServiceBus/Serverless/TransportWrapper/SendOnlyReceiver.cs

@@ -0,0 +1,26 @@
+namespace NServiceBus.AzureFunctions.InProcess.ServiceBus
+{
+    using System;
+    using System.Threading;
+    using System.Threading.Tasks;
+    using Transport;
+
+    class SendOnlyReceiver : IMessageReceiver
+    {
+        static readonly InvalidOperationException SendOnlyEndpointException = new($"This endpoint cannot process messages because it is configured in send-only mode. Remove the '{nameof(EndpointConfiguration)}.{nameof(EndpointConfiguration.SendOnly)}' configuration or do not call '{nameof(IFunctionEndpoint)}.{nameof(IFunctionEndpoint.ProcessAtomic)}/{nameof(IFunctionEndpoint.ProcessNonAtomic)}'");
+
+        public Task Initialize(PushRuntimeSettings limitations, OnMessage onMessage, OnError onError,
+            CancellationToken cancellationToken = new CancellationToken()) =>
+            throw SendOnlyEndpointException;
+
+        public Task StartReceive(CancellationToken cancellationToken = new CancellationToken()) => throw SendOnlyEndpointException;
+
+        public Task ChangeConcurrency(PushRuntimeSettings limitations, CancellationToken cancellationToken = new CancellationToken()) => throw SendOnlyEndpointException;
+
+        public Task StopReceive(CancellationToken cancellationToken = new CancellationToken()) => throw SendOnlyEndpointException;
+
+        public ISubscriptionManager Subscriptions => throw SendOnlyEndpointException;
+        public string Id => throw SendOnlyEndpointException;
+        public string ReceiveAddress => throw SendOnlyEndpointException;
+    }
+}

src/NServiceBus.AzureFunctions.InProcess.ServiceBus/Serverless/TransportWrapper/ServerlessTransport.cs

@@ -34,7 +34,7 @@ public override async Task<TransportInfrastructure> Initialize(HostSettings host
 
             PipelineInvoker = receivers.Length > 0
                 ? (PipelineInvoker)serverlessTransportInfrastructure.Receivers[MainReceiverId]
-                : new PipelineInvoker(new NullReceiver()); // send-only endpoint
+                : new PipelineInvoker(new SendOnlyReceiver()); // send-only endpoint
 
             return serverlessTransportInfrastructure;
         }
@@ -57,21 +57,4 @@ public override IReadOnlyCollection<TransportTransactionMode> GetSupportedTransa
             TransportTransactionMode.SendsAtomicWithReceive
         };
     }
-
-    class NullReceiver : IMessageReceiver
-    {
-        public Task Initialize(PushRuntimeSettings limitations, OnMessage onMessage, OnError onError,
-            CancellationToken cancellationToken = new CancellationToken()) =>
-            throw new System.NotImplementedException();
-
-        public Task StartReceive(CancellationToken cancellationToken = new CancellationToken()) => throw new System.NotImplementedException();
-
-        public Task ChangeConcurrency(PushRuntimeSettings limitations, CancellationToken cancellationToken = new CancellationToken()) => throw new System.NotImplementedException();
-
-        public Task StopReceive(CancellationToken cancellationToken = new CancellationToken()) => throw new System.NotImplementedException();
-
-        public ISubscriptionManager Subscriptions { get; }
-        public string Id { get; }
-        public string ReceiveAddress { get; }
-    }
 }