Merge pull request #11 from gamulka/Rebus-ReplyToOriginator-Extension

Add ReplyToOriginator-Extension
evicertia · Sep 23, 2016 · 62ec641 · 62ec641
2 parents 5442751 + 97fb505
commit 62ec641
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/HermaFx.Rebus/RebusExtensions.cs b/HermaFx.Rebus/RebusExtensions.cs
@@ -4,6 +4,7 @@
 using System.Threading.Tasks;
 
 using Rebus;
+using Rebus.Shared;
 
 namespace HermaFx.Rebus
 {
@@ -52,5 +53,16 @@ public static void Reply<TResponse>(this IBus bus, Action<TResponse> customizer)
 
 			bus.Reply(message);
 		}
+
+		public static void ReplyTo<TMessage>(this IBus bus, string originator, string correlationId, TMessage message)
+		{
+			Guard.IsNotNull(bus, nameof(bus));
+			Guard.IsNotNullNorEmpty(originator, nameof(originator));
+			Guard.IsNotNullNorEmpty(correlationId, nameof(correlationId));
+			Guard.IsNotNull(message, nameof(message));
+
+			bus.AttachHeader(message, Headers.CorrelationId, correlationId);
+			bus.Advanced.Routing.Send(originator, message);
+		}
 	}
 }