13
0
geforkt von Mirrors/Velocity
Dieser Commit ist enthalten in:
creeper123123321 2020-04-13 11:57:12 -03:00
Ursprung e93a510b0f
Commit 9f6d7c2e82
2 geänderte Dateien mit 5 neuen und 5 gelöschten Zeilen

Datei anzeigen

@ -271,7 +271,7 @@ public class VelocityServer implements ProxyServer {
} }
public ChannelInitializer<Channel> getBackendChannelInitializer() { public ChannelInitializer<Channel> getBackendChannelInitializer() {
return this.cm.backendChannelInitializerHolder.get(); return this.cm.backendChannelInitializer.get();
} }
public boolean isShutdown() { public boolean isShutdown() {

Datei anzeigen

@ -47,7 +47,7 @@ public final class ConnectionManager {
@SuppressWarnings("WeakerAccess") @SuppressWarnings("WeakerAccess")
public final ServerChannelInitializerHolder serverChannelInitializer; public final ServerChannelInitializerHolder serverChannelInitializer;
@SuppressWarnings("WeakerAccess") @SuppressWarnings("WeakerAccess")
public final BackendChannelInitializerHolder backendChannelInitializerHolder; public final BackendChannelInitializerHolder backendChannelInitializer;
private final DnsAddressResolverGroup resolverGroup; private final DnsAddressResolverGroup resolverGroup;
private final AsyncHttpClient httpClient; private final AsyncHttpClient httpClient;
@ -64,7 +64,7 @@ public final class ConnectionManager {
this.workerGroup = this.transportType.createEventLoopGroup(TransportType.Type.WORKER); this.workerGroup = this.transportType.createEventLoopGroup(TransportType.Type.WORKER);
this.serverChannelInitializer = new ServerChannelInitializerHolder( this.serverChannelInitializer = new ServerChannelInitializerHolder(
new ServerChannelInitializer(this.server)); new ServerChannelInitializer(this.server));
this.backendChannelInitializerHolder = new BackendChannelInitializerHolder( this.backendChannelInitializer = new BackendChannelInitializerHolder(
new BackendChannelInitializer(this.server)); new BackendChannelInitializer(this.server));
this.resolverGroup = new DnsAddressResolverGroup(new DnsNameResolverBuilder() this.resolverGroup = new DnsAddressResolverGroup(new DnsNameResolverBuilder()
.channelType(this.transportType.datagramChannelClass) .channelType(this.transportType.datagramChannelClass)
@ -209,7 +209,7 @@ public final class ConnectionManager {
return httpClient; return httpClient;
} }
public BackendChannelInitializerHolder getBackendChannelInitializerHolder() { public BackendChannelInitializerHolder getBackendChannelInitializer() {
return this.backendChannelInitializerHolder; return this.backendChannelInitializer;
} }
} }