Package septogeddon.pluginquery

Class PreparedQueryConnection

java.lang.Object

septogeddon.pluginquery.PreparedQueryConnection

All Implemented Interfaces:

QueryConnection

public class PreparedQueryConnection
extends Object
implements QueryConnection

Constructor Summary

Constructors

Constructor	Description
PreparedQueryConnection(QueryMessenger messenger, SocketAddress address)

Method Summary

Modifier and Type	Method	Description
QueryFuture<QueryConnection>	connect()	Connect to the remote address
QueryFuture<QueryConnection>	connect(int currentTime)
protected void	connectionConnected()
protected void	connectionDisconnected()
static io.netty.buffer.ByteBuf	createHandshake(io.netty.buffer.ByteBuf buf, QueryConnection conn)
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.
void	finalize()
void	flushQueue()
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
void	handshake(QueryCompletableFuture<QueryConnection> future, int currentTime)
static void	handshakenConnection(QueryProtocol protocol, io.netty.channel.ChannelPipeline pipeline)
boolean	isConnected()	Check if the connection is connected
boolean	isHandshaken()	Check if both connection already handshaken and ready to use
protected void	prepareChannel()
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
QueryFuture<QueryConnection>	sendQuery(QueryMessage message, boolean queue)

Methods inherited from class java.lang.Object

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

Constructor Details

PreparedQueryConnection

public PreparedQueryConnection(QueryMessenger messenger,
 SocketAddress address)

Method Details

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

handshakenConnection

public static void handshakenConnection(QueryProtocol protocol,
 io.netty.channel.ChannelPipeline pipeline)

createHandshake

public static io.netty.buffer.ByteBuf createHandshake(io.netty.buffer.ByteBuf buf,
 QueryConnection conn)

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

prepareChannel

protected void prepareChannel()

connectionDisconnected

protected void connectionDisconnected()

connectionConnected

protected void connectionConnected()

getMessenger

public QueryMessenger getMessenger()

Description copied from interface: QueryConnection

Get the messenger

Specified by:

getMessenger in interface QueryConnection

Returns:

QueryMessenger instance

handshake

public void handshake(QueryCompletableFuture<QueryConnection> future,
 int currentTime)

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

connect

public QueryFuture<QueryConnection> connect(int currentTime)

flushQueue

public void flushQueue()

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

finalize

public void finalize()

Overrides:

finalize in class Object

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

getAddress

public SocketAddress getAddress()

Description copied from interface: QueryConnection

Get the connection remote address

Specified by:

getAddress in interface QueryConnection

Returns:

Connection Socket Address

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

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(QueryMessage message,
 boolean queue)

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

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