Package de.dytanic.cloudnet.driver.network.netty.client

Class NettyNetworkClient

java.lang.Object

de.dytanic.cloudnet.driver.network.netty.client.NettyNetworkClient

All Implemented Interfaces:

DefaultNetworkComponent, INetworkClient, IPacketSender, java.lang.AutoCloseable

@Internal
public final class NettyNetworkClient
extends java.lang.Object
implements DefaultNetworkComponent, INetworkClient

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.Collection<INetworkChannel>	channels
protected long	connectedTime
protected io.netty.channel.EventLoopGroup	eventLoopGroup
protected java.util.concurrent.Callable<INetworkChannelHandler>	networkChannelHandler
protected java.util.concurrent.Executor	packetDispatcher
protected IPacketListenerRegistry	packetRegistry
protected SSLConfiguration	sslConfiguration
protected io.netty.handler.ssl.SslContext	sslContext

Constructor Summary

Constructors

Constructor	Description
NettyNetworkClient(java.util.concurrent.Callable<INetworkChannelHandler> networkChannelHandler)
NettyNetworkClient(java.util.concurrent.Callable<INetworkChannelHandler> networkChannelHandler, SSLConfiguration sslConfiguration)
NettyNetworkClient(java.util.concurrent.Callable<INetworkChannelHandler> networkChannelHandler, SSLConfiguration sslConfiguration, de.dytanic.cloudnet.common.concurrent.ITaskScheduler taskScheduler)	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	connect(@NotNull HostAndPort hostAndPort)	Open a new connection to the specific host and port
java.util.Collection<INetworkChannel>	getChannels()
long	getConnectedTime()	Gets the time when this client was connected to the server in milliseconds
default INetworkChannel	getFirstChannel()
java.util.Collection<INetworkChannel>	getModifiableChannels()
java.util.concurrent.Executor	getPacketDispatcher()
IPacketListenerRegistry	getPacketRegistry()
boolean	isSslEnabled()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface de.dytanic.cloudnet.driver.network.DefaultNetworkComponent

closeChannels, sendPacket, sendPacket, sendPacketSync

Methods inherited from interface de.dytanic.cloudnet.driver.network.protocol.IPacketSender

sendPacketSync

Field Detail

packetDispatcher

protected final java.util.concurrent.Executor packetDispatcher

eventLoopGroup

protected final io.netty.channel.EventLoopGroup eventLoopGroup

channels

protected final java.util.Collection<INetworkChannel> channels

packetRegistry

protected final IPacketListenerRegistry packetRegistry

networkChannelHandler

protected final java.util.concurrent.Callable<INetworkChannelHandler> networkChannelHandler

sslConfiguration

protected final SSLConfiguration sslConfiguration

connectedTime

protected long connectedTime

sslContext

protected io.netty.handler.ssl.SslContext sslContext

Constructor Detail

NettyNetworkClient

public NettyNetworkClient(java.util.concurrent.Callable<INetworkChannelHandler> networkChannelHandler)

NettyNetworkClient

public NettyNetworkClient(java.util.concurrent.Callable<INetworkChannelHandler> networkChannelHandler,
                          SSLConfiguration sslConfiguration)

NettyNetworkClient

@Deprecated
@ScheduledForRemoval
public NettyNetworkClient(java.util.concurrent.Callable<INetworkChannelHandler> networkChannelHandler,
                          SSLConfiguration sslConfiguration,
                          de.dytanic.cloudnet.common.concurrent.ITaskScheduler taskScheduler)

Deprecated.

Method Detail

isSslEnabled

public boolean isSslEnabled()

connect

public boolean connect(@NotNull
                       @NotNull HostAndPort hostAndPort)

Description copied from interface: INetworkClient

Open a new connection to the specific host and port

Specified by:

connect in interface INetworkClient

Parameters:

hostAndPort - the address, that should the client connect to

Returns:

true if the connection was success or false if the connection was unsuccessful or refused

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

getChannels

public java.util.Collection<INetworkChannel> getChannels()

getPacketDispatcher

public java.util.concurrent.Executor getPacketDispatcher()

getModifiableChannels

public java.util.Collection<INetworkChannel> getModifiableChannels()

Specified by:

getModifiableChannels in interface DefaultNetworkComponent

getConnectedTime

public long getConnectedTime()

Description copied from interface: INetworkClient

Gets the time when this client was connected to the server in milliseconds

Specified by:

getConnectedTime in interface INetworkClient

getPacketRegistry

public IPacketListenerRegistry getPacketRegistry()

getFirstChannel

public default INetworkChannel getFirstChannel()