Package kieker.analysis.generic.source.amqp

Class RegularRecordHandler

java.lang.Object

kieker.analysis.generic.source.amqp.RegularRecordHandler

All Implemented Interfaces:

Runnable, IRecordReceivedListener

public class RegularRecordHandler
extends Object
implements Runnable, IRecordReceivedListener

Runnable to handle incoming regular records.

Since:

1.12

Author:

Holger Knoche

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	enqueueRegularRecord(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 Details

RegularRecordHandler

public RegularRecordHandler(AMQPReader readerLogic,
 ReaderRegistry<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 Details

run

public void run()

Specified by:

run in interface Runnable

enqueueRegularRecord

public void enqueueRegularRecord(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

Parameters:

record - record to be processed by the listener