use high transport type when sending the cluster state

This commit is contained in:
kimchy 2010-12-27 16:50:55 +02:00
parent ec2f0e05f9
commit d560ceabe4
1 changed files with 9 additions and 5 deletions

View File

@ -67,7 +67,11 @@ public class PublishClusterStateAction extends AbstractComponent {
// no need to send to our self
continue;
}
transportService.sendRequest(node, PublishClusterStateRequestHandler.ACTION, new PublishClusterStateRequest(clusterState), new VoidTransportResponseHandler(false) {
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);
}