Skip to content

Commit

Permalink
remove connection manager public constructor
Browse files Browse the repository at this point in the history
  • Loading branch information
javanna committed Oct 23, 2018
1 parent e681ef5 commit 0ff7065
Showing 1 changed file with 2 additions and 6 deletions.
Expand Up @@ -18,8 +18,8 @@
*/
package org.elasticsearch.transport;

import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.message.ParameterizedMessage;
import org.elasticsearch.action.ActionListener;
import org.elasticsearch.cluster.node.DiscoveryNode;
Expand Down Expand Up @@ -67,14 +67,10 @@ public class ConnectionManager implements Closeable {
private final DelegatingNodeConnectionListener connectionListener = new DelegatingNodeConnectionListener();

public ConnectionManager(Settings settings, Transport transport, ThreadPool threadPool) {
this(settings, transport, threadPool, buildDefaultConnectionProfile(settings));
}

public ConnectionManager(Settings settings, Transport transport, ThreadPool threadPool, ConnectionProfile defaultProfile) {
this.transport = transport;
this.threadPool = threadPool;
this.pingSchedule = TcpTransport.PING_SCHEDULE.get(settings);
this.defaultProfile = defaultProfile;
this.defaultProfile = buildDefaultConnectionProfile(settings);
this.lifecycle.moveToStarted();

if (pingSchedule.millis() > 0) {
Expand Down

0 comments on commit 0ff7065

Please sign in to comment.