diff --git a/src/main/java/io/mapsmessaging/api/message/Message.java b/src/main/java/io/mapsmessaging/api/message/Message.java
index 3e01cc132..ec01765d8 100644
--- a/src/main/java/io/mapsmessaging/api/message/Message.java
+++ b/src/main/java/io/mapsmessaging/api/message/Message.java
@@ -93,6 +93,10 @@ public class Message implements IdentifierResolver, Storable {
   @Getter
   @Setter
   private boolean lastMessage; // This is set via the engine as it is delivered to the client
+
+  @Getter
+  @Setter
+  private transient String destinationName; // Set by the engine before delivering to an Analyser
   // </editor-fold>
   // <editor-fold desc="Persistent data">
   @Getter
diff --git a/src/main/java/io/mapsmessaging/network/protocol/Protocol.java b/src/main/java/io/mapsmessaging/network/protocol/Protocol.java
index b0fbfdb4e..f75156b7c 100644
--- a/src/main/java/io/mapsmessaging/network/protocol/Protocol.java
+++ b/src/main/java/io/mapsmessaging/network/protocol/Protocol.java
@@ -309,6 +309,7 @@ private ParsedMessage processMessageAnalyser(ParsedMessage parsedMessage, Subscr
     }
     Message msg = parsedMessage.getMessage();
     if(analyser != null){
+      msg.setDestinationName(parsedMessage.getDestinationName());
       msg = analyser.ingest(msg);
       if(msg == null){
         return null;