Go to the documentation of this file.
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>
35 #include <Ice/Proxy.h>
36 #include <Ice/ProxyF.h>
37 #include <Ice/StreamHelpers.h>
38 #include <Ice/Value.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 // C++11 mapping
63 class SubscriberObserver;
64 class ObserverUpdater;
65 class TopicManagerObserver;
84 class TopicObserver :
public virtual ::Ice::Instrumentation::Observer
94 class SubscriberObserver :
public virtual ::Ice::Instrumentation::Observer
99 virtual void queued(
int) = 0;
106 class ObserverUpdater
116 class TopicManagerObserver
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;
171 #else // C++98 mapping
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);
310 const ::std::string&,
315 const ::std::string&,
316 const ::Ice::ObjectPrx&,
317 const ::IceStorm::QoS&,
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;
348 static const int minValue = 0;
349 static const int maxValue = 2;
350 static const int minWireSize = 1;
351 static const bool fixedLength =
false;
358 #include <IceUtil/PopDisableWarnings.h>
::IceInternal::Handle<::IceStorm::Instrumentation::ObserverUpdater > ObserverUpdaterPtr
bool operator<(const TopicObserver &lhs, const TopicObserver &rhs)
::IceInternal::Handle<::IceStorm::Instrumentation::SubscriberObserver > SubscriberObserverPtr
SubscriberObserverPtr PointerType
TopicManagerObserverPtr PointerType
TopicObserverPtr PointerType
virtual ~TopicManagerObserver()
bool operator==(const TopicObserver &lhs, const TopicObserver &rhs)
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
The ObserverUpdater interface is implemented by IceStorm and an instance of this interface is provide...
virtual void updateTopicObservers()=0
virtual void updateSubscriberObservers()=0
virtual ::IceStorm::Instrumentation::TopicObserverPtr getTopicObserver(const ::std::string &, const ::std::string &, const ::IceStorm::Instrumentation::TopicObserverPtr &)=0
virtual void setObserverUpdater(const ::IceStorm::Instrumentation::ObserverUpdaterPtr &)=0
The topic manager observer interface used by the Ice run-time to obtain and update observers for its ...
::IceInternal::ProxyHandle<::IceProxy::IceStorm::Topic > TopicPrx
@ SubscriberStateOffline
Offline, retrying.
::IceInternal::Handle<::IceStorm::Instrumentation::TopicManagerObserver > TopicManagerObserverPtr
::IceInternal::Handle<::IceStorm::Instrumentation::TopicObserver > TopicObserverPtr
virtual void published()=0
::Ice::LocalObject * upCast(::IceStorm::Instrumentation::TopicObserver *)
virtual void delivered(::Ice::Int)=0
ObserverUpdaterPtr PointerType
virtual ~ObserverUpdater()
virtual void queued(::Ice::Int)=0
virtual ~SubscriberObserver()
virtual void forwarded()=0
virtual void outstanding(::Ice::Int)=0
@ SubscriberStateError
Error state, awaiting to be destroyed.
@ SubscriberStateOnline
Online waiting to send events.