org.agilewiki.jasocket.node

Class Node

java.lang.Object

org.agilewiki.jasocket.node.Node

public class Node
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected AgentChannelManager	agentChannelManager

Constructor Summary

Constructors

Constructor and Description
Node(String[] args, int threadCount)

Method Summary

Methods

Modifier and Type	Method and Description
AgentChannelManager	agentChannelManager()
String[]	args()
int	clusterPort()
protected void	createAgentChannelManager()
JASocketFactories	factory()
Server	initializeServer(Class<Server> serverClass)
org.agilewiki.jactor.MailboxFactory	mailboxFactory()
static void	main(String[] args)
File	nodeDirectory()
protected void	openAgentChannelManager(int clusterPort, Commands commands)
org.apache.sshd.server.PasswordAuthenticator	passwordAuthenticator()
void	process()
protected void	setNodeDirectory()
protected void	startDiscovery()
protected void	startKeepAlive()
void	startup(Class serverClass, String args)

Methods inherited from class java.lang.Object

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

Field Detail

agentChannelManager

protected AgentChannelManager agentChannelManager

Constructor Detail

Node

public Node(String[] args,
    int threadCount)
     throws Exception

Throws:

Exception

Method Detail

args

public String[] args()

mailboxFactory

public org.agilewiki.jactor.MailboxFactory mailboxFactory()

agentChannelManager

public AgentChannelManager agentChannelManager()

nodeDirectory

public File nodeDirectory()

factory

public JASocketFactories factory()
                          throws Exception

Throws:

Exception

clusterPort

public int clusterPort()
                throws Exception

Throws:

Exception

process

public void process()
             throws Exception

Throws:

Exception

initializeServer

public Server initializeServer(Class<Server> serverClass)
                        throws Exception

Throws:

Exception

startup

public void startup(Class serverClass,
           String args)
             throws Exception

Throws:

Exception

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

setNodeDirectory

protected void setNodeDirectory()
                         throws Exception

Throws:

Exception

createAgentChannelManager

protected void createAgentChannelManager()

openAgentChannelManager

protected void openAgentChannelManager(int clusterPort,
                           Commands commands)
                                throws Exception

Throws:

Exception

startDiscovery

protected void startDiscovery()
                       throws Exception

Throws:

Exception

startKeepAlive

protected void startKeepAlive()
                       throws Exception

Throws:

Exception

passwordAuthenticator

public org.apache.sshd.server.PasswordAuthenticator passwordAuthenticator()