SpliceSubscriberListener.h

Go to the documentation of this file.

#ifndef _SPLICE_SUBSCRIBER_LISTENER_H_
#define _SPLICE_SUBSCRIBER_LISTENER_H_
 
#include <string>
 
#include "madara/knowledge/ThreadSafeContext.h"
#include "madara/transport/Transport.h"
 
#include "ccpp_dds_dcps.h"
#include "madara/transport/splice/ccpp_SpliceKnowledgeUpdate.h"
 
namespace madara
{
namespace transport
{
class SpliceSubscriberListener : public DDS::SubscriberListener
{
public:
  SpliceSubscriberListener(
      const std::string& id, knowledge::ThreadSafeContext& context);
 
  SpliceSubscriberListener(const SpliceSubscriberListener& ref);
 
  ~SpliceSubscriberListener();
 
  void handle_assignment(Knowledge::Update& data);
  void handle_multiassignment(Knowledge::Update& data);
 
public:
  void on_requested_deadline_missed(
      DDS::DataReader_ptr, const DDS::RequestedDeadlineMissedStatus& status);
 
  void on_requested_incompatible_qos(
      DDS::DataReader_ptr, const DDS::RequestedIncompatibleQosStatus& status);
 
  void on_sample_rejected(
      DDS::DataReader_ptr, const DDS::SampleRejectedStatus& status);
 
  void on_liveliness_changed(
      DDS::DataReader_ptr, const DDS::LivelinessChangedStatus& status);
 
  void on_sample_lost(DDS::DataReader_ptr, const DDS::SampleLostStatus& status);
 
  void on_subscription_matched(
      DDS::DataReader_ptr reader, const DDS::SubscriptionMatchedStatus& status);
 
  void on_data_available(DDS::DataReader_ptr reader);
 
  void on_data_on_readers(DDS::Subscriber_ptr sub);
 
private:
  // NDDS variables
  const std::string id_;
  knowledge::ThreadSafeContext& context_;
 
};  // End of class NDDSListener
}
}
 
#endif  // _SPLICE_SUBSCRIBER_LISTENER_H_