kieker.analysisteetime.plugin.reader.amqp

Class RegularRecordHandler

java.lang.Object

kieker.analysisteetime.plugin.reader.amqp.RegularRecordHandler

All Implemented Interfaces:

java.lang.Runnable, IRecordReceivedListener

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

Runnable to handle incoming regular records.

Since:

1.12

Author:

Holger Knoche

Constructor Summary

Constructors

Constructor and Description
RegularRecordHandler(AMQPReader readerLogic, ReaderRegistry<java.lang.String> stringRegistry) Creates a new regular record handler.

Method Summary

Modifier and Type	Method and Description
void	enqueueRegularRecord(java.nio.ByteBuffer buffer) Enqueues an unparsed regular record for processing.
void	onRecordReceived(IMonitoringRecord record)
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 readerLogic,
                            ReaderRegistry<java.lang.String> stringRegistry)

Creates a new regular record handler.

Parameters:

readerLogic - The reader logic class 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

onRecordReceived

public void onRecordReceived(IMonitoringRecord record)

Specified by:

onRecordReceived in interface IRecordReceivedListener