de.dytanic.cloudnet.lib.network

Class NetworkConnection

java.lang.Object

de.dytanic.cloudnet.lib.network.NetworkConnection

All Implemented Interfaces:

Nameable, PacketSender, IProtocolSender

public final class NetworkConnection
extends Object
implements PacketSender

Created by Tareko on 22.07.2017.

Field Summary

Fields

Modifier and Type	Field and Description
private io.netty.channel.Channel	channel
private ConnectableAddress	connectableAddress
private long	connectionTrys
private io.netty.channel.EventLoopGroup	eventLoopGroup
private PacketManager	packetManager
private io.netty.handler.ssl.SslContext	sslContext
private Runnable	task

Constructor Summary

Constructors

Constructor and Description
NetworkConnection(ConnectableAddress connectableAddress)
NetworkConnection(ConnectableAddress connectableAddress, Runnable task)

Method Summary

Modifier and Type	Method and Description
io.netty.channel.Channel	getChannel()
ConnectableAddress	getConnectableAddress()
long	getConnectionTrys()
io.netty.channel.EventLoopGroup	getEventLoopGroup()
String	getName()
PacketManager	getPacketManager()
io.netty.handler.ssl.SslContext	getSslContext()
Runnable	getTask()
boolean	isConnected()
void	send(int id, Object element)
void	send(IProtocol iProtocol, Object element)
void	send(Object object)
void	sendAsynchronized(int id, Object element)
void	sendAsynchronized(IProtocol iProtocol, Object element)
void	sendAsynchronized(Object object)
void	sendFile(File file)
void	sendFile(Path path)
void	sendPacket(Packet... packets)
void	sendPacket(Packet packet)
void	sendPacketSynchronized(Packet packet)
void	sendSynchronized(int id, Object element)
void	sendSynchronized(IProtocol iProtocol, Object element)
void	sendSynchronized(Object object)
protected void	setChannel(io.netty.channel.Channel channel)
boolean	tryConnect(boolean ssl, io.netty.channel.SimpleChannelInboundHandler<Packet> default_handler, Auth auth)
boolean	tryConnect(boolean ssl, io.netty.channel.SimpleChannelInboundHandler<Packet> default_handler, Auth auth, Runnable cancelTask)
boolean	tryDisconnect()

Methods inherited from class java.lang.Object

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

Field Detail

packetManager

private final PacketManager packetManager

eventLoopGroup

private final io.netty.channel.EventLoopGroup eventLoopGroup

channel

private io.netty.channel.Channel channel

connectableAddress

private ConnectableAddress connectableAddress

connectionTrys

private long connectionTrys

task

private Runnable task

sslContext

private io.netty.handler.ssl.SslContext sslContext

Constructor Detail

NetworkConnection

public NetworkConnection(ConnectableAddress connectableAddress)

NetworkConnection

public NetworkConnection(ConnectableAddress connectableAddress,
                         Runnable task)

Method Detail

getPacketManager

public PacketManager getPacketManager()

getChannel

public io.netty.channel.Channel getChannel()

setChannel

protected void setChannel(io.netty.channel.Channel channel)

getSslContext

public io.netty.handler.ssl.SslContext getSslContext()

getConnectableAddress

public ConnectableAddress getConnectableAddress()

getEventLoopGroup

public io.netty.channel.EventLoopGroup getEventLoopGroup()

getConnectionTrys

public long getConnectionTrys()

getTask

public Runnable getTask()

getName

public String getName()

Specified by:

getName in interface Nameable

tryConnect

public boolean tryConnect(boolean ssl,
                          io.netty.channel.SimpleChannelInboundHandler<Packet> default_handler,
                          Auth auth)

tryConnect

public boolean tryConnect(boolean ssl,
                          io.netty.channel.SimpleChannelInboundHandler<Packet> default_handler,
                          Auth auth,
                          Runnable cancelTask)

tryDisconnect

public boolean tryDisconnect()

sendFile

public void sendFile(Path path)

send

public void send(Object object)

Specified by:

send in interface IProtocolSender

sendSynchronized

public void sendSynchronized(Object object)

Specified by:

sendSynchronized in interface IProtocolSender

sendAsynchronized

public void sendAsynchronized(Object object)

Specified by:

sendAsynchronized in interface IProtocolSender

send

public void send(IProtocol iProtocol,
                 Object element)

Specified by:

send in interface IProtocolSender

send

public void send(int id,
                 Object element)

Specified by:

send in interface IProtocolSender

sendAsynchronized

public void sendAsynchronized(int id,
                              Object element)

Specified by:

sendAsynchronized in interface IProtocolSender

sendAsynchronized

public void sendAsynchronized(IProtocol iProtocol,
                              Object element)

Specified by:

sendAsynchronized in interface IProtocolSender

sendSynchronized

public void sendSynchronized(int id,
                             Object element)

Specified by:

sendSynchronized in interface IProtocolSender

sendSynchronized

public void sendSynchronized(IProtocol iProtocol,
                             Object element)

Specified by:

sendSynchronized in interface IProtocolSender

sendFile

public void sendFile(File file)

sendPacket

public void sendPacket(Packet... packets)

Specified by:

sendPacket in interface PacketSender

sendPacket

public void sendPacket(Packet packet)

Specified by:

sendPacket in interface PacketSender

sendPacketSynchronized

public void sendPacketSynchronized(Packet packet)

Specified by:

sendPacketSynchronized in interface PacketSender

isConnected

public boolean isConnected()