acknowledge_all(bool is_positive_acknowledgment=true) | rti::queuing::QueueRequester< TReq, TRep > | inline |
acknowledge_reply(const dds::sub::SampleInfo &sample_info, bool is_positive_acknowledgment=true) | rti::queuing::QueueRequester< TReq, TRep > | inline |
consumer() const | rti::queuing::QueueRequester< TReq, TRep > | inline |
enable() | rti::queuing::QueueRequester< TReq, TRep > | inline |
guid() | rti::queuing::QueueRequester< TReq, TRep > | inline |
has_matching_reply_reader_queue() | rti::queuing::QueueRequester< TReq, TRep > | inline |
has_matching_request_reader_queue() | rti::queuing::QueueRequester< TReq, TRep > | inline |
listener(Listener *the_listener, const dds::core::status::StatusMask &event_mask=dds::core::status::StatusMask::none()) | rti::queuing::QueueRequester< TReq, TRep > | inline |
listener() const | rti::queuing::QueueRequester< TReq, TRep > | inline |
producer() const | rti::queuing::QueueRequester< TReq, TRep > | inline |
QueueRequester(const QueueRequesterParams ¶ms, bool is_enabled=true, Listener *requester_listener=NULL, const rti::core::Guid &requester_guid=rti::core::Guid::unknown()) | rti::queuing::QueueRequester< TReq, TRep > | inlineexplicit |
read_replies() | rti::queuing::QueueRequester< TReq, TRep > | inline |
read_replies(int max_count) | rti::queuing::QueueRequester< TReq, TRep > | inline |
read_replies(const rti::core::SampleIdentity &related_request_id) | rti::queuing::QueueRequester< TReq, TRep > | inline |
reader() const | rti::queuing::QueueRequester< TReq, TRep > | inline |
receive_replies(const dds::core::Duration &max_wait) | rti::queuing::QueueRequester< TReq, TRep > | inline |
receive_replies(int min_count, int max_count, const dds::core::Duration &max_wait) | rti::queuing::QueueRequester< TReq, TRep > | inline |
send_availability(ConsumerAvailabilityParams parameters) | rti::queuing::QueueRequester< TReq, TRep > | inline |
send_request(const TReq &request) | rti::queuing::QueueRequester< TReq, TRep > | inline |
send_request(const TReq &request, rti::pub::WriteParams &write_params) | rti::queuing::QueueRequester< TReq, TRep > | inline |
take_replies() | rti::queuing::QueueRequester< TReq, TRep > | inline |
take_replies(int max_count) | rti::queuing::QueueRequester< TReq, TRep > | inline |
take_replies(int max_count, const rti::core::SampleIdentity &related_request_id) | rti::queuing::QueueRequester< TReq, TRep > | inline |
take_replies(const rti::core::SampleIdentity &related_request_id) | rti::queuing::QueueRequester< TReq, TRep > | inline |
wait_for_acknowledgments(const dds::core::Duration &max_wait) | rti::queuing::QueueRequester< TReq, TRep > | inline |
wait_for_acknowledgments(const rti::core::SampleIdentity &identity, const dds::core::Duration &max_wait) | rti::queuing::QueueRequester< TReq, TRep > | inline |
wait_for_replies(const dds::core::Duration &max_wait) | rti::queuing::QueueRequester< TReq, TRep > | inline |
wait_for_replies(int min_count, const dds::core::Duration &max_wait) | rti::queuing::QueueRequester< TReq, TRep > | inline |
wait_for_replies(int min_count, const dds::core::Duration &max_wait, const rti::core::SampleIdentity &related_request_id) | rti::queuing::QueueRequester< TReq, TRep > | inline |
writer() const | rti::queuing::QueueRequester< TReq, TRep > | inline |