Package septogeddon.pluginquery

Class InjectedQueryConnection

java.lang.Object

septogeddon.pluginquery.InjectedQueryConnection

All Implemented Interfaces:

QueryConnection

public class InjectedQueryConnection
extends Object
implements QueryConnection

Constructor Summary

Constructors

Constructor	Description
InjectedQueryConnection(QueryMessenger messenger, io.netty.channel.Channel channel)

Method Summary

Modifier and Type	Method	Description
QueryFuture<QueryConnection>	connect()	Connect to the remote address
protected void	connectionConnected()
protected void	connectionDisconnected()
void	consumeQueryConnections(List<SocketAddress> addresses)
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	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
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
void	sendQueryMessage(QueryMessage msg, QueryCompletableFuture<QueryConnection> future, boolean queue)

Methods inherited from class java.lang.Object

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

Constructor Details

InjectedQueryConnection

public InjectedQueryConnection(QueryMessenger messenger,
 io.netty.channel.Channel channel)

Method Details

consumeQueryConnections

public void consumeQueryConnections(List<SocketAddress> addresses)

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

connectionDisconnected

protected void connectionDisconnected()

connectionConnected

protected void connectionConnected()

prepareChannel

protected void prepareChannel()

flushQueue

public void flushQueue()

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

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

sendQueryMessage

public void sendQueryMessage(QueryMessage msg,
 QueryCompletableFuture<QueryConnection> future,
 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