Package septogeddon.pluginquery

Class QueryMessengerImpl

java.lang.Object

septogeddon.pluginquery.QueryMessengerImpl

All Implemented Interfaces:

QueryMessenger

public class QueryMessengerImpl
extends Object
implements QueryMessenger

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<QueryConnection>	connections

Constructor Summary

Constructors

Constructor	Description
QueryMessengerImpl()

Method Summary

Modifier and Type	Method	Description
Collection<? extends QueryConnection>	getActiveConnections()	Get all connections (inactive connections aren't included here, they're all goes GC'ed when you stop referring to them)
Class<? extends io.netty.channel.Channel>	getChannelClass()	Netty Channel Class
QueryEventBus	getEventBus()	Event Manager that listen to all connections
io.netty.channel.EventLoopGroup	getEventLoopGroup()	Netty Event Loop Group
QueryMetadata	getMetadata()	Get Messenger metadata
QueryPipeline	getPipeline()	Pipeline for all connections
QueryConnection	injectConnection(io.netty.channel.Channel channel)	Inject served channel to handle query protocols
QueryConnection	newConnection(SocketAddress address)	Prepare new connection using specified address

Methods inherited from class java.lang.Object

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

Methods inherited from interface septogeddon.pluginquery.api.QueryMessenger

broadcastQuery, broadcastQuery

Field Details

connections

protected final List<QueryConnection> connections

Constructor Details

QueryMessengerImpl

public QueryMessengerImpl()

Method Details

newConnection

public QueryConnection newConnection(SocketAddress address)

Description copied from interface: QueryMessenger

Prepare new connection using specified address

Specified by:

newConnection in interface QueryMessenger

Parameters:

address -

Returns:

injectConnection

public QueryConnection injectConnection(io.netty.channel.Channel channel)

Description copied from interface: QueryMessenger

Inject served channel to handle query protocols

Specified by:

injectConnection in interface QueryMessenger

Parameters:

channel -

Returns:

getActiveConnections

public Collection<? extends QueryConnection> getActiveConnections()

Description copied from interface: QueryMessenger

Get all connections (inactive connections aren't included here, they're all goes GC'ed when you stop referring to them)

Specified by:

getActiveConnections in interface QueryMessenger

Returns:

getMetadata

public QueryMetadata getMetadata()

Description copied from interface: QueryMessenger

Get Messenger metadata

Specified by:

getMetadata in interface QueryMessenger

Returns:

getEventBus

public QueryEventBus getEventBus()

Description copied from interface: QueryMessenger

Event Manager that listen to all connections

Specified by:

getEventBus in interface QueryMessenger

Returns:

getPipeline

public QueryPipeline getPipeline()

Description copied from interface: QueryMessenger

Pipeline for all connections

Specified by:

getPipeline in interface QueryMessenger

Returns:

getEventLoopGroup

public io.netty.channel.EventLoopGroup getEventLoopGroup()

Description copied from interface: QueryMessenger

Netty Event Loop Group

Specified by:

getEventLoopGroup in interface QueryMessenger

Returns:

getChannelClass

public Class<? extends io.netty.channel.Channel> getChannelClass()

Description copied from interface: QueryMessenger

Netty Channel Class

Specified by:

getChannelClass in interface QueryMessenger

Returns: