io.parallec.core.resources

Class TcpUdpSshPingResourceStore

java.lang.Object

io.parallec.core.resources.TcpUdpSshPingResourceStore

public class TcpUdpSshPingResourceStore
extends java.lang.Object

Provide external resources needed for netty based TCP/UDP worker: ChannelFactory and HashedWheelTimer timer

Author:

Yuanteng (Jeff) Pei

Field Summary

Fields

Modifier and Type	Field and Description
private org.jboss.netty.channel.ChannelFactory	channelFactory
private org.jboss.netty.channel.socket.DatagramChannelFactory	datagramChannelFactory
private static TcpUdpSshPingResourceStore	instance The singleton instance.
private java.util.concurrent.ExecutorService	threadPoolForSshPing
private org.jboss.netty.util.HashedWheelTimer	timer

Constructor Summary

Constructors

Modifier	Constructor and Description
private	TcpUdpSshPingResourceStore() Instantiates a new http client store.

Method Summary

Modifier and Type	Method and Description
org.jboss.netty.channel.ChannelFactory	getChannelFactory()
org.jboss.netty.channel.socket.DatagramChannelFactory	getDatagramChannelFactory()
static TcpUdpSshPingResourceStore	getInstance()
java.util.concurrent.ExecutorService	getThreadPoolForSshPing()
org.jboss.netty.util.HashedWheelTimer	getTimer()
void	init() Initialize; cached threadpool is safe as it is releasing resources automatically if idle
void	reinit() close and clean up the http client, then create the new ones.
void	setChannelFactory(org.jboss.netty.channel.ChannelFactory channelFactory)
void	setDatagramChannelFactory(org.jboss.netty.channel.socket.DatagramChannelFactory datagramChannelFactory)
void	setThreadPoolForSshPing(java.util.concurrent.ExecutorService threadPoolForSshPing)
void	setTimer(org.jboss.netty.util.HashedWheelTimer timer)
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

instance

private static final TcpUdpSshPingResourceStore instance

The singleton instance.

channelFactory

private org.jboss.netty.channel.ChannelFactory channelFactory

datagramChannelFactory

private org.jboss.netty.channel.socket.DatagramChannelFactory datagramChannelFactory

timer

private org.jboss.netty.util.HashedWheelTimer timer

threadPoolForSshPing

private java.util.concurrent.ExecutorService threadPoolForSshPing

Constructor Detail

TcpUdpSshPingResourceStore

private TcpUdpSshPingResourceStore()

Instantiates a new http client store.

Method Detail

getInstance

public static TcpUdpSshPingResourceStore getInstance()

shutdown

public void shutdown()

init

public void init()

Initialize; cached threadpool is safe as it is releasing resources automatically if idle

reinit

public void reinit()

close and clean up the http client, then create the new ones.

getChannelFactory

public org.jboss.netty.channel.ChannelFactory getChannelFactory()

setChannelFactory

public void setChannelFactory(org.jboss.netty.channel.ChannelFactory channelFactory)

getTimer

public org.jboss.netty.util.HashedWheelTimer getTimer()

setTimer

public void setTimer(org.jboss.netty.util.HashedWheelTimer timer)

getThreadPoolForSshPing

public java.util.concurrent.ExecutorService getThreadPoolForSshPing()

setThreadPoolForSshPing

public void setThreadPoolForSshPing(java.util.concurrent.ExecutorService threadPoolForSshPing)

getDatagramChannelFactory

public org.jboss.netty.channel.socket.DatagramChannelFactory getDatagramChannelFactory()

setDatagramChannelFactory

public void setDatagramChannelFactory(org.jboss.netty.channel.socket.DatagramChannelFactory datagramChannelFactory)