connect.facet
Class FacetConsumerChannel

java.lang.Object
  |
  +--org.omg.PortableServer.Servant
        |
        +--edu.wustl.doc.facet.EventComm.PushConsumerPOA
              |
              +--edu.wustl.doc.facet.PushConsumerBase
                    |
                    +--edu.wustl.doc.facet.EventChannelPushConsumer
                          |
                          +--connect.facet.FacetConsumerChannel

All Implemented Interfaces:

ConsumerChannel, InvokeHandler, edu.wustl.doc.facet.EventComm.PushConsumerOperations

public class FacetConsumerChannel

extends edu.wustl.doc.facet.EventChannelPushConsumer

implements ConsumerChannel

Field Summary

private util.Queue

q

Fields inherited from class edu.wustl.doc.facet.EventComm.PushConsumerPOA

Fields inherited from class org.omg.PortableServer.Servant

Constructor Summary

FacetConsumerChannel(int source, int type, edu.wustl.doc.facet.EventChannelAdmin.ProxyPushSupplier pps, POA poa)

Method Summary

void	close() Closes this channel.
void	disconnect_push_supplier()
boolean	isAvailable() Returns true if it is possible at the time of the call to consume additional data from the channel.
void	push(edu.wustl.doc.facet.EventComm.Event e)
Object	readObject() Reads in an Object from the channel.

Methods inherited from class edu.wustl.doc.facet.EventChannelPushConsumer

disconnect_push_consumer, push_vec, push, push, push

Methods inherited from class edu.wustl.doc.facet.EventComm.PushConsumerPOA

_all_interfaces, _invoke, _this, _this

Methods inherited from class org.omg.PortableServer.Servant

_default_POA, _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

Field Detail

q

private util.Queue q

Constructor Detail

FacetConsumerChannel

public FacetConsumerChannel(int source,
                            int type,
                            edu.wustl.doc.facet.EventChannelAdmin.ProxyPushSupplier pps,
                            POA poa)

Method Detail

disconnect_push_supplier

public void disconnect_push_supplier()

push

public void push(edu.wustl.doc.facet.EventComm.Event e)

Specified by:

push in interface edu.wustl.doc.facet.EventComm.PushConsumerOperations

Overrides:

push in class edu.wustl.doc.facet.EventChannelPushConsumer

readObject

public Object readObject()
                  throws IOException,
                         ClassNotFoundException

Description copied from interface: ConsumerChannel

Reads in an Object from the channel. This method blocks until an Object is available.

Specified by:

readObject in interface ConsumerChannel

IOException

ClassNotFoundException

isAvailable

public boolean isAvailable()
                    throws IOException

Description copied from interface: ConsumerChannel

Returns true if it is possible at the time of the call to consume additional data from the channel.

Specified by:

isAvailable in interface ConsumerChannel

IOException

close

public void close()
           throws IOException

Description copied from interface: ConsumerChannel

Closes this channel.

Specified by:

close in interface ConsumerChannel

IOException