FailoverListener.h

Go to the documentation of this file.
00001 /*
00002  *
00003  *
00004  * Distributed under the OpenDDS License.
00005  * See: http://www.opendds.org/license.html
00006  */
00007 
00008 #ifndef FAILOVERLISTENER_T_H
00009 #define FAILOVERLISTENER_T_H
00010 
00011 #include "dds/DdsDcpsSubscriptionExtC.h"
00012 #include "dds/DCPS/Definitions.h"
00013 #include "dds/DCPS/LocalObject.h"
00014 #include "dds/DCPS/Discovery.h"
00015 
00016 #if !defined (ACE_LACKS_PRAGMA_ONCE)
00017 #pragma once
00018 #endif /* ACE_LACKS_PRAGMA_ONCE */
00019 
00020 OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL
00021 
00022 namespace OpenDDS {
00023 namespace DCPS {
00024 
00025 /// @class FailoverListener
00026 class FailoverListener
00027   : public virtual OpenDDS::DCPS::LocalObject<OpenDDS::DCPS::DataReaderListener> {
00028 public:
00029   /// Only construct with a repository key value.
00030   FailoverListener(Discovery::RepoKey key);
00031 
00032   /// Virtual destructor
00033   virtual ~FailoverListener();
00034 
00035   virtual void on_requested_deadline_missed(
00036     DDS::DataReader_ptr reader,
00037     const DDS::RequestedDeadlineMissedStatus & status);
00038 
00039   virtual void on_requested_incompatible_qos(
00040     DDS::DataReader_ptr reader,
00041     const DDS::RequestedIncompatibleQosStatus & status);
00042 
00043   virtual void on_liveliness_changed(
00044     DDS::DataReader_ptr reader,
00045     const DDS::LivelinessChangedStatus & status);
00046 
00047   virtual void on_subscription_matched(
00048     DDS::DataReader_ptr reader,
00049     const DDS::SubscriptionMatchedStatus & status);
00050 
00051   virtual void on_sample_rejected(
00052     DDS::DataReader_ptr reader,
00053     const DDS::SampleRejectedStatus& status);
00054 
00055   virtual void on_data_available(
00056     DDS::DataReader_ptr reader);
00057 
00058   virtual void on_sample_lost(
00059     DDS::DataReader_ptr reader,
00060     const DDS::SampleLostStatus& status);
00061 
00062   virtual void on_subscription_disconnected(
00063     DDS::DataReader_ptr reader,
00064     const OpenDDS::DCPS::SubscriptionDisconnectedStatus& status);
00065 
00066   virtual void on_subscription_reconnected(
00067     DDS::DataReader_ptr reader,
00068     const OpenDDS::DCPS::SubscriptionReconnectedStatus& status);
00069 
00070   virtual void on_subscription_lost(
00071     DDS::DataReader_ptr reader,
00072     const OpenDDS::DCPS::SubscriptionLostStatus& status);
00073 
00074   virtual void on_budget_exceeded(
00075     DDS::DataReader_ptr reader,
00076     const OpenDDS::DCPS::BudgetExceededStatus& status);
00077 
00078 private:
00079   /// Our repository key.  If we trigger, this is the key to the
00080   /// repository that has been lost.
00081   Discovery::RepoKey key_;
00082 };
00083 
00084 } // namespace DCPS
00085 } // namespace OpenDDS
00086 
00087 OPENDDS_END_VERSIONED_NAMESPACE_DECL
00088 
00089 #endif /* FAILOVERLISTENER_T_H  */