Kieker 1.12

kieker.analysis.plugin.reader.amqp
Class RegularRecordHandler

java.lang.Object
  extended by kieker.analysis.plugin.reader.amqp.RegularRecordHandler
All Implemented Interfaces:
java.lang.Runnable

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

Runnable to handle incoming regular records.

Since:
1.12
Author:
Holger Knoche

Constructor Summary
RegularRecordHandler(AMQPReader reader, ILookup<java.lang.String> stringRegistry)
          Creates a new regular record handler.
 
Method Summary
 void enqueueRegularRecord(java.nio.ByteBuffer buffer)
          Enqueues an unparsed regular 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

RegularRecordHandler

public RegularRecordHandler(AMQPReader reader,
                            ILookup<java.lang.String> stringRegistry)
Creates a new regular record handler.

Parameters:
reader - The reader 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

Kieker 1.12

Copyright 2015 Kieker Project, http://kieker-monitoring.net