org.tubo.resource.consumer.serversocket
Class ServerSocketConsumer

java.lang.Object
  org.tubo.resource.baseimpl.BaseResourceImpl
      org.tubo.resource.consumer.BaseConsumerImpl
          org.tubo.resource.consumer.serversocket.ServerSocketConsumer

All Implemented Interfaces:

Consumer, Resource

Direct Known Subclasses:

EchoConsumer, ServerSocketLineReaderConsumer

public class ServerSocketConsumer
extends BaseConsumerImpl

Created: Sep 4, 2006, 1:33:26 AM Last Modification Date: $Date: 2006-10-26 01:51:28 -0300 (Thu, 26 Oct 2006) $

Version:

$Revision: 39 $

Author:

maldito_orco (maldito_orco@users.sourceforge.net)

Field Summary

static java.lang.String	NEW_CONNECTION_EVENT
static java.lang.String	RCS_ID

Constructor Summary

ServerSocketConsumer()

Method Summary

void	process(java.net.Socket socket) This method is executed from ServerSocketConsumerWorker.

Methods inherited from class org.tubo.resource.consumer.BaseConsumerImpl

createEvent, createFlowContext, createItem, dispatchOriginFlowEvent, doConsumerLifeCycle, initializeEvent, initializeItem, postOriginFlowEvent, preOriginFlowEvent, setListener

Methods inherited from class org.tubo.resource.baseimpl.BaseResourceImpl

getId, getProperties, getProperty, getResourceManager, setId, setProperties, setProperty, setResourceManager

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.tubo.resource.consumer.Consumer

getId

Field Detail

RCS_ID

public static final java.lang.String RCS_ID

See Also:

Constant Field Values

NEW_CONNECTION_EVENT

public static final java.lang.String NEW_CONNECTION_EVENT

See Also:

Constant Field Values

Constructor Detail

ServerSocketConsumer

public ServerSocketConsumer()

Method Detail

process

public void process(java.net.Socket socket)
             throws TuboConsumerException

This method is executed from ServerSocketConsumerWorker. Is used like entry point to consumer. The socket is closed on worker.

Parameters:

socket - A new socket open from client

Throws:

TuboConsumerException