23#include <fastdds/rtps/common/Guid.h>
24#include <fastdds/rtps/common/Time_t.h>
25#include <fastdds/rtps/common/Locator.h>
26#include <fastrtps/attributes/SubscriberAttributes.h>
27#include <fastrtps/qos/DeadlineMissedStatus.h>
28#include <fastrtps/qos/LivelinessChangedStatus.h>
45 friend class SubscriberImpl;
58 SubscriberImpl* pimpl)
74 const Duration_t one_day{ 24 * 3600, 0 };
75 while (!wait_for_unread_samples(one_day))
87 const Duration_t& timeout);
149 return get_unread_count();
178 rtps::LocatorList_t& locators)
const;
182 SubscriberImpl* mp_impl;
Class SampleInfo_t with information that is provided along a sample when reading data from a Subscrib...
Definition SampleInfo.h:39
Class SubscriberAttributes, used by the user to define the attributes of a Subscriber.
Definition SubscriberAttributes.h:39
Class Subscriber, contains the public API that allows the user to control the reception of messages.
Definition Subscriber.h:44
bool updateAttributes(const SubscriberAttributes &att)
Update the Attributes of the subscriber;.
void get_liveliness_changed_status(LivelinessChangedStatus &status)
Returns the liveliness changed status.
Subscriber(SubscriberImpl *pimpl)
Constructor from a SubscriberImpl pointer.
Definition Subscriber.h:57
bool get_first_untaken_info(SampleInfo_t *info)
Returns information about the first untaken sample.
const rtps::GUID_t & getGuid()
Get the associated GUID.
bool readNextData(void *sample, SampleInfo_t *info)
Reads next unread sample from the Subscriber.
const SubscriberAttributes & getAttributes() const
Get the Attributes of the Subscriber.
uint64_t get_unread_count() const
Get the unread count.
bool isInCleanState() const
Returns there is a clean state with all Publishers.
void get_requested_deadline_missed_status(RequestedDeadlineMissedStatus &status)
Get the requested deadline missed status.
bool wait_for_unread_samples(const Duration_t &timeout)
Blocks the current thread until an unread sample is available.
uint64_t getUnreadCount() const
Get the unread count.
Definition Subscriber.h:147
void get_listening_locators(rtps::LocatorList_t &locators) const
Get the list of locators on which this subscriber is listening.
void waitForUnreadMessage()
Method to block the current thread until an unread message is available.
Definition Subscriber.h:72
bool takeNextData(void *sample, SampleInfo_t *info)
Takes next sample from the Subscriber.
DeadlineMissedStatus RequestedDeadlineMissedStatus
Definition DeadlineMissedStatus.h:30
fastdds::dds::LivelinessChangedStatus LivelinessChangedStatus
Definition LivelinessChangedStatus.h:27
eProsima namespace.
Definition LibrarySettingsAttributes.h:23