Package kieker.analysis.generic.source.tcp

Class Connection

java.lang.Object

kieker.analysis.generic.source.tcp.Connection

public class Connection
extends Object

Represents one connection to read records from.

Since:

1.15

Author:

Reiner Jung

Constructor Summary

Constructors

Constructor	Description
Connection(SocketChannel channel, int bufferSize)	Create a connection for the given channel and utilizing the specified buffer size.

Method Summary

Modifier and Type	Method	Description
ByteBuffer	getBuffer()
SocketChannel	getChannel()
ReaderRegistry<String>	getRegistry()
IValueDeserializer	getValueDeserializer()
boolean	isError()
void	setError(boolean error)

Methods inherited from class java.lang.Object

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

Constructor Details

Connection

public Connection(SocketChannel channel,
 int bufferSize)

Create a connection for the given channel and utilizing the specified buffer size.

Parameters:

channel - connection channel used to read data

bufferSize - buffer size for reading information

Method Details

getRegistry

public ReaderRegistry<String> getRegistry()

getChannel

public SocketChannel getChannel()

getBuffer

public ByteBuffer getBuffer()

getValueDeserializer

public IValueDeserializer getValueDeserializer()

setError

public void setError(boolean error)

isError

public boolean isError()