diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/discovery/zen/publish/PublishClusterStateAction.java b/modules/elasticsearch/src/main/java/org/elasticsearch/discovery/zen/publish/PublishClusterStateAction.java
index 482932b2a91..5a4cae44d6f 100644
--- a/modules/elasticsearch/src/main/java/org/elasticsearch/discovery/zen/publish/PublishClusterStateAction.java
+++ b/modules/elasticsearch/src/main/java/org/elasticsearch/discovery/zen/publish/PublishClusterStateAction.java
@@ -67,11 +67,15 @@ public class PublishClusterStateAction extends AbstractComponent {
                 // no need to send to our self
                 continue;
             }
-            transportService.sendRequest(node, PublishClusterStateRequestHandler.ACTION, new PublishClusterStateRequest(clusterState), new VoidTransportResponseHandler(false) {
-                @Override public void handleException(TransportException exp) {
-                    logger.debug("failed to send cluster state to [{}], should be detected as failed soon...", exp, node);
-                }
-            });
+            transportService.sendRequest(node, PublishClusterStateRequestHandler.ACTION,
+                    new PublishClusterStateRequest(clusterState),
+                    TransportRequestOptions.options().withHighType(),
+
+                    new VoidTransportResponseHandler(false) {
+                        @Override public void handleException(TransportException exp) {
+                            logger.debug("failed to send cluster state to [{}], should be detected as failed soon...", exp, node);
+                        }
+                    });
         }
     }