Package septogeddon.pluginquery.library.remote

Class RemoteObjectProvider<T>

java.lang.Object

septogeddon.pluginquery.library.remote.RemoteObjectProvider<T>

Type Parameters:

T -

Direct Known Subclasses:

BungeeRemoteObjectMessenger, SpigotRemoteObjectMessenger, VelocityRemoteObjectMessenger

public class RemoteObjectProvider<T>
extends Object

Provide Object to all active connections

Author:

Thito Yalasatria Sunarya

Constructor Summary

Constructors

Constructor	Description
RemoteObjectProvider(QueryMessenger messenger, String channel, T object)	Initialize RemoteObjectProvider for specified channel and messenger

Method Summary

Modifier and Type	Method	Description
long	getFutureTimeout()	Get future timeout for this provider
QueryMessenger	getMessenger()	Get the messenger
ClassRegistry	getRegistry()	Get the current class registry for this provider
boolean	isQueueQuery()	Get queue option for this provider
protected void	prepare()
void	setExecutorService(ExecutorService service)	Set the ThreadPool handler for this provider
void	setFutureTimeout(long futureTimeout)	Set future timeout for this handler
void	setQueueQuery(boolean queueQuery)	Set whether the query should queue when the connection goes inactive
void	setRegistry(ClassRegistry registry)	Set class registry for this provider.

Methods inherited from class java.lang.Object

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

Constructor Details

RemoteObjectProvider

public RemoteObjectProvider(QueryMessenger messenger,
 String channel,
 T object)

Initialize RemoteObjectProvider for specified channel and messenger

Parameters:

messenger - the messenger

channel - the channel

object - the object

Method Details

getRegistry

public ClassRegistry getRegistry()

Get the current class registry for this provider

Returns:

setRegistry

public void setRegistry(ClassRegistry registry)

Set class registry for this provider.

Parameters:

registry - the class registry

prepare

protected void prepare()

getMessenger

public QueryMessenger getMessenger()

Get the messenger

Returns:

messenger

setExecutorService

public void setExecutorService(ExecutorService service)

Set the ThreadPool handler for this provider

Parameters:

service -

getFutureTimeout

public long getFutureTimeout()

Get future timeout for this provider

Returns:

future timeout time

setFutureTimeout

public void setFutureTimeout(long futureTimeout)

Set future timeout for this handler

Parameters:

futureTimeout -

isQueueQuery

public boolean isQueueQuery()

Get queue option for this provider

Returns:

true if its queue-enabled

setQueueQuery

public void setQueueQuery(boolean queueQuery)

Set whether the query should queue when the connection goes inactive

Parameters:

queueQuery -