public class MessageStructureTopicDataReader
extends com.rti.dds.subscription.DataReaderImpl
Modifier and Type | Method and Description |
---|---|
void |
get_key_value(MessageStructureTopic key_holder,
com.rti.dds.infrastructure.InstanceHandle_t handle) |
com.rti.dds.infrastructure.InstanceHandle_t |
lookup_instance(MessageStructureTopic key_holder) |
void |
read_instance_w_condition(MessageStructureTopicSeq received_data,
com.rti.dds.subscription.SampleInfoSeq info_seq,
int max_samples,
com.rti.dds.infrastructure.InstanceHandle_t a_handle,
com.rti.dds.subscription.ReadCondition condition) |
void |
read_instance(MessageStructureTopicSeq received_data,
com.rti.dds.subscription.SampleInfoSeq info_seq,
int max_samples,
com.rti.dds.infrastructure.InstanceHandle_t a_handle,
int sample_states,
int view_states,
int instance_states) |
void |
read_next_instance_w_condition(MessageStructureTopicSeq received_data,
com.rti.dds.subscription.SampleInfoSeq info_seq,
int max_samples,
com.rti.dds.infrastructure.InstanceHandle_t a_handle,
com.rti.dds.subscription.ReadCondition condition) |
void |
read_next_instance(MessageStructureTopicSeq received_data,
com.rti.dds.subscription.SampleInfoSeq info_seq,
int max_samples,
com.rti.dds.infrastructure.InstanceHandle_t a_handle,
int sample_states,
int view_states,
int instance_states) |
void |
read_next_sample(MessageStructureTopic received_data,
com.rti.dds.subscription.SampleInfo sample_info) |
void |
read_w_condition(MessageStructureTopicSeq received_data,
com.rti.dds.subscription.SampleInfoSeq info_seq,
int max_samples,
com.rti.dds.subscription.ReadCondition condition) |
void |
read(MessageStructureTopicSeq received_data,
com.rti.dds.subscription.SampleInfoSeq info_seq,
int max_samples,
int sample_states,
int view_states,
int instance_states) |
void |
return_loan(MessageStructureTopicSeq received_data,
com.rti.dds.subscription.SampleInfoSeq info_seq) |
void |
take_instance_w_condition(MessageStructureTopicSeq received_data,
com.rti.dds.subscription.SampleInfoSeq info_seq,
int max_samples,
com.rti.dds.infrastructure.InstanceHandle_t a_handle,
com.rti.dds.subscription.ReadCondition condition) |
void |
take_instance(MessageStructureTopicSeq received_data,
com.rti.dds.subscription.SampleInfoSeq info_seq,
int max_samples,
com.rti.dds.infrastructure.InstanceHandle_t a_handle,
int sample_states,
int view_states,
int instance_states) |
void |
take_next_instance_w_condition(MessageStructureTopicSeq received_data,
com.rti.dds.subscription.SampleInfoSeq info_seq,
int max_samples,
com.rti.dds.infrastructure.InstanceHandle_t a_handle,
com.rti.dds.subscription.ReadCondition condition) |
void |
take_next_instance(MessageStructureTopicSeq received_data,
com.rti.dds.subscription.SampleInfoSeq info_seq,
int max_samples,
com.rti.dds.infrastructure.InstanceHandle_t a_handle,
int sample_states,
int view_states,
int instance_states) |
void |
take_next_sample(MessageStructureTopic received_data,
com.rti.dds.subscription.SampleInfo sample_info) |
void |
take_w_condition(MessageStructureTopicSeq received_data,
com.rti.dds.subscription.SampleInfoSeq info_seq,
int max_samples,
com.rti.dds.subscription.ReadCondition condition) |
void |
take(MessageStructureTopicSeq received_data,
com.rti.dds.subscription.SampleInfoSeq info_seq,
int max_samples,
int sample_states,
int view_states,
int instance_states) |
acknowledge_all, acknowledge_all, acknowledge_sample, acknowledge_sample, call_listenerT, create_corelation_index, create_indexcondition, create_querycondition, create_readcondition, delete_contained_entities, delete_index, delete_readcondition, get_datareader_cache_status, get_datareader_protocol_status, get_datareaderI, get_delegate, get_key_hash, get_key_value_untyped, get_listener, get_liveliness_changed_status, get_matched_publication_data, get_matched_publication_datareader_protocol_status, get_matched_publications, get_qos, get_requested_deadline_missed_status, get_requested_incompatible_qos_status, get_sample_lost_status, get_sample_rejected_status, get_subscriber, get_subscription_matched_status, get_topicdescription, lookup_instance_untyped, on_native_entity_finalized, read_instance_untyped, read_instance_w_condition_untyped, read_next_instance_untyped, read_next_instance_w_condition_untyped, read_next_sample_untyped, read_untyped, read_w_condition_untyped, return_loan_untyped, set_datareader_cache_statusT, set_datareader_protocol_statusT, set_last_publication_sequence_number, set_listener, set_liveliness_changed_statusT, set_matched_publication_datareader_protocol_statusT, set_qos_with_profile, set_qos, set_requested_deadline_missed_statusT, set_requested_incompatible_qos_statusT, set_sample_lost_statusT, set_sample_rejected_statusT, set_subscription_matched_statusT, take_instance_untyped, take_instance_w_condition_untyped, take_next_instance_untyped, take_next_instance_w_condition_untyped, take_next_sample_untyped, take_untyped, take_w_condition_untyped, wait_for_historical_data
cleanup, DDS_Entity_lockI, DDS_Entity_unlockI, enable, get_instance_handle, get_status_changes, get_statuscondition, get_untyped_listenerI, get_untyped_qos, lock_native_entityI, lock, set_untyped_listenerI, set_untyped_qos, unlock_native_entityI, unlock
after_delete_native, before_delete_native, check_aliveI, check_aliveI, check_for_zeroI, clear_native_pointer, get_native_pointer, is_alive, is_aliveI
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public void read(MessageStructureTopicSeq received_data, com.rti.dds.subscription.SampleInfoSeq info_seq, int max_samples, int sample_states, int view_states, int instance_states)
public void take(MessageStructureTopicSeq received_data, com.rti.dds.subscription.SampleInfoSeq info_seq, int max_samples, int sample_states, int view_states, int instance_states)
public void read_w_condition(MessageStructureTopicSeq received_data, com.rti.dds.subscription.SampleInfoSeq info_seq, int max_samples, com.rti.dds.subscription.ReadCondition condition)
public void take_w_condition(MessageStructureTopicSeq received_data, com.rti.dds.subscription.SampleInfoSeq info_seq, int max_samples, com.rti.dds.subscription.ReadCondition condition)
public void read_next_sample(MessageStructureTopic received_data, com.rti.dds.subscription.SampleInfo sample_info)
public void take_next_sample(MessageStructureTopic received_data, com.rti.dds.subscription.SampleInfo sample_info)
public void read_instance(MessageStructureTopicSeq received_data, com.rti.dds.subscription.SampleInfoSeq info_seq, int max_samples, com.rti.dds.infrastructure.InstanceHandle_t a_handle, int sample_states, int view_states, int instance_states)
public void take_instance(MessageStructureTopicSeq received_data, com.rti.dds.subscription.SampleInfoSeq info_seq, int max_samples, com.rti.dds.infrastructure.InstanceHandle_t a_handle, int sample_states, int view_states, int instance_states)
public void read_instance_w_condition(MessageStructureTopicSeq received_data, com.rti.dds.subscription.SampleInfoSeq info_seq, int max_samples, com.rti.dds.infrastructure.InstanceHandle_t a_handle, com.rti.dds.subscription.ReadCondition condition)
public void take_instance_w_condition(MessageStructureTopicSeq received_data, com.rti.dds.subscription.SampleInfoSeq info_seq, int max_samples, com.rti.dds.infrastructure.InstanceHandle_t a_handle, com.rti.dds.subscription.ReadCondition condition)
public void read_next_instance(MessageStructureTopicSeq received_data, com.rti.dds.subscription.SampleInfoSeq info_seq, int max_samples, com.rti.dds.infrastructure.InstanceHandle_t a_handle, int sample_states, int view_states, int instance_states)
public void take_next_instance(MessageStructureTopicSeq received_data, com.rti.dds.subscription.SampleInfoSeq info_seq, int max_samples, com.rti.dds.infrastructure.InstanceHandle_t a_handle, int sample_states, int view_states, int instance_states)
public void read_next_instance_w_condition(MessageStructureTopicSeq received_data, com.rti.dds.subscription.SampleInfoSeq info_seq, int max_samples, com.rti.dds.infrastructure.InstanceHandle_t a_handle, com.rti.dds.subscription.ReadCondition condition)
public void take_next_instance_w_condition(MessageStructureTopicSeq received_data, com.rti.dds.subscription.SampleInfoSeq info_seq, int max_samples, com.rti.dds.infrastructure.InstanceHandle_t a_handle, com.rti.dds.subscription.ReadCondition condition)
public void return_loan(MessageStructureTopicSeq received_data, com.rti.dds.subscription.SampleInfoSeq info_seq)
public void get_key_value(MessageStructureTopic key_holder, com.rti.dds.infrastructure.InstanceHandle_t handle)
public com.rti.dds.infrastructure.InstanceHandle_t lookup_instance(MessageStructureTopic key_holder)