21#ifndef __IceStorm_Instrumentation_h__
22#define __IceStorm_Instrumentation_h__
24#include <Ice/Comparable.h>
25#include <Ice/Exception.h>
26#include <Ice/ExceptionHelpers.h>
27#include <Ice/FactoryTableInit.h>
28#include <Ice/GCObject.h>
29#include <Ice/Incoming.h>
30#include <Ice/Instrumentation.h>
31#include <Ice/LocalObject.h>
32#include <Ice/Object.h>
33#include <Ice/ObjectF.h>
34#include <Ice/Optional.h>
36#include <Ice/ProxyF.h>
37#include <Ice/StreamHelpers.h>
39#include <Ice/ValueF.h>
40#include <IceStorm/IceStorm.h>
41#include <IceUtil/PushDisableWarnings.h>
42#include <IceUtil/ScopedArray.h>
43#include <IceUtil/UndefSysMacros.h>
45#ifndef ICE_IGNORE_VERSION
46#if ICE_INT_VERSION / 100 != 307
47#error Ice version mismatch!
49#if ICE_INT_VERSION % 100 > 50
50#error Beta header file detected
52#if ICE_INT_VERSION % 100 < 0
53#error Ice patch level mismatch!
57#ifdef ICE_CPP11_MAPPING
84 class TopicObserver :
public virtual ::Ice::Instrumentation::Observer
99 virtual void queued(
int) = 0;
121 virtual ::std::shared_ptr<::IceStorm::Instrumentation::TopicObserver>
123 const ::std::string&,
124 const ::std::shared_ptr<::IceStorm::Instrumentation::TopicObserver>&) = 0;
126 virtual ::std::shared_ptr<::IceStorm::Instrumentation::SubscriberObserver>
128 const ::std::string&,
129 const ::std::string&,
130 const ::std::shared_ptr<::Ice::ObjectPrx>&,
131 const ::IceStorm::QoS&,
132 const ::std::shared_ptr<::IceStorm::TopicPrx>&,
134 const ::std::shared_ptr<::IceStorm::Instrumentation::SubscriberObserver>&) = 0;
137 const ::std::shared_ptr<::IceStorm::Instrumentation::ObserverUpdater>&) = 0;
148 static const StreamHelperCategory helper = StreamHelperCategoryEnum;
149 static const int minValue = 0;
150 static const int maxValue = 2;
151 static const int minWireSize = 1;
152 static const bool fixedLength =
false;
183 typedef ::IceInternal::Handle<::IceStorm::Instrumentation::TopicObserver>
TopicObserverPtr;
187 typedef ::IceInternal::Handle<::IceStorm::Instrumentation::SubscriberObserver>
196 typedef ::IceInternal::Handle<::IceStorm::Instrumentation::TopicManagerObserver>
236 return static_cast<const ::Ice::LocalObject&
>(lhs) ==
237 static_cast<const ::Ice::LocalObject&
>(rhs);
243 return static_cast<const ::Ice::LocalObject&
>(lhs) <
244 static_cast<const ::Ice::LocalObject&
>(rhs);
264 return static_cast<const ::Ice::LocalObject&
>(lhs) ==
265 static_cast<const ::Ice::LocalObject&
>(rhs);
271 return static_cast<const ::Ice::LocalObject&
>(lhs) <
272 static_cast<const ::Ice::LocalObject&
>(rhs);
290 return static_cast<const ::Ice::LocalObject&
>(lhs) ==
291 static_cast<const ::Ice::LocalObject&
>(rhs);
297 return static_cast<const ::Ice::LocalObject&
>(lhs) <
298 static_cast<const ::Ice::LocalObject&
>(rhs);
308 virtual ::IceStorm::Instrumentation::TopicObserverPtr
310 const ::std::string&,
311 const ::IceStorm::Instrumentation::TopicObserverPtr&) = 0;
313 virtual ::IceStorm::Instrumentation::SubscriberObserverPtr
315 const ::std::string&,
316 const ::Ice::ObjectPrx&,
317 const ::IceStorm::QoS&,
318 const ::IceStorm::TopicPrx&,
320 const ::IceStorm::Instrumentation::SubscriberObserverPtr&) = 0;
328 return static_cast<const ::Ice::LocalObject&
>(lhs) ==
329 static_cast<const ::Ice::LocalObject&
>(rhs);
335 return static_cast<const ::Ice::LocalObject&
>(lhs) <
336 static_cast<const ::Ice::LocalObject&
>(rhs);
347 static const StreamHelperCategory
helper = StreamHelperCategoryEnum;
358#include <IceUtil/PopDisableWarnings.h>
The ObserverUpdater interface is implemented by IceStorm and an instance of this interface is provide...
virtual void updateTopicObservers()=0
virtual ~ObserverUpdater()
ObserverUpdaterPtr PointerType
virtual void updateSubscriberObservers()=0
virtual void delivered(::Ice::Int)=0
virtual void outstanding(::Ice::Int)=0
SubscriberObserverPtr PointerType
virtual ~SubscriberObserver()
virtual void queued(::Ice::Int)=0
The topic manager observer interface used by the Ice run-time to obtain and update observers for its ...
virtual ~TopicManagerObserver()
TopicManagerObserverPtr PointerType
virtual::IceStorm::Instrumentation::SubscriberObserverPtr getSubscriberObserver(const ::std::string &, const ::std::string &, const ::Ice::ObjectPrx &, const ::IceStorm::QoS &, const ::IceStorm::TopicPrx &, ::IceStorm::Instrumentation::SubscriberState, const ::IceStorm::Instrumentation::SubscriberObserverPtr &)=0
virtual void setObserverUpdater(const ::IceStorm::Instrumentation::ObserverUpdaterPtr &)=0
virtual::IceStorm::Instrumentation::TopicObserverPtr getTopicObserver(const ::std::string &, const ::std::string &, const ::IceStorm::Instrumentation::TopicObserverPtr &)=0
TopicObserverPtr PointerType
virtual void forwarded()=0
virtual void published()=0
::IceInternal::Handle<::IceStorm::Instrumentation::ObserverUpdater > ObserverUpdaterPtr
bool operator==(const TopicObserver &lhs, const TopicObserver &rhs)
bool operator<(const TopicObserver &lhs, const TopicObserver &rhs)
::IceInternal::Handle<::IceStorm::Instrumentation::SubscriberObserver > SubscriberObserverPtr
::Ice::LocalObject * upCast(::IceStorm::Instrumentation::TopicObserver *)
@ SubscriberStateOnline
Online waiting to send events.
@ SubscriberStateOffline
Offline, retrying.
@ SubscriberStateError
Error state, awaiting to be destroyed.
::IceInternal::Handle<::IceStorm::Instrumentation::TopicManagerObserver > TopicManagerObserverPtr
::IceInternal::Handle<::IceStorm::Instrumentation::TopicObserver > TopicObserverPtr
static const StreamHelperCategory helper
static const int maxValue
static const int minValue
static const bool fixedLength
static const int minWireSize