Package septogeddon.pluginquery

Class DispatcherQueryConnection

java.lang.Object

septogeddon.pluginquery.DispatcherQueryConnection

All Implemented Interfaces:

QueryConnection

public class DispatcherQueryConnection
extends Object
implements QueryConnection

Constructor Summary

Constructors

Constructor	Description
DispatcherQueryConnection(SocketAddress address, InjectedQueryConnection delegated)

Method Summary

Modifier and Type	Method	Description
QueryFuture<QueryConnection>	connect()	Connect to the remote address
QueryFuture<QueryConnection>	disconnect()	Disconnect the connection.
QueryFuture<Set<QueryConnection>>	fetchActiveConnections()	Get the active connection addresses from the other side of this connection as dispatcher connections, where you can send query directly to the connection without having to redirect it on this connection.
SocketAddress	getAddress()	Get the connection remote address
io.netty.channel.Channel	getChannel()	Get the channel wrapped by this connection
QueryEventBus	getEventBus()	Event Handler
QueryMessenger	getMessenger()	Get the messenger
QueryMetadata	getMetadata()	Metadata Storage
boolean	isConnected()	Check if the connection is connected
boolean	isHandshaken()	Check if both connection already handshaken and ready to use
QueryFuture<QueryConnection>	sendQuery(String channel, byte[] message)	Send query to this connection
QueryFuture<QueryConnection>	sendQuery(String channel, byte[] message, boolean queue)	Send query to this connection

Methods inherited from class java.lang.Object

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

Constructor Details

DispatcherQueryConnection

public DispatcherQueryConnection(SocketAddress address,
 InjectedQueryConnection delegated)

Method Details

getChannel

public io.netty.channel.Channel getChannel()

Description copied from interface: QueryConnection

Get the channel wrapped by this connection

Specified by:

getChannel in interface QueryConnection

Returns:

Netty Channel

getAddress

public SocketAddress getAddress()

Description copied from interface: QueryConnection

Get the connection remote address

Specified by:

getAddress in interface QueryConnection

Returns:

Connection Socket Address

fetchActiveConnections

public QueryFuture<Set<QueryConnection>> fetchActiveConnections()

Description copied from interface: QueryConnection

Get the active connection addresses from the other side of this connection as dispatcher connections, where you can send query directly to the connection without having to redirect it on this connection.

Specified by:

fetchActiveConnections in interface QueryConnection

Returns:

QueryFuture that results a set of active connection addresses

isConnected

public boolean isConnected()

Description copied from interface: QueryConnection

Check if the connection is connected

Specified by:

isConnected in interface QueryConnection

Returns:

true if its connected

isHandshaken

public boolean isHandshaken()

Description copied from interface: QueryConnection

Check if both connection already handshaken and ready to use

Specified by:

isHandshaken in interface QueryConnection

Returns:

true if the connection already send a handshake packet

getMessenger

public QueryMessenger getMessenger()

Description copied from interface: QueryConnection

Get the messenger

Specified by:

getMessenger in interface QueryConnection

Returns:

QueryMessenger instance

connect

public QueryFuture<QueryConnection> connect()

Description copied from interface: QueryConnection

Connect to the remote address

Specified by:

connect in interface QueryConnection

Returns:

QueryFuture for future handling

disconnect

public QueryFuture<QueryConnection> disconnect()

Description copied from interface: QueryConnection

Disconnect the connection. Won't get removed from connection pool, allows you to re-use this connection.

Specified by:

disconnect in interface QueryConnection

Returns:

QueryFuture for future handling

getMetadata

public QueryMetadata getMetadata()

Description copied from interface: QueryConnection

Metadata Storage

Specified by:

getMetadata in interface QueryConnection

Returns:

the storage

getEventBus

public QueryEventBus getEventBus()

Description copied from interface: QueryConnection

Event Handler

Specified by:

getEventBus in interface QueryConnection

Returns:

the event handler

sendQuery

public QueryFuture<QueryConnection> sendQuery(String channel,
 byte[] message)

Description copied from interface: QueryConnection

Send query to this connection

Specified by:

sendQuery in interface QueryConnection

Parameters:

channel -

message -

Returns:

QueryFuture for future handling

sendQuery

public QueryFuture<QueryConnection> sendQuery(String channel,
 byte[] message,
 boolean queue)

Description copied from interface: QueryConnection

Send query to this connection

Specified by:

sendQuery in interface QueryConnection

Parameters:

channel -

message -

queue -

Returns:

QueryFuture for future handling