edu.iris.Fissures.IfRealTimeCollector

Interface RealTimeCollectorOperations

All Known Subinterfaces:

RealTimeCollector

All Known Implementing Classes:

_RealTimeCollectorStub, RealTimeCollectorPOA, RealTimeCollectorPOATie

public interface RealTimeCollectorOperations

The real time collector is an interface to accepts raw data from data acquisition system. Implementation of this interface would act as either store and forward proxies or seismogram creation system. Seismogram creation implementation would connect to one or more Seismogram factories and create new seismogram then append data to them. These implementation would have the knowledge of how to partition raw data into seperate seismograms

Method Summary

Modifier and Type	Method and Description
void	add_data(DataChunk[] data) Adds data to the collector.
void	configure(CollectorConfiguration[] a_configuration)
void	destroy() Once all history data is send the Collector is useless.
RealTimeCollector	get_collector() Allows the DAS the send cached data seperate from real time data.
void	reset_sequence(ChannelId[] channels, int[] next_valid) Collector would reset his sequence counter and most likely close the old seismogram and start a new one.

Method Detail

configure

void configure(CollectorConfiguration[] a_configuration)

add_data

void add_data(DataChunk[] data)
       throws UnknownChannels,
              ChunkOutOfOrder

Adds data to the collector. If any exception occurs, the client should assume that no data was successfully sent. It should attempt to correct the errors before resending the data.

Throws:

UnknownChannels

ChunkOutOfOrder

reset_sequence

void reset_sequence(ChannelId[] channels,
                    int[] next_valid)
             throws UnknownChannels

Collector would reset his sequence counter and most likely close the old seismogram and start a new one. Sequences must be the same length.

Throws:

UnknownChannels

get_collector

RealTimeCollector get_collector()
                         throws NotImplemented

Allows the DAS the send cached data seperate from real time data. This allows most recent data to be processed first and older data to be send through a seperate collector. It is the decision of the DAS as to which collector gets the real time data and which gets the older data.

Throws:

NotImplemented

destroy

void destroy()

Once all history data is send the Collector is useless. No more data will be sent through it. It can be destroyed.