| org.jacorb.dds.SubscriberImpl
| SubscriberImpl | | public class SubscriberImpl extends SubscriberPOA (Code) | | A Subscriber is the object responsible for the actual reception of the data resulting
from its subscriptions. A Subscriber acts on the behalf of one or several DataReader
objects that are related to it. When it receives data (from the other parts of the
system), it builds the list of concerned DataReader objects, and then indicates to
the application that data is available, through its listener or by enabling related
conditions. The application can access the list of concerned DataReader objects
through the operation get_datareaders and then access the data available though
operations on the DataReader.
|
| Constructor Summary | |
| public | SubscriberImpl(SubscriberQos qos, SubscriberListener listner, DomainParticipant DP)
|
| SubscriberImpl | | public SubscriberImpl(SubscriberQos qos, SubscriberListener listner, DomainParticipant DP)(Code) | |
Parameters:
qos -
Parameters:
listner -
Parameters:
DP - |
| add | | public boolean add(DataReader DR)(Code) | |
Parameters:
arg0 - |
| begin_access | | public int begin_access()(Code) | | Not Implemented
|
| copy_from_topic_qos | | public int copy_from_topic_qos(DataReaderQosHolder a_datareader_qos, TopicQos a_topic_qos)(Code) | |
Parameters:
a_datareader_qos -
Parameters:
a_topic_qos - |
| create_datareader | | public DataReader create_datareader(TopicDescription a_topic, DataReaderQos qos, DataReaderListener a_listener)(Code) | |
Parameters:
a_topic -
Parameters:
qos -
Parameters:
a_listener - |
| delete_contained_entities | | public int delete_contained_entities()(Code) | | Not Implemented
|
| delete_datareader | | public int delete_datareader(DataReader a_datareader)(Code) | |
Parameters:
a_datareader - |
| enable | | public int enable()(Code) | | Not Implemented
|
| end_access | | public int end_access()(Code) | | Not Implemented
|
| getDP_Parent | | public DomainParticipant getDP_Parent()(Code) | | Returns the dP_Parent. |
| getInstance | | public Object getInstance()(Code) | | Returns the instance. |
| getVector_DataReaders | | public Vector getVector_DataReaders()(Code) | | Returns the vector_DataReaders. |
| get_datareaders | | public int get_datareaders(DataReaderSeqHolder readers, int sample_states, int view_states, int instance_states)(Code) | |
Parameters:
readers -
Parameters:
sample_states -
Parameters:
view_states -
Parameters:
instance_states - |
| get_default_datareader_qos | | public void get_default_datareader_qos(DataReaderQosHolder qos)(Code) | |
Parameters:
qos - |
| get_listener | | public SubscriberListener get_listener()(Code) | | |
| get_participant | | public DomainParticipant get_participant()(Code) | | |
| get_qos | | public void get_qos(SubscriberQosHolder qos)(Code) | |
Parameters:
qos - |
| get_status_changes | | public int get_status_changes()(Code) | | Not Implemented
|
| get_statuscondition | | public StatusCondition get_statuscondition()(Code) | | Not Implemented
|
| isDeletable | | public boolean isDeletable()(Code) | | Not Implemented
|
| lookup_datareader | | public DataReader lookup_datareader(String topic_name)(Code) | |
Parameters:
topic_name - |
| notify_datareaders | | public void notify_datareaders()(Code) | | |
| remove | | public boolean remove(DataReader DR)(Code) | |
Parameters:
arg0 - |
| setInstance | | public void setInstance(Object instance)(Code) | |
Parameters:
instance - The instance to set. |
| set_default_datareader_qos | | public int set_default_datareader_qos(DataReaderQos qos)(Code) | |
Parameters:
qos - |
| set_listener | | public int set_listener(SubscriberListener a_listener, int mask)(Code) | |
Parameters:
a_listener -
Parameters:
mask - |
| set_qos | | public int set_qos(SubscriberQos qos)(Code) | |
Parameters:
qos - |
|
|