parent
2382781072
commit
96c280f43d
4
pom.xml
4
pom.xml
|
@ -43,8 +43,8 @@ governing permissions and limitations under the License. -->
|
|||
</parent>
|
||||
|
||||
<properties>
|
||||
<elasticsearch.version>1.0.0</elasticsearch.version>
|
||||
<lucene.version>4.6.1</lucene.version>
|
||||
<elasticsearch.version>1.1.0</elasticsearch.version>
|
||||
<lucene.version>4.7.0</lucene.version>
|
||||
<tests.output>onerror</tests.output>
|
||||
<tests.jvms>1</tests.jvms>
|
||||
<tests.shuffle>true</tests.shuffle>
|
||||
|
|
|
@ -28,6 +28,7 @@ import org.elasticsearch.common.collect.ImmutableList;
|
|||
import org.elasticsearch.common.inject.Inject;
|
||||
import org.elasticsearch.common.network.NetworkService;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.discovery.DiscoverySettings;
|
||||
import org.elasticsearch.discovery.zen.ZenDiscovery;
|
||||
import org.elasticsearch.discovery.zen.ping.ZenPing;
|
||||
import org.elasticsearch.discovery.zen.ping.ZenPingService;
|
||||
|
@ -46,8 +47,10 @@ public class AzureDiscovery extends ZenDiscovery {
|
|||
@Inject
|
||||
public AzureDiscovery(Settings settings, ClusterName clusterName, ThreadPool threadPool, TransportService transportService,
|
||||
ClusterService clusterService, NodeSettingsService nodeSettingsService, ZenPingService pingService,
|
||||
DiscoveryNodeService discoveryNodeService, AzureComputeService azureService, NetworkService networkService) {
|
||||
super(settings, clusterName, threadPool, transportService, clusterService, nodeSettingsService, discoveryNodeService, pingService, Version.CURRENT);
|
||||
DiscoveryNodeService discoveryNodeService, AzureComputeService azureService, NetworkService networkService,
|
||||
DiscoverySettings discoverySettings) {
|
||||
super(settings, clusterName, threadPool, transportService, clusterService, nodeSettingsService,
|
||||
discoveryNodeService, pingService, Version.CURRENT, discoverySettings);
|
||||
if (settings.getAsBoolean("cloud.enabled", true)) {
|
||||
ImmutableList<? extends ZenPing> zenPings = pingService.zenPings();
|
||||
UnicastZenPing unicastZenPing = null;
|
||||
|
|
Loading…
Reference in New Issue