Package kieker.analysis.generic.source.tcp

Class Connection

java.lang.Object
kieker.analysis.generic.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 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 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 Details

    • 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 Details