edu.iris.Fissures.IfRealTimeCollector

Class RealTimeCollectorPOATie

java.lang.Object

org.omg.PortableServer.Servant

edu.iris.Fissures.IfRealTimeCollector.RealTimeCollectorPOA

edu.iris.Fissures.IfRealTimeCollector.RealTimeCollectorPOATie

All Implemented Interfaces:

RealTimeCollectorOperations, org.omg.CORBA.portable.InvokeHandler

public class RealTimeCollectorPOATie
extends RealTimeCollectorPOA

Constructor Summary

Constructors

Constructor and Description
RealTimeCollectorPOATie(RealTimeCollectorOperations delegate)
RealTimeCollectorPOATie(RealTimeCollectorOperations delegate, org.omg.PortableServer.POA poa)

Method Summary

Modifier and Type	Method and Description
org.omg.PortableServer.POA	_default_POA()
RealTimeCollectorOperations	_delegate()
void	_delegate(RealTimeCollectorOperations delegate)
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.

Methods inherited from class edu.iris.Fissures.IfRealTimeCollector.RealTimeCollectorPOA

_all_interfaces, _invoke, _this, _this

Methods inherited from class org.omg.PortableServer.Servant

_get_delegate, _get_interface_def, _is_a, _non_existent, _object_id, _orb, _poa, _set_delegate, _this_object, _this_object

Methods inherited from class java.lang.Object

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

Constructor Detail

RealTimeCollectorPOATie

public RealTimeCollectorPOATie(RealTimeCollectorOperations delegate)

RealTimeCollectorPOATie

public RealTimeCollectorPOATie(RealTimeCollectorOperations delegate,
                               org.omg.PortableServer.POA poa)

Method Detail

_delegate

public RealTimeCollectorOperations _delegate()

_delegate

public void _delegate(RealTimeCollectorOperations delegate)

_default_POA

public org.omg.PortableServer.POA _default_POA()

Overrides:

_default_POA in class org.omg.PortableServer.Servant

configure

public void configure(CollectorConfiguration[] a_configuration)

add_data

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

Description copied from interface: RealTimeCollectorOperations

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

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

Description copied from interface: RealTimeCollectorOperations

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

public RealTimeCollector get_collector()
                                throws NotImplemented

Description copied from interface: RealTimeCollectorOperations

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

public void destroy()

Description copied from interface: RealTimeCollectorOperations

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