diff --git a/provider/indexer-ibm/src/main/java/org/opengroup/osdu/indexer/ibm/publish/PublisherImpl.java b/provider/indexer-ibm/src/main/java/org/opengroup/osdu/indexer/ibm/publish/PublisherImpl.java
index ef3f5a53e70ec0652b174a9a6756ca93141aef0a..ade3b11c4a21832b5fa3aca6ac55780b6c4c45e6 100644
--- a/provider/indexer-ibm/src/main/java/org/opengroup/osdu/indexer/ibm/publish/PublisherImpl.java
+++ b/provider/indexer-ibm/src/main/java/org/opengroup/osdu/indexer/ibm/publish/PublisherImpl.java
@@ -32,6 +32,7 @@ import org.opengroup.osdu.core.ibm.messagebus.IMessageFactory;
 import org.opengroup.osdu.indexer.provider.interfaces.IPublisher;
 import org.springframework.stereotype.Component;
 import org.springframework.web.context.annotation.RequestScope;
+
 import com.google.common.reflect.TypeToken;
 import com.google.gson.Gson;
 import com.google.gson.GsonBuilder;
@@ -47,6 +48,7 @@ public class PublisherImpl implements IPublisher {
     @Inject
     private JaxRsDpsLog logger;
 
+
     @Override
     public void publishStatusChangedTagsToTopic(DpsHeaders headers, JobStatus indexerBatchStatus) throws Exception {
 
@@ -64,7 +66,7 @@ public class PublisherImpl implements IPublisher {
 
         try {
             logger.info("Indexer publishes message " + headers.getCorrelationId());
-            rabbitMQ.sendMessage(message.toString());
+            rabbitMQ.sendMessage("indexer", message.toString());
         }
         catch (Exception e) {
             logger.error(e.getMessage(), e);