org.tubo.resource.consumer.serversocket
Class ServerSocketWorker

java.lang.Object
  org.tubo.resource.consumer.serversocket.ServerSocketWorker

All Implemented Interfaces:

java.lang.Runnable

public class ServerSocketWorker
extends java.lang.Object
implements java.lang.Runnable

This class listen for new ServerSocket connections, when a new connection arrives, take a thead from the pool and a consumer and instance a WorkerProcessor for work with the new connection/consumer. Created: Sep 7, 2006, 12:51:43 AM Last Modification Date: $Date: 2006-11-09 02:26:18 -0300 (Thu, 09 Nov 2006) $

Version:

$Revision: 67 $

Author:

maldito_orco (maldito_orco@users.sourceforge.net)

Field Summary

static int	DEFAULT_MAX_CAPACITY
static java.lang.String	RCS_ID
static int	STATE_ERROR
static int	STATE_LOADING
static int	STATE_RUNNING
static int	STATE_STOPED
static int	STATE_UNLOADING

Constructor Summary

ServerSocketWorker(ConsumerManager manager, int port)
TODO

Method Summary

void	run() TODO

Methods inherited from class java.lang.Object

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

Field Detail

RCS_ID

public static final java.lang.String RCS_ID

See Also:

Constant Field Values

STATE_LOADING

public static final int STATE_LOADING

See Also:

Constant Field Values

STATE_RUNNING

public static final int STATE_RUNNING

See Also:

Constant Field Values

STATE_UNLOADING

public static final int STATE_UNLOADING

See Also:

Constant Field Values

STATE_STOPED

public static final int STATE_STOPED

See Also:

Constant Field Values

STATE_ERROR

public static final int STATE_ERROR

See Also:

Constant Field Values

DEFAULT_MAX_CAPACITY

public static final int DEFAULT_MAX_CAPACITY

See Also:

Constant Field Values

Constructor Detail

ServerSocketWorker

public ServerSocketWorker(ConsumerManager manager,
                          int port)
                   throws TuboConsumerLoaderException

TODO

Parameters:

manager -

port -

Throws:

TuboConsumerLoaderException

Method Detail

run

public void run()

TODO

Specified by:

run in interface java.lang.Runnable