kieker.analysis.plugin.reader.amqp
Class RegistryRecordHandler

java.lang.Object
  kieker.analysis.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

Constructor Summary

RegistryRecordHandler(ILookup<java.lang.String> stringRegistry)
Creates a new registry record handler for the given registry.

Method Summary

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(ILookup<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