Package kieker.common.namedRecordPipe
Class Pipe
java.lang.Object
kieker.common.namedRecordPipe.Pipe
public final class Pipe
extends java.lang.Object
This implementation represents a simple pipe that can be used by readers and writers to transfer monitoring records.
- Since:
- 1.3
- Author:
- Andre van Hoorn
-
Constructor Summary
Constructors Constructor Description Pipe(java.lang.String name)
Creates a new instance of this class using the given parameters. -
Method Summary
Modifier and Type Method Description void
close()
This method closes the pipe and notifies the pipe reader about this event as well.java.lang.String
getName()
Delivers the name of this pipe.void
setPipeReader(IPipeReader pipeReader)
Sets the pipe reader to a new value.boolean
writeMonitoringRecord(IMonitoringRecord monitoringRecord)
Passes the monitoring record to the registered pipe reader.
-
Constructor Details
-
Pipe
public Pipe(java.lang.String name)Creates a new instance of this class using the given parameters.- Parameters:
name
- The name of the pipe.
-
-
Method Details
-
setPipeReader
Sets the pipe reader to a new value. The pipe reader will be informed about new records.- Parameters:
pipeReader
- The new pipe reader.
-
getName
public java.lang.String getName()Delivers the name of this pipe.- Returns:
- The name of the pipe.
-
writeMonitoringRecord
Passes the monitoring record to the registered pipe reader.- Parameters:
monitoringRecord
- The monitoring record to write into the pipe.- Returns:
- true on success; false otherwise.
-
close
public void close()This method closes the pipe and notifies the pipe reader about this event as well.
-