it_bus_services/peer_monitor.h

#ifndef _IT_BUS_SERVICES_PEER_MONITOR_H_
#define _IT_BUS_SERVICES_PEER_MONITOR_H_

// @Copyright 2004 IONA Technologies, Plc. All Rights Reserved.
//

#ifndef IT_PMS_SVR_API
#ifdef IT_PMS_SVR_API_EXPORT
#define IT_PMS_SVR_API    IT_DECLSPEC_EXPORT
#else
#define IT_PMS_SVR_API    IT_DECLSPEC_IMPORT
#endif
#endif

#include <orbix_pdk/orb_plugin.hh>
#include <it_bus/types.h>
#ifdef IT_MINIMISE_INCLUDES
#include <it_bus/wsaddressing_xsdTypes.h>
#endif

namespace WS_Addressing
{
    class EndpointReferenceType;
}

namespace IT_Bus_Services
{
    struct PeerMonitorId
    {
        IT_Bus::String base_id;
        IT_Bus::String element_id;
    };

    class IT_PMS_SVR_API PingReceiverCallback
    {
      public:
        virtual ~PingReceiverCallback();

        virtual void
        ping_failure(
            const PeerMonitorId& id
        ) = 0;
    };

    class IT_PMS_SVR_API PeerMonitor : public CORBA::LocalObject
    {
      public:

        virtual PeerMonitorId
        monitor(
            const WS_Addressing::EndpointReferenceType& peer,
            PingReceiverCallback* cb,
            IT_Bus::ULong timeout_msecs
        ) = 0;

        virtual void
        stop_monitor(
            const IT_Bus::String& base_id,
            PingReceiverCallback* callback,
            bool deregister_interest = true
        ) = 0;

        virtual const WS_Addressing::EndpointReferenceType&
        get_epr_reference() = 0;

        virtual bool
        is_local_id(
            const PeerMonitorId& id
        ) = 0;
    };
}

#endif  

---