MADARA  3.4.1
SpliceSubscriberListener.cpp
Go to the documentation of this file.
2 #include "madara/utility/LogMacros.h"
5 
6 #include <iostream>
7 #include <sstream>
8 
11  : id_(id), context_(context)
12 {
13 }
14 
16  const SpliceSubscriberListener& ref)
17  : id_(ref.id_), context_(ref.context_)
18 {
19 }
20 
22 
24  DDS::DataReader_ptr, const DDS::SampleLostStatus& status)
25 {
26 }
27 
29  DDS::DataReader_ptr, const DDS::SampleRejectedStatus& status)
30 {
31 }
32 
34  DDS::DataReader_ptr, const DDS::RequestedIncompatibleQosStatus& status)
35 {
36 }
37 
39  DDS::DataReader_ptr reader,
40  const DDS::RequestedDeadlineMissedStatus& status)
41 {
42 }
43 
45  DDS::DataReader_ptr reader, const DDS::LivelinessChangedStatus& status)
46 {
47 }
48 
50  DDS::DataReader_ptr reader, const DDS::SubscriptionMatchedStatus& status)
51 {
52 }
53 
55  DDS::DataReader_ptr reader)
56 {
57 }
58 
60  DDS::Subscriber_ptr sub)
61 {
62  sub->notify_datareaders();
63 }
const ThreadSafeContext * context_
This class stores variables and their values for use by any entity needing state information in a thr...
Container for subscriber callbacks (deprecated and unused)
void on_requested_incompatible_qos(DDS::DataReader_ptr, const DDS::RequestedIncompatibleQosStatus &status)
DDS callback for incompatible qos.
void on_sample_lost(DDS::DataReader_ptr, const DDS::SampleLostStatus &status)
DDS callback for sample lost.
SpliceSubscriberListener(const std::string &id, knowledge::ThreadSafeContext &context)
void on_sample_rejected(DDS::DataReader_ptr, const DDS::SampleRejectedStatus &status)
DDS callback for sample rejected.
void on_subscription_matched(DDS::DataReader_ptr reader, const DDS::SubscriptionMatchedStatus &status)
DDS callback for subscription matched.
void on_liveliness_changed(DDS::DataReader_ptr, const DDS::LivelinessChangedStatus &status)
DDS callback for sample rejected.
void on_data_on_readers(DDS::Subscriber_ptr sub)
DDS callback for reader status changes (including new data)
void on_data_available(DDS::DataReader_ptr reader)
DDS callback for new data being available.
void on_requested_deadline_missed(DDS::DataReader_ptr, const DDS::RequestedDeadlineMissedStatus &status)
DDS callback for deadline being missed.
constexpr string_t string