21 #ifndef __IceStorm_Instrumentation_h__
22 #define __IceStorm_Instrumentation_h__
24 #include <IceUtil/PushDisableWarnings.h>
25 #include <Ice/ProxyF.h>
26 #include <Ice/ObjectF.h>
27 #include <Ice/ValueF.h>
28 #include <Ice/Exception.h>
29 #include <Ice/LocalObject.h>
30 #include <Ice/StreamHelpers.h>
31 #include <Ice/Comparable.h>
32 #include <Ice/Proxy.h>
33 #include <Ice/Object.h>
34 #include <Ice/GCObject.h>
35 #include <Ice/Value.h>
36 #include <Ice/Incoming.h>
37 #include <Ice/FactoryTableInit.h>
38 #include <IceUtil/ScopedArray.h>
39 #include <Ice/Optional.h>
40 #include <Ice/ExceptionHelpers.h>
41 #include <Ice/Instrumentation.h>
42 #include <IceStorm/IceStorm.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;
88 class TopicObserver :
public virtual ::Ice::Instrumentation::Observer
99 class SubscriberObserver :
public virtual ::Ice::Instrumentation::Observer
105 virtual void queued(
int) = 0;
112 class ObserverUpdater
123 class TopicManagerObserver
129 virtual ::std::shared_ptr<::IceStorm::Instrumentation::TopicObserver>
getTopicObserver(const ::std::string&, const ::std::string&, const ::std::shared_ptr<::IceStorm::Instrumentation::TopicObserver>&) = 0;
131 virtual ::std::shared_ptr<::IceStorm::Instrumentation::SubscriberObserver>
getSubscriberObserver(const ::std::string&, const ::std::string&, const ::std::shared_ptr<::Ice::ObjectPrx>&, const ::IceStorm::QoS&, const ::std::shared_ptr<::IceStorm::TopicPrx>&, ::
IceStorm::Instrumentation::SubscriberState, const ::std::shared_ptr<::IceStorm::Instrumentation::SubscriberObserver>&) = 0;
133 virtual void setObserverUpdater(const ::std::shared_ptr<::IceStorm::Instrumentation::ObserverUpdater>&) = 0;
146 static const StreamHelperCategory helper = StreamHelperCategoryEnum;
147 static const int minValue = 0;
148 static const int maxValue = 2;
149 static const int minWireSize = 1;
150 static const bool fixedLength =
false;
170 #else // C++98 mapping
182 typedef ::IceInternal::Handle< ::IceStorm::Instrumentation::TopicObserver>
TopicObserverPtr;
237 return static_cast<const ::Ice::LocalObject&
>(lhs) ==
static_cast<const ::Ice::LocalObject&
>(rhs);
242 return static_cast<const ::Ice::LocalObject&
>(lhs) <
static_cast<const ::Ice::LocalObject&
>(rhs);
262 return static_cast<const ::Ice::LocalObject&
>(lhs) ==
static_cast<const ::Ice::LocalObject&
>(rhs);
267 return static_cast<const ::Ice::LocalObject&
>(lhs) <
static_cast<const ::Ice::LocalObject&
>(rhs);
285 return static_cast<const ::Ice::LocalObject&
>(lhs) ==
static_cast<const ::Ice::LocalObject&
>(rhs);
290 return static_cast<const ::Ice::LocalObject&
>(lhs) <
static_cast<const ::Ice::LocalObject&
>(rhs);
310 return static_cast<const ::Ice::LocalObject&
>(lhs) ==
static_cast<const ::Ice::LocalObject&
>(rhs);
315 return static_cast<const ::Ice::LocalObject&
>(lhs) <
static_cast<const ::Ice::LocalObject&
>(rhs);
328 static const StreamHelperCategory helper = StreamHelperCategoryEnum;
329 static const int minValue = 0;
330 static const int maxValue = 2;
331 static const int minWireSize = 1;
332 static const bool fixedLength =
false;
339 #include <IceUtil/PopDisableWarnings.h>