SubscriberLink handles broadcasting messages to a single subscriber on a single topic. More...
#include <intraprocess_subscriber_link.h>
Public Member Functions | |
| virtual void | drop () |
| virtual void | enqueueMessage (const SerializedMessage &m, bool ser, bool nocopy) |
| Queue up a message for publication. Throws out old messages if we've reached our Publication's max queue size. More... | |
| virtual void | getPublishTypes (bool &ser, bool &nocopy, const std::type_info &ti) |
| virtual std::string | getTransportInfo () |
| virtual std::string | getTransportType () |
| IntraProcessSubscriberLink (const PublicationPtr &parent) | |
| virtual bool | isIntraprocess () |
| bool | isLatching () |
| void | setSubscriber (const IntraProcessPublisherLinkPtr &subscriber) |
| virtual | ~IntraProcessSubscriberLink () |
 Public Member Functions inherited from roswrap::SubscriberLink | |
| int | getConnectionID () const |
| const std::string & | getDataType () |
| const std::string & | getDestinationCallerID () const |
| const std::string & | getMD5Sum () |
| const std::string & | getMessageDefinition () |
| const Stats & | getStats () |
| const std::string & | getTopic () const |
| SubscriberLink () | |
| virtual | ~SubscriberLink () |
Private Attributes | |
| boost::recursive_mutex | drop_mutex_ |
| bool | dropped_ |
| IntraProcessPublisherLinkPtr | subscriber_ |
Additional Inherited Members | |
| Protected Member Functions inherited from roswrap::SubscriberLink | |
| bool | verifyDatatype (const std::string &datatype) |
| Protected Attributes inherited from roswrap::SubscriberLink | |
| unsigned int | connection_id_ |
| std::string | destination_caller_id_ |
| PublicationWPtr | parent_ |
| Stats | stats_ |
| std::string | topic_ |
Detailed Description
SubscriberLink handles broadcasting messages to a single subscriber on a single topic.
Definition at line 45 of file intraprocess_subscriber_link.h.
Constructor & Destructor Documentation
◆ IntraProcessSubscriberLink()
| roswrap::IntraProcessSubscriberLink::IntraProcessSubscriberLink | ( | const PublicationPtr & | parent | ) |
◆ ~IntraProcessSubscriberLink()
|
virtual |
Member Function Documentation
◆ drop()
|
virtual |
Implements roswrap::SubscriberLink.
◆ enqueueMessage()
|
virtual |
Queue up a message for publication. Throws out old messages if we've reached our Publication's max queue size.
Implements roswrap::SubscriberLink.
◆ getPublishTypes()
|
virtual |
Reimplemented from roswrap::SubscriberLink.
◆ getTransportInfo()
|
virtual |
Implements roswrap::SubscriberLink.
◆ getTransportType()
|
virtual |
Implements roswrap::SubscriberLink.
◆ isIntraprocess()
|
inlinevirtual |
Reimplemented from roswrap::SubscriberLink.
Definition at line 58 of file intraprocess_subscriber_link.h.
◆ isLatching()
| bool roswrap::IntraProcessSubscriberLink::isLatching | ( | ) |
◆ setSubscriber()
| void roswrap::IntraProcessSubscriberLink::setSubscriber | ( | const IntraProcessPublisherLinkPtr & | subscriber | ) |
Member Data Documentation
◆ drop_mutex_
|
private |
Definition at line 64 of file intraprocess_subscriber_link.h.
◆ dropped_
|
private |
Definition at line 63 of file intraprocess_subscriber_link.h.
◆ subscriber_
|
private |
Definition at line 62 of file intraprocess_subscriber_link.h.
The documentation for this class was generated from the following file: