OutputPublisher

org.eso.ias.dasu.publisher.OutputPublisher

The OutputPublisher publishes the output generated by the DASU.

The DASU keeps publishing the output even in case of error.

initialize() must be called before the subscriber is ready to publish events. cleanUp() must be called before terminating with the subscriber to let it release all the acquired resources.

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Members list

Value members

Abstract methods

def cleanUpPublisher(): Try[Unit]

Release all the acquired resources.

Release all the acquired resources.

Attributes

def initializePublisher(): Try[Unit]

Initialize the subscriber.

Initialize the subscriber.

The subscriber is supposed to acquire the resource and do all the initialization to be ready to publish IASValues.

Attributes

Returns

Success or Failure if the initialization went well or encountered a problem

def publish(iasio: IASValue[_]): Try[Unit]

Publish the output.

Publish the output.

Value parameters

iasio

the not null IASIO to publish

Attributes

Returns

a try to let the caller aware of errors publishing