Package septogeddon.pluginquery.library.forwarder

Class QueryForwarder

java.lang.Object

septogeddon.pluginquery.library.forwarder.QueryForwarder

All Implemented Interfaces:

QueryListener

public final class QueryForwarder
extends Object
implements QueryListener

Method Summary

Modifier and Type	Method	Description
List<String>	getChannels()
Set<QueryConnection>	getForwardedConnections()
static QueryForwarder	getForwarder(QueryConnection connection)
QueryConnection	getSource()
void	onConnectionStateChange(QueryConnection connection)	Called when QueryConnection.isConnected() value changed
void	onQueryReceived(QueryConnection connection, String channel, byte[] message)	Called when the connection received a query message
void	registerChannel(String channel)
void	registerConnection(Collection<? extends QueryConnection> connections)
void	registerConnection(QueryConnection... connections)
void	unregisterChannel(String channel)
void	unregisterConnection(QueryConnection connection)

Methods inherited from class java.lang.Object

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

Method Details

getForwarder

public static QueryForwarder getForwarder(QueryConnection connection)

getSource

public QueryConnection getSource()

registerChannel

public void registerChannel(String channel)

unregisterChannel

public void unregisterChannel(String channel)

registerConnection

public void registerConnection(Collection<? extends QueryConnection> connections)

registerConnection

public void registerConnection(QueryConnection... connections)

unregisterConnection

public void unregisterConnection(QueryConnection connection)

getForwardedConnections

public Set<QueryConnection> getForwardedConnections()

getChannels

public List<String> getChannels()

onConnectionStateChange

public void onConnectionStateChange(QueryConnection connection)
                             throws Throwable

Description copied from interface: QueryListener

Called when QueryConnection.isConnected() value changed

Specified by:

onConnectionStateChange in interface QueryListener

Parameters:

connection -

Throws:

Throwable - any error that could possibly happen during the event listener execution

onQueryReceived

public void onQueryReceived(QueryConnection connection,
 String channel,
 byte[] message)
                     throws Throwable

Description copied from interface: QueryListener

Called when the connection received a query message

Specified by:

onQueryReceived in interface QueryListener

Parameters:

connection -

channel -

message -

Throws:

Throwable - any error that could possibly happen during the event listener execution