Package kieker.analysis.generic.source.amqp

Class RegistryRecordHandler

java.lang.Object

kieker.analysis.generic.source.amqp.RegistryRecordHandler

All Implemented Interfaces:

Runnable

public class RegistryRecordHandler
extends Object
implements Runnable

Runnable to handle incoming registry records.

Since:

1.12

Author:

Holger Knoche

Constructor Summary

Constructors

Constructor	Description
RegistryRecordHandler(ReaderRegistry<String> stringRegistry)	Creates a new registry record handler for the given registry.

Method Summary

Modifier and Type	Method	Description
void	enqueueRegistryRecord(ByteBuffer buffer)	Enqueues an unparsed registry record for processing.
void	run()

Methods inherited from class java.lang.Object

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

Constructor Details

RegistryRecordHandler

public RegistryRecordHandler(ReaderRegistry<String> stringRegistry)

Creates a new registry record handler for the given registry.

Parameters:

stringRegistry - The string registry to operate on

Method Details

run

public void run()

Specified by:

run in interface Runnable

enqueueRegistryRecord

public void enqueueRegistryRecord(ByteBuffer buffer)

Enqueues an unparsed registry record for processing.

Parameters:

buffer - The unparsed data in an appropriately positioned byte buffer