Go to the documentation of this file.00001
00023 #ifndef GSDFPACKET_LISTENER_H_
00024 #define GSDFPACKET_LISTENER_H_
00025
00026 #include <string>
00027 #include <sstream>
00028 #include <iostream>
00029 #include <boost/function.hpp>
00030 #include <boost/bind.hpp>
00031 #include "ccpp_dds_dcps.h"
00032 #include "check_status.h"
00033 #include "ccpp_GSDFPacket.h"
00034
00035 namespace opensplice_dds_broker{
00036
00037 class GSDFPacketListener: public virtual DDS::DataReaderListener
00038 {
00039 public:
00040 boost::function<void(const GSDFPacket&)> callBack_;
00041
00042 GSDFPacketListener ()
00043 {
00044
00045 }
00046
00047
00048 virtual void on_data_available(DDS::DataReader_ptr reader)
00049 THROW_ORB_EXCEPTIONS;
00050
00051 virtual void on_requested_deadline_missed(DDS::DataReader_ptr reader,
00052 const DDS::RequestedDeadlineMissedStatus &status)THROW_ORB_EXCEPTIONS;
00053
00054 virtual void on_requested_incompatible_qos(DDS::DataReader_ptr reader,
00055 const DDS::RequestedIncompatibleQosStatus &status)THROW_ORB_EXCEPTIONS;
00056
00057 virtual void on_sample_rejected(DDS::DataReader_ptr reader, const DDS
00058 ::SampleRejectedStatus &status)THROW_ORB_EXCEPTIONS;
00059
00060 virtual void on_liveliness_changed(DDS::DataReader_ptr reader, const DDS
00061 ::LivelinessChangedStatus &status)THROW_ORB_EXCEPTIONS;
00062
00063 virtual void on_subscription_matched(DDS::DataReader_ptr reader, const
00064 DDS::SubscriptionMatchedStatus &status)THROW_ORB_EXCEPTIONS;
00065
00066 virtual void on_sample_lost(DDS::DataReader_ptr reader, const DDS
00067 ::SampleLostStatus &status)THROW_ORB_EXCEPTIONS;
00068 };
00069 };
00070 #endif