kieker.analysisteetime.plugin.reader.amqp

Class RegistryRecordHandler

java.lang.Object

kieker.analysisteetime.plugin.reader.amqp.RegistryRecordHandler

All Implemented Interfaces:

java.lang.Runnable

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

Runnable to handle incoming registry records.

Since:

1.12

Author:

Holger Knoche

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	enqueueRegistryRecord(java.nio.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 Detail

RegistryRecordHandler

public RegistryRecordHandler(ReaderRegistry<java.lang.String> stringRegistry)

Creates a new registry record handler for the given registry.

Parameters:

stringRegistry - The string registry to operate on

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

enqueueRegistryRecord

public void enqueueRegistryRecord(java.nio.ByteBuffer buffer)

Enqueues an unparsed registry record for processing.

Parameters:

buffer - The unparsed data in an appropriately positioned byte buffer