kieker.analysis.plugin.reader.amqp
Class RegularRecordHandler

java.lang.Object
  kieker.analysis.plugin.reader.amqp.RegularRecordHandler

All Implemented Interfaces:

java.lang.Runnable

public class RegularRecordHandler
extends java.lang.Object
implements java.lang.Runnable

Runnable to handle incoming regular records.

Since:

1.12

Author:

Holger Knoche

Constructor Summary

RegularRecordHandler(AMQPReader reader, ILookup<java.lang.String> stringRegistry)
Creates a new regular record handler.

Method Summary

void	enqueueRegularRecord(java.nio.ByteBuffer buffer) Enqueues an unparsed regular record for processing.
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

RegularRecordHandler

public RegularRecordHandler(AMQPReader reader,
                            ILookup<java.lang.String> stringRegistry)

Creates a new regular record handler.

Parameters:

reader - The reader to send the instantiated records to

stringRegistry - The string registry to use

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

enqueueRegularRecord

public void enqueueRegularRecord(java.nio.ByteBuffer buffer)

Enqueues an unparsed regular record for processing.

Parameters:

buffer - The unparsed data in an appropriately positioned byte buffer