| demo.dds.dcps.foosample.FooDataReaderImpl
| FooDataReaderImpl | | public class FooDataReaderImpl extends FooDataReaderPOA (Code) | | DataReader is an abstract class. It must be specialized for each particular application
data-type . The additional methods that must be defined in the auto-generated class for
a hypothetical application type “Foo” .
|
| Method Summary | |
| public boolean | add(Object arg0)
| | public void | clear()
| | public QueryCondition | create_querycondition(int sample_states, int view_states, int instance_states, String query_expression, String[] query_parameters)
| | public ReadCondition | create_readcondition(int sample_states, int view_states, int instance_states)
| | public int | delete_contained_entities()
| | public int | delete_readcondition(ReadCondition a_condition)
| | public int | enable()
| | public DataReaderListener | getA_listener()
| | public DataReaderQos | getQos()
| | public Subscriber | getSubParent()
| | public Vector | getVector_Foo()
| | public int | get_key_value(FooHolder key_holder, int handle)
| | public DataReaderListener | get_listener()
| | public LivelinessChangedStatus | get_liveliness_changed_status()
| | public int | get_matched_publication_data(PublicationBuiltinTopicDataHolder publication_data, int publication_handle)
| | public int | get_matched_publications(InstanceHandleSeqHolder publication_handles)
| | public void | get_qos(DataReaderQosHolder qos)
| | public RequestedDeadlineMissedStatus | get_requested_deadline_missed_status()
| | public RequestedIncompatibleQosStatus | get_requested_incompatible_qos_status()
| | public SampleLostStatus | get_sample_lost_status()
| | public SampleRejectedStatus | get_sample_rejected_status()
| | public int | get_status_changes()
| | public StatusCondition | get_statuscondition()
| | public Subscriber | get_subscriber()
| | public SubscriptionMatchStatus | get_subscription_match_status()
| | public TopicDescription | get_topicdescription()
| | public int | read(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int sample_states, int view_states, int instance_states)
| | public int | read_instance(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int a_handle, int sample_states, int view_states, int instance_states)
| | public int | read_next_instance(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int a_handle, int sample_states, int view_states, int instance_states)
| | public int | read_next_instance_w_condition(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int a_handle, ReadCondition a_condition)
| | public int | read_next_sample(FooHolder received_data, SampleInfoHolder sample_info)
| | public int | read_w_condition(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, ReadCondition a_condition)
| | public boolean | remove(Object arg0)
| | public int | return_loan(FooSeqHolder received_data, SampleInfoSeqHolder info_seq)
| | public int | set_listener(org.omg.dds.DataReaderListener a_listener, int mask)
| | public int | set_qos(DataReaderQos qos)
| | public int | take(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int sample_states, int view_states, int instance_states)
| | public int | take_instance(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int a_handle, int sample_states, int view_states, int instance_states)
| | public void | take_instance_from_subscriber()
| | public int | take_next_instance(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int a_handle, int sample_states, int view_states, int instance_states)
| | public int | take_next_instance_w_condition(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int a_handle, ReadCondition a_condition)
| | public int | take_next_sample(FooHolder received_data, SampleInfoHolder sample_info)
| | public int | take_w_condition(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, ReadCondition a_condition)
| | public int | wait_for_historical_data(Duration_t max_wait)
|
| FooDataReaderImpl | | public FooDataReaderImpl(DataReaderQos qos, DataReaderListener a_listener, Subscriber subParent, Topic topic, org.omg.CORBA.ORB orb, org.omg.PortableServer.POA poa)(Code) | |
Parameters:
qos -
Parameters:
a_listener -
Parameters:
subParent -
Parameters:
topic_name - |
| clear | | public void clear()(Code) | | |
| create_querycondition | | public QueryCondition create_querycondition(int sample_states, int view_states, int instance_states, String query_expression, String[] query_parameters)(Code) | | Not Implemented
|
| create_readcondition | | public ReadCondition create_readcondition(int sample_states, int view_states, int instance_states)(Code) | | Not Implemented
|
| delete_contained_entities | | public int delete_contained_entities()(Code) | | Not Implemented
|
| delete_readcondition | | public int delete_readcondition(ReadCondition a_condition)(Code) | | Not Implemented
|
| enable | | public int enable()(Code) | | Not Implemented
|
| getA_listener | | public DataReaderListener getA_listener()(Code) | | Returns the a_listener. |
| getQos | | public DataReaderQos getQos()(Code) | | Returns the qos. |
| getSubParent | | public Subscriber getSubParent()(Code) | | Returns the subParent. |
| getVector_Foo | | public Vector getVector_Foo()(Code) | | Returns the vector_Foo. |
| get_key_value | | public int get_key_value(FooHolder key_holder, int handle)(Code) | | Not Implemented
|
| get_listener | | public DataReaderListener get_listener()(Code) | | _listener |
| get_liveliness_changed_status | | public LivelinessChangedStatus get_liveliness_changed_status()(Code) | | Not Implemented
|
| get_matched_publication_data | | public int get_matched_publication_data(PublicationBuiltinTopicDataHolder publication_data, int publication_handle)(Code) | | Not Implemented
|
| get_matched_publications | | public int get_matched_publications(InstanceHandleSeqHolder publication_handles)(Code) | | Not Implemented
|
| get_qos | | public void get_qos(DataReaderQosHolder qos)(Code) | | Not Implemented
|
| get_requested_deadline_missed_status | | public RequestedDeadlineMissedStatus get_requested_deadline_missed_status()(Code) | | Not Implemented
|
| get_requested_incompatible_qos_status | | public RequestedIncompatibleQosStatus get_requested_incompatible_qos_status()(Code) | | Not Implemented
|
| get_sample_lost_status | | public SampleLostStatus get_sample_lost_status()(Code) | | Not Implemented
|
| get_sample_rejected_status | | public SampleRejectedStatus get_sample_rejected_status()(Code) | | Not Implemented
|
| get_status_changes | | public int get_status_changes()(Code) | | Not Implemented
|
| get_statuscondition | | public StatusCondition get_statuscondition()(Code) | | Not Implemented
|
| get_subscriber | | public Subscriber get_subscriber()(Code) | | Not Implemented
|
| get_subscription_match_status | | public SubscriptionMatchStatus get_subscription_match_status()(Code) | | Not Implemented
|
| get_topicdescription | | public TopicDescription get_topicdescription()(Code) | | topic |
| read | | public int read(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int sample_states, int view_states, int instance_states)(Code) | |
Parameters:
received_data -
Parameters:
info_seq -
Parameters:
max_samples -
Parameters:
sample_states -
Parameters:
view_states -
Parameters:
instance_states - |
| read_instance | | public int read_instance(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int a_handle, int sample_states, int view_states, int instance_states)(Code) | | Not Implemented
|
| read_next_instance | | public int read_next_instance(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int a_handle, int sample_states, int view_states, int instance_states)(Code) | | Not Implemented
|
| read_next_instance_w_condition | | public int read_next_instance_w_condition(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int a_handle, ReadCondition a_condition)(Code) | | Not Implemented
|
| read_next_sample | | public int read_next_sample(FooHolder received_data, SampleInfoHolder sample_info)(Code) | | Not Implemented
|
| read_w_condition | | public int read_w_condition(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, ReadCondition a_condition)(Code) | | Not Implemented
|
| remove | | public boolean remove(Object arg0)(Code) | |
Parameters:
arg0 - |
| return_loan | | public int return_loan(FooSeqHolder received_data, SampleInfoSeqHolder info_seq)(Code) | | Not Implemented
|
| set_listener | | public int set_listener(org.omg.dds.DataReaderListener a_listener, int mask)(Code) | |
Parameters:
a_listener -
Parameters:
mask - |
| set_qos | | public int set_qos(DataReaderQos qos)(Code) | | Not Implemented
|
| take | | public int take(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int sample_states, int view_states, int instance_states)(Code) | |
Parameters:
received_data -
Parameters:
info_seq -
Parameters:
max_samples -
Parameters:
sample_states -
Parameters:
view_states -
Parameters:
instance_states - |
| take_instance | | public int take_instance(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int a_handle, int sample_states, int view_states, int instance_states)(Code) | | Not Implemented
|
| take_instance_from_subscriber | | public void take_instance_from_subscriber()(Code) | | take instance of Foo from suscriber
|
| take_next_instance | | public int take_next_instance(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int a_handle, int sample_states, int view_states, int instance_states)(Code) | | Not Implemented
|
| take_next_instance_w_condition | | public int take_next_instance_w_condition(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, int a_handle, ReadCondition a_condition)(Code) | | Not Implemented
|
| take_next_sample | | public int take_next_sample(FooHolder received_data, SampleInfoHolder sample_info)(Code) | | Not Implemented
|
| take_w_condition | | public int take_w_condition(FooSeqHolder received_data, SampleInfoSeqHolder info_seq, int max_samples, ReadCondition a_condition)(Code) | | Not Implemented
|
| wait_for_historical_data | | public int wait_for_historical_data(Duration_t max_wait)(Code) | | Not Implemented
|
|
|