kieker.analysis.source.tcp

Class Connection

java.lang.Object

kieker.analysis.source.tcp.Connection

public class Connection
extends java.lang.Object

Represents one connection to read records from.

Since:

1.15

Author:

Reiner Jung

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
java.nio.ByteBuffer	getBuffer()
java.nio.channels.SocketChannel	getChannel()
ReaderRegistry<java.lang.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 Detail

Connection

public Connection(java.nio.channels.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 Detail

getRegistry

public ReaderRegistry<java.lang.String> getRegistry()

getChannel

public java.nio.channels.SocketChannel getChannel()

getBuffer

public java.nio.ByteBuffer getBuffer()

getValueDeserializer

public IValueDeserializer getValueDeserializer()

setError

public void setError(boolean error)

isError

public boolean isError()