stream.net

Class TcpSender

java.lang.Object

stream.AbstractProcessor

stream.net.TcpSender

All Implemented Interfaces:

Processor, StatefulProcessor

public class TcpSender
extends AbstractProcessor

Author:

chris

Field Summary

Fields

Modifier and Type	Field and Description
(package private) String	address
(package private) String[]	keys
(package private) static org.slf4j.Logger	log
(package private) PrintStream	out
(package private) int	port
(package private) Socket	socket

Fields inherited from class stream.AbstractProcessor

context

Constructor Summary

Constructors

Constructor and Description
TcpSender()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	connect()
void	finish()
String	getAddress()
String[]	getKeys()
int	getPort()
void	init(ProcessContext ctx)
Data	process(Data input)
void	setAddress(String address)
void	setKeys(String[] keys)
void	setPort(int port)

Methods inherited from class stream.AbstractProcessor

resetState

Methods inherited from class java.lang.Object

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

Field Detail

log

static org.slf4j.Logger log

socket

Socket socket

out

PrintStream out

keys

String[] keys

address

String address

port

int port

Constructor Detail

TcpSender

public TcpSender()

Method Detail

init

public void init(ProcessContext ctx)
          throws Exception

Specified by:

init in interface StatefulProcessor

Overrides:

init in class AbstractProcessor

Throws:

Exception

See Also:

AbstractProcessor.init(stream.ProcessContext)

connect

protected void connect()
                throws Exception

Throws:

Exception

process

public Data process(Data input)

See Also:

Processor.process(stream.Data)

finish

public void finish()
            throws Exception

Specified by:

finish in interface StatefulProcessor

Overrides:

finish in class AbstractProcessor

Throws:

Exception

See Also:

AbstractProcessor.finish()

getAddress

public String getAddress()

Returns:

the address

setAddress

public void setAddress(String address)

Parameters:

address - the address to set

getPort

public int getPort()

Returns:

the port

setPort

public void setPort(int port)

Parameters:

port - the port to set

getKeys

public String[] getKeys()

Returns:

the keys

setKeys

public void setKeys(String[] keys)

Parameters:

keys - the keys to set