Package org.eso.ias.plugin.publisher.impl

Class FilePublisher

java.lang.Object

org.eso.ias.plugin.publisher.PublisherBase

org.eso.ias.plugin.publisher.BufferedPublisherBase

org.eso.ias.plugin.publisher.impl.BufferedFilePublisherBase

org.eso.ias.plugin.publisher.impl.FilePublisher

All Implemented Interfaces:

MonitorPointSender

public class FilePublisher
extends BufferedFilePublisherBase

A publisher that dumps messages in the passed writer.

This implementation allows to investigate the sending of monitor points to the core of the IAS by looking at the file where they are all dumped.

Author:

acaproni

Nested Class Summary

Nested classes/interfaces inherited from interface org.eso.ias.plugin.publisher.MonitorPointSender

MonitorPointSender.SenderStats

Field Summary

Fields inherited from class org.eso.ias.plugin.publisher.PublisherBase

defaultBufferSize, defaultThrottlingTime, iso8601dateFormat, MAX_BUFFER_SIZE_PROPNAME, maxBufferSize, monitoredSystemId, monitorPoints, monitorPointsSent, numOfErrorsSending, pluginId, publishedMessages, THROTTLING_PROPNAME, throttlingTime

Constructor Summary

Constructors

Constructor	Description
FilePublisher(String pluginId, String monitoredSystemId, ScheduledExecutorService executorSvc, BufferedWriter outWriter)	Constructor

Method Summary

Modifier and Type	Method	Description
protected String	buildString(BufferedMonitoredSystemData data)	Build and return a string representing the data

Methods inherited from class org.eso.ias.plugin.publisher.impl.BufferedFilePublisherBase

publish, shutdown, start

Methods inherited from class org.eso.ias.plugin.publisher.BufferedPublisherBase

publish, sendMonitoredPointsToIas, setUp

Methods inherited from class org.eso.ias.plugin.publisher.PublisherBase

getStats, isClosed, isStopped, mergeProperties, offer, startSending, stopSending, tearDown

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eso.ias.plugin.publisher.MonitorPointSender

getStats, isClosed, isStopped, offer, startSending, stopSending, tearDown

Constructor Details

FilePublisher

public FilePublisher(String pluginId,
 String monitoredSystemId,
 ScheduledExecutorService executorSvc,
 BufferedWriter outWriter)

Constructor

Parameters:

pluginId - The identifier of the plugin

monitoredSystemId - The identifier of the system monitored by the plugin

executorSvc - The executor service

outWriter - The output writer

Method Details

buildString

protected String buildString(BufferedMonitoredSystemData data)
                      throws PublisherException

Build and return a string representing the data

Specified by:

buildString in class BufferedFilePublisherBase

Parameters:

data - The data to be sent to core of the IAS

Returns:

a string representing the data

Throws:

PublisherException - In case of error building the string

See Also:

• BufferedFilePublisherBase.buildString(BufferedMonitoredSystemData)