|
| Requester () |
|
| Requester (RequesterParams req_params) |
|
ReturnCode_t | send_request (TReq request) |
|
ReturnCode_t | send_request_oneway (TReq request) |
|
bool | receive_reply (Sample< TRep > reply, Duration_t timeout) |
|
bool | receive_reply (Sample< TRep > reply, SampleIdentity_t relatedRequestId) |
|
LoanedSamples< TRep > | receive_replies (Duration_t max_wait) |
|
LoanedSamples< TRep > | receive_replies (int min_count, int max_count, Duration_t max_wait) |
|
bool | wait_for_replies (int min_count, Duration_t max_wait) |
|
bool | wait_for_replies (Duration_t max_wait) |
|
bool | wait_for_replies (int min_count, Duration_t max_wait, SampleIdentity_t related_request_id) |
|
bool | take_reply (Sample< TRep > reply) |
|
bool | take_reply (Sample< TRep > reply, SampleIdentity_t related_request_id) |
|
LoanedSamples< TRep > | take_replies (int max_count) |
|
LoanedSamples< TRep > | take_replies (int max_count, SampleIdentity_t related_request_id) |
|
LoanedSamples< TRep > | take_replies (SampleIdentity_t related_request_id) |
|
bool | read_reply (Sample< TRep > reply) |
|
bool | read_reply (Sample< TRep > reply, SampleIdentity_t related_request_id) |
|
LoanedSamples< TRep > | read_replies (int max_count) |
|
LoanedSamples< TRep > | read_replies (int max_count, SampleIdentity_t related_request_id) |
|
LoanedSamples< TRep > | read_replies (SampleIdentity_t related_request_id) |
|
bool | receive_nondata_samples (bool enable) |
|
RequesterParams | get_requester_params () |
|
DataWriterI< TReq > | get_request_datawriter () |
|
DataReaderI< TRep > | get_reply_datareader () |
|
void | close () |
|
bool | is_null () |
|
void | bind (String i_name) |
|
void | unbind () |
|
bool | is_bound () |
|
String | get_bound_instance_name () |
|
List< String > | get_discovered_service_instances () |
|
ReturnCode_t | wait_for_service () |
|
ReturnCode_t | wait_for_service (Duration_t maxWait) |
|
ReturnCode_t | wait_for_service (String instanceName) |
|
ReturnCode_t | wait_for_service (Duration_t max_wait, String instanceName) |
|
ReturnCode_t | wait_for_services (uint count) |
|
ReturnCode_t | wait_for_services (Duration_t max_wait, uint count) |
|
ReturnCode_t | wait_for_services (List< String > instanceNames) |
|
ReturnCode_t | wait_for_services (Duration_t max_wait, List< String > instanceNames) |
|
A Requester sends requests and receives replies.
An instance of a Requester is configured at the time of construction using RequesterParams, which is a container of configuration parameters, such as domain participant, QoS, listeners and more.
Requester is inherently asynchronous as sending a request and receiving its corresponding reply (or replies) are separated. Requester allows listener-based, polling-based, and future-based reception of replies.
SimpleRequesterListener<TRep> and RequesterListener<TReq, TRep> interfaces enable callback-based notification when a reply is available. On the other hand, Requester provides functions to allow polling reception of replies.
Future-based notification of replies is analogous to callback-based notification, however, no request-reply correlation is necessary because every future represents a reply to a unique request.
A requester reference may be bound to a specific service instance. Requests sent through a bound requester reference shall be sent to the bound service instance only.
- Type Constraints
-
TReq | : | RequestType | |
TReq | : | new() | |
TRep | : | ReplyType | |
TRep | : | new() | |