16 #ifndef __IceStorm_IceStorm_h__
17 #define __IceStorm_IceStorm_h__
42 #ifndef ICE_IGNORE_VERSION
43 # if ICE_INT_VERSION / 100 != 307
44 # error Ice version mismatch!
46 # if ICE_INT_VERSION % 100 >= 50
47 # error Beta header file detected
49 # if ICE_INT_VERSION % 100 < 10
50 # error Ice patch level mismatch!
55 # if defined(ICE_STATIC_LIBS)
57 # elif defined(ICESTORM_API_EXPORTS)
58 # define ICESTORM_API ICE_DECLSPEC_EXPORT
60 # define ICESTORM_API ICE_DECLSPEC_IMPORT
64 #ifdef ICE_CPP11_MAPPING // C++11 mapping
90 ::std::shared_ptr<::IceStorm::TopicPrx>
theTopic;
104 std::tuple<const ::std::shared_ptr<::IceStorm::TopicPrx>&, const ::std::string&,
const int&>
ice_tuple()
const
119 using QoS = ::std::map<::std::string, ::std::string>;
151 return std::tie(name);
200 return std::tie(name);
276 return std::tie(reason);
321 return std::tie(reason);
339 using TopicDict = ::std::map<::std::string, ::std::shared_ptr<TopicPrx>>;
371 return std::tie(name);
416 return std::tie(name);
431 using Ice::operator<;
432 using Ice::operator<=;
433 using Ice::operator>;
434 using Ice::operator>=;
435 using Ice::operator==;
436 using Ice::operator!=;
461 virtual bool ice_isA(::std::string
id, const ::Ice::Current& current)
const override;
468 virtual ::std::vector<::std::string>
ice_ids(const ::Ice::Current& current)
const override;
475 virtual ::std::string
ice_id(const ::Ice::Current& current)
const override;
489 virtual ::std::string
getName(const ::Ice::Current& current)
const = 0;
491 bool _iceD_getName(::IceInternal::Incoming&, const ::Ice::Current&)
const;
503 virtual ::std::shared_ptr<::Ice::ObjectPrx>
getPublisher(const ::Ice::Current& current)
const = 0;
505 bool _iceD_getPublisher(::IceInternal::Incoming&, const ::Ice::Current&)
const;
518 bool _iceD_getNonReplicatedPublisher(::IceInternal::Incoming&, const ::Ice::Current&)
const;
536 virtual ::std::shared_ptr<::Ice::ObjectPrx>
subscribeAndGetPublisher(
QoS theQoS, ::std::shared_ptr<::Ice::ObjectPrx> subscriber, const ::Ice::Current& current) = 0;
538 bool _iceD_subscribeAndGetPublisher(::IceInternal::Incoming&, const ::Ice::Current&);
547 virtual void unsubscribe(::std::shared_ptr<::Ice::ObjectPrx> subscriber, const ::Ice::Current& current) = 0;
549 bool _iceD_unsubscribe(::IceInternal::Incoming&, const ::Ice::Current&);
561 virtual void link(::std::shared_ptr<TopicPrx> linkTo,
int cost, const ::Ice::Current& current) = 0;
563 bool _iceD_link(::IceInternal::Incoming&, const ::Ice::Current&);
572 virtual void unlink(::std::shared_ptr<TopicPrx> linkTo, const ::Ice::Current& current) = 0;
574 bool _iceD_unlink(::IceInternal::Incoming&, const ::Ice::Current&);
584 bool _iceD_getLinkInfoSeq(::IceInternal::Incoming&, const ::Ice::Current&)
const;
594 bool _iceD_getSubscribers(::IceInternal::Incoming&, const ::Ice::Current&)
const;
601 virtual void destroy(const ::Ice::Current& current) = 0;
603 bool _iceD_destroy(::IceInternal::Incoming&, const ::Ice::Current&);
607 virtual bool _iceDispatch(::IceInternal::Incoming&, const ::Ice::Current&)
override;
628 virtual bool ice_isA(::std::string
id, const ::Ice::Current& current)
const override;
635 virtual ::std::vector<::std::string>
ice_ids(const ::Ice::Current& current)
const override;
642 virtual ::std::string
ice_id(const ::Ice::Current& current)
const override;
658 virtual ::std::shared_ptr<TopicPrx>
create(::std::string name, const ::Ice::Current& current) = 0;
660 bool _iceD_create(::IceInternal::Incoming&, const ::Ice::Current&);
670 virtual ::std::shared_ptr<TopicPrx>
retrieve(::std::string name, const ::Ice::Current& current)
const = 0;
672 bool _iceD_retrieve(::IceInternal::Incoming&, const ::Ice::Current&)
const;
682 bool _iceD_retrieveAll(::IceInternal::Incoming&, const ::Ice::Current&)
const;
692 bool _iceD_getSliceChecksums(::IceInternal::Incoming&, const ::Ice::Current&)
const;
696 virtual bool _iceDispatch(::IceInternal::Incoming&, const ::Ice::Current&)
override;
719 virtual bool ice_isA(::std::string
id, const ::Ice::Current& current)
const override;
726 virtual ::std::vector<::std::string>
ice_ids(const ::Ice::Current& current)
const override;
733 virtual ::std::string
ice_id(const ::Ice::Current& current)
const override;
747 virtual ::std::shared_ptr<TopicManagerPrx>
getTopicManager(const ::Ice::Current& current) = 0;
749 bool _iceD_getTopicManager(::IceInternal::Incoming&, const ::Ice::Current&);
753 virtual bool _iceDispatch(::IceInternal::Incoming&, const ::Ice::Current&)
override;
780 return _makePromiseOutgoing<::std::string>(
true,
this, &TopicPrx::_iceI_getName, context).get();
789 template<
template<
typename>
class P = ::std::promise>
791 -> decltype(::std::declval<P<::std::string>>().get_future())
793 return _makePromiseOutgoing<::std::string, P>(
false,
this, &TopicPrx::_iceI_getName, context);
805 ::std::function<void()>
807 ::std::function<
void(::std::exception_ptr)> ex =
nullptr,
808 ::std::function<
void(
bool)> sent =
nullptr,
811 return _makeLamdaOutgoing<::std::string>(std::move(response), std::move(ex), std::move(sent),
this, &IceStorm::TopicPrx::_iceI_getName, context);
829 return _makePromiseOutgoing<::std::shared_ptr<::Ice::ObjectPrx>>(
true,
this, &TopicPrx::_iceI_getPublisher, context).get();
841 template<
template<
typename>
class P = ::std::promise>
843 -> decltype(::std::declval<P<::std::shared_ptr<::Ice::ObjectPrx>>>().get_future())
845 return _makePromiseOutgoing<::std::shared_ptr<::Ice::ObjectPrx>, P>(
false,
this, &TopicPrx::_iceI_getPublisher, context);
860 ::std::function<void()>
862 ::std::function<
void(::std::exception_ptr)> ex =
nullptr,
863 ::std::function<
void(
bool)> sent =
nullptr,
866 return _makeLamdaOutgoing<::std::shared_ptr<::Ice::ObjectPrx>>(std::move(response), std::move(ex), std::move(sent),
this, &IceStorm::TopicPrx::_iceI_getPublisher, context);
883 return _makePromiseOutgoing<::std::shared_ptr<::Ice::ObjectPrx>>(
true,
this, &TopicPrx::_iceI_getNonReplicatedPublisher, context).get();
894 template<
template<
typename>
class P = ::std::promise>
896 -> decltype(::std::declval<P<::std::shared_ptr<::Ice::ObjectPrx>>>().get_future())
898 return _makePromiseOutgoing<::std::shared_ptr<::Ice::ObjectPrx>, P>(
false,
this, &TopicPrx::_iceI_getNonReplicatedPublisher, context);
912 ::std::function<void()>
914 ::std::function<
void(::std::exception_ptr)> ex =
nullptr,
915 ::std::function<
void(
bool)> sent =
nullptr,
918 return _makeLamdaOutgoing<::std::shared_ptr<::Ice::ObjectPrx>>(std::move(response), std::move(ex), std::move(sent),
this, &IceStorm::TopicPrx::_iceI_getNonReplicatedPublisher, context);
942 return _makePromiseOutgoing<::std::shared_ptr<::Ice::ObjectPrx>>(
true,
this, &TopicPrx::_iceI_subscribeAndGetPublisher, theQoS, subscriber, context).get();
955 template<
template<
typename>
class P = ::std::promise>
957 -> decltype(::std::declval<P<::std::shared_ptr<::Ice::ObjectPrx>>>().get_future())
959 return _makePromiseOutgoing<::std::shared_ptr<::Ice::ObjectPrx>, P>(
false,
this, &TopicPrx::_iceI_subscribeAndGetPublisher, theQoS, subscriber, context);
975 ::std::function<void()>
977 ::std::function<
void(::std::shared_ptr<::Ice::ObjectPrx>)> response,
978 ::std::function<
void(::std::exception_ptr)> ex =
nullptr,
979 ::std::function<
void(
bool)> sent =
nullptr,
982 return _makeLamdaOutgoing<::std::shared_ptr<::Ice::ObjectPrx>>(std::move(response), std::move(ex), std::move(sent),
this, &IceStorm::TopicPrx::_iceI_subscribeAndGetPublisher, theQoS, subscriber, context);
986 ICE_MEMBER(
ICESTORM_API)
void _iceI_subscribeAndGetPublisher(const ::std::shared_ptr<::IceInternal::OutgoingAsyncT<::std::shared_ptr<::Ice::ObjectPrx>>>&,
const QoS&, const ::std::shared_ptr<::Ice::ObjectPrx>&,
const ::Ice::Context&);
997 _makePromiseOutgoing<void>(
true,
this, &TopicPrx::_iceI_unsubscribe, subscriber, context).get();
1007 template<
template<
typename>
class P = ::std::promise>
1009 -> decltype(::std::declval<P<void>>().get_future())
1011 return _makePromiseOutgoing<void, P>(
false,
this, &TopicPrx::_iceI_unsubscribe, subscriber, context);
1024 ::std::function<void()>
1026 ::std::function<
void()> response,
1027 ::std::function<
void(::std::exception_ptr)> ex =
nullptr,
1028 ::std::function<
void(
bool)> sent =
nullptr,
1031 return _makeLamdaOutgoing<void>(std::move(response), std::move(ex), std::move(sent),
this, &IceStorm::TopicPrx::_iceI_unsubscribe, subscriber, context);
1049 _makePromiseOutgoing<void>(
true,
this, &TopicPrx::_iceI_link, linkTo, cost, context).get();
1060 template<
template<
typename>
class P = ::std::promise>
1062 -> decltype(::std::declval<P<void>>().get_future())
1064 return _makePromiseOutgoing<void, P>(
false,
this, &TopicPrx::_iceI_link, linkTo, cost, context);
1078 ::std::function<void()>
1079 linkAsync(const ::std::shared_ptr<TopicPrx>& linkTo,
int cost,
1080 ::std::function<
void()> response,
1081 ::std::function<
void(::std::exception_ptr)> ex =
nullptr,
1082 ::std::function<
void(
bool)> sent =
nullptr,
1085 return _makeLamdaOutgoing<void>(std::move(response), std::move(ex), std::move(sent),
this, &IceStorm::TopicPrx::_iceI_link, linkTo, cost, context);
1100 _makePromiseOutgoing<void>(
true,
this, &TopicPrx::_iceI_unlink, linkTo, context).get();
1109 template<
template<
typename>
class P = ::std::promise>
1111 -> decltype(::std::declval<P<void>>().get_future())
1113 return _makePromiseOutgoing<void, P>(
false,
this, &TopicPrx::_iceI_unlink, linkTo, context);
1125 ::std::function<void()>
1127 ::std::function<
void()> response,
1128 ::std::function<
void(::std::exception_ptr)> ex =
nullptr,
1129 ::std::function<
void(
bool)> sent =
nullptr,
1132 return _makeLamdaOutgoing<void>(std::move(response), std::move(ex), std::move(sent),
this, &IceStorm::TopicPrx::_iceI_unlink, linkTo, context);
1146 return _makePromiseOutgoing<::IceStorm::LinkInfoSeq>(
true,
this, &TopicPrx::_iceI_getLinkInfoSeq, context).get();
1154 template<
template<
typename>
class P = ::std::promise>
1156 -> decltype(::std::declval<P<::IceStorm::LinkInfoSeq>>().get_future())
1158 return _makePromiseOutgoing<::IceStorm::LinkInfoSeq, P>(
false,
this, &TopicPrx::_iceI_getLinkInfoSeq, context);
1169 ::std::function<void()>
1171 ::std::function<
void(::std::exception_ptr)> ex =
nullptr,
1172 ::std::function<
void(
bool)> sent =
nullptr,
1175 return _makeLamdaOutgoing<::IceStorm::LinkInfoSeq>(std::move(response), std::move(ex), std::move(sent),
this, &IceStorm::TopicPrx::_iceI_getLinkInfoSeq, context);
1189 return _makePromiseOutgoing<::Ice::IdentitySeq>(
true,
this, &TopicPrx::_iceI_getSubscribers, context).get();
1197 template<
template<
typename>
class P = ::std::promise>
1199 -> decltype(::std::declval<P<::Ice::IdentitySeq>>().get_future())
1201 return _makePromiseOutgoing<::Ice::IdentitySeq, P>(
false,
this, &TopicPrx::_iceI_getSubscribers, context);
1212 ::std::function<void()>
1214 ::std::function<
void(::std::exception_ptr)> ex =
nullptr,
1215 ::std::function<
void(
bool)> sent =
nullptr,
1218 return _makeLamdaOutgoing<::Ice::IdentitySeq>(std::move(response), std::move(ex), std::move(sent),
this, &IceStorm::TopicPrx::_iceI_getSubscribers, context);
1231 _makePromiseOutgoing<void>(
true,
this, &TopicPrx::_iceI_destroy, context).get();
1239 template<
template<
typename>
class P = ::std::promise>
1241 -> decltype(::std::declval<P<void>>().get_future())
1243 return _makePromiseOutgoing<void, P>(
false,
this, &TopicPrx::_iceI_destroy, context);
1254 ::std::function<void()>
1256 ::std::function<
void(::std::exception_ptr)> ex =
nullptr,
1257 ::std::function<
void(
bool)> sent =
nullptr,
1260 return _makeLamdaOutgoing<void>(std::move(response), std::move(ex), std::move(sent),
this, &IceStorm::TopicPrx::_iceI_destroy, context);
1277 friend ::std::shared_ptr<TopicPrx> IceInternal::createProxy<TopicPrx>();
1302 return _makePromiseOutgoing<::std::shared_ptr<::IceStorm::TopicPrx>>(
true,
this, &TopicManagerPrx::_iceI_create, name, context).get();
1311 template<
template<
typename>
class P = ::std::promise>
1313 -> decltype(::std::declval<P<::std::shared_ptr<::IceStorm::TopicPrx>>>().get_future())
1315 return _makePromiseOutgoing<::std::shared_ptr<::IceStorm::TopicPrx>, P>(
false,
this, &TopicManagerPrx::_iceI_create, name, context);
1327 ::std::function<void()>
1329 ::std::function<
void(::std::shared_ptr<::IceStorm::TopicPrx>)> response,
1330 ::std::function<
void(::std::exception_ptr)> ex =
nullptr,
1331 ::std::function<
void(
bool)> sent =
nullptr,
1334 return _makeLamdaOutgoing<::std::shared_ptr<::IceStorm::TopicPrx>>(std::move(response), std::move(ex), std::move(sent),
this, &IceStorm::TopicManagerPrx::_iceI_create, name, context);
1350 return _makePromiseOutgoing<::std::shared_ptr<::IceStorm::TopicPrx>>(
true,
this, &TopicManagerPrx::_iceI_retrieve, name, context).get();
1359 template<
template<
typename>
class P = ::std::promise>
1361 -> decltype(::std::declval<P<::std::shared_ptr<::IceStorm::TopicPrx>>>().get_future())
1363 return _makePromiseOutgoing<::std::shared_ptr<::IceStorm::TopicPrx>, P>(
false,
this, &TopicManagerPrx::_iceI_retrieve, name, context);
1375 ::std::function<void()>
1377 ::std::function<
void(::std::shared_ptr<::IceStorm::TopicPrx>)> response,
1378 ::std::function<
void(::std::exception_ptr)> ex =
nullptr,
1379 ::std::function<
void(
bool)> sent =
nullptr,
1382 return _makeLamdaOutgoing<::std::shared_ptr<::IceStorm::TopicPrx>>(std::move(response), std::move(ex), std::move(sent),
this, &IceStorm::TopicManagerPrx::_iceI_retrieve, name, context);
1396 return _makePromiseOutgoing<::IceStorm::TopicDict>(
true,
this, &TopicManagerPrx::_iceI_retrieveAll, context).get();
1404 template<
template<
typename>
class P = ::std::promise>
1406 -> decltype(::std::declval<P<::IceStorm::TopicDict>>().get_future())
1408 return _makePromiseOutgoing<::IceStorm::TopicDict, P>(
false,
this, &TopicManagerPrx::_iceI_retrieveAll, context);
1419 ::std::function<void()>
1421 ::std::function<
void(::std::exception_ptr)> ex =
nullptr,
1422 ::std::function<
void(
bool)> sent =
nullptr,
1425 return _makeLamdaOutgoing<::IceStorm::TopicDict>(std::move(response), std::move(ex), std::move(sent),
this, &IceStorm::TopicManagerPrx::_iceI_retrieveAll, context);
1439 return _makePromiseOutgoing<::Ice::SliceChecksumDict>(
true,
this, &TopicManagerPrx::_iceI_getSliceChecksums, context).get();
1447 template<
template<
typename>
class P = ::std::promise>
1449 -> decltype(::std::declval<P<::Ice::SliceChecksumDict>>().get_future())
1451 return _makePromiseOutgoing<::Ice::SliceChecksumDict, P>(
false,
this, &TopicManagerPrx::_iceI_getSliceChecksums, context);
1462 ::std::function<void()>
1464 ::std::function<
void(::std::exception_ptr)> ex =
nullptr,
1465 ::std::function<
void(
bool)> sent =
nullptr,
1468 return _makeLamdaOutgoing<::Ice::SliceChecksumDict>(std::move(response), std::move(ex), std::move(sent),
this, &IceStorm::TopicManagerPrx::_iceI_getSliceChecksums, context);
1485 friend ::std::shared_ptr<TopicManagerPrx> IceInternal::createProxy<TopicManagerPrx>();
1510 return _makePromiseOutgoing<::std::shared_ptr<::IceStorm::TopicManagerPrx>>(
true,
this, &FinderPrx::_iceI_getTopicManager, context).get();
1519 template<
template<
typename>
class P = ::std::promise>
1521 -> decltype(::std::declval<P<::std::shared_ptr<::IceStorm::TopicManagerPrx>>>().get_future())
1523 return _makePromiseOutgoing<::std::shared_ptr<::IceStorm::TopicManagerPrx>, P>(
false,
this, &FinderPrx::_iceI_getTopicManager, context);
1535 ::std::function<void()>
1537 ::std::function<
void(::std::exception_ptr)> ex =
nullptr,
1538 ::std::function<
void(
bool)> sent =
nullptr,
1541 return _makeLamdaOutgoing<::std::shared_ptr<::IceStorm::TopicManagerPrx>>(std::move(response), std::move(ex), std::move(sent),
this, &IceStorm::FinderPrx::_iceI_getTopicManager, context);
1558 friend ::std::shared_ptr<FinderPrx> IceInternal::createProxy<FinderPrx>();
1573 static const StreamHelperCategory helper = StreamHelperCategoryStruct;
1574 static const int minWireSize = 7;
1575 static const bool fixedLength =
false;
1578 template<
typename S>
1587 template<
typename S>
1592 istr->readAll(v.
name);
1596 template<
typename S>
1601 istr->readAll(v.
name);
1605 template<
typename S>
1614 template<
typename S>
1623 template<
typename S>
1628 istr->readAll(v.
name);
1632 template<
typename S>
1637 istr->readAll(v.
name);
1648 using TopicPtr = ::std::shared_ptr<Topic>;
1649 using TopicPrxPtr = ::std::shared_ptr<TopicPrx>;
1651 using TopicManagerPtr = ::std::shared_ptr<TopicManager>;
1652 using TopicManagerPrxPtr = ::std::shared_ptr<TopicManagerPrx>;
1654 using FinderPtr = ::std::shared_ptr<Finder>;
1655 using FinderPrxPtr = ::std::shared_ptr<FinderPrx>;
1660 #else // C++98 mapping
1671 ICESTORM_API ::IceProxy::Ice::Object* upCast(Topic*);
1677 ICESTORM_API ::IceProxy::Ice::Object* upCast(TopicManager*);
1683 ICESTORM_API ::IceProxy::Ice::Object* upCast(Finder*);
1695 ICESTORM_API ::Ice::Object* upCast(Topic*);
1697 typedef ::IceInternal::Handle< Topic> TopicPtr;
1698 typedef ::IceInternal::ProxyHandle< ::IceProxy::IceStorm::Topic> TopicPrx;
1699 typedef TopicPrx TopicPrxPtr;
1701 ICESTORM_API void _icePatchObjectPtr(TopicPtr&, const ::Ice::ObjectPtr&);
1706 ICESTORM_API ::Ice::Object* upCast(TopicManager*);
1708 typedef ::IceInternal::Handle< TopicManager> TopicManagerPtr;
1709 typedef ::IceInternal::ProxyHandle< ::IceProxy::IceStorm::TopicManager> TopicManagerPrx;
1710 typedef TopicManagerPrx TopicManagerPrxPtr;
1712 ICESTORM_API void _icePatchObjectPtr(TopicManagerPtr&, const ::Ice::ObjectPtr&);
1717 ICESTORM_API ::Ice::Object* upCast(Finder*);
1719 typedef ::IceInternal::Handle< Finder> FinderPtr;
1720 typedef ::IceInternal::ProxyHandle< ::IceProxy::IceStorm::Finder> FinderPrx;
1721 typedef FinderPrx FinderPrxPtr;
1723 ICESTORM_API void _icePatchObjectPtr(FinderPtr&, const ::Ice::ObjectPtr&);
1760 typedef ::std::map< ::std::string, ::std::string>
QoS;
1776 explicit LinkExists(const ::std::string& name);
1778 #ifdef ICE_CPP11_COMPILER
1779 LinkExists(
const LinkExists&) =
default;
1780 virtual ~LinkExists();
1782 virtual ~LinkExists() throw();
1789 virtual ::std::string ice_id()
const;
1794 virtual LinkExists* ice_clone()
const;
1798 virtual void ice_throw()
const;
1814 static LinkExists _iceS_LinkExists_init;
1831 explicit NoSuchLink(const ::std::string& name);
1833 #ifdef ICE_CPP11_COMPILER
1834 NoSuchLink(
const NoSuchLink&) =
default;
1835 virtual ~NoSuchLink();
1837 virtual ~NoSuchLink() throw();
1844 virtual ::std::string ice_id()
const;
1849 virtual NoSuchLink* ice_clone()
const;
1853 virtual void ice_throw()
const;
1877 AlreadySubscribed() {}
1879 #ifdef ICE_CPP11_COMPILER
1880 AlreadySubscribed(
const AlreadySubscribed&) =
default;
1881 virtual ~AlreadySubscribed();
1883 virtual ~AlreadySubscribed() throw();
1890 virtual ::std::string ice_id()
const;
1895 virtual AlreadySubscribed* ice_clone()
const;
1899 virtual void ice_throw()
const;
1918 InvalidSubscriber() {}
1923 explicit InvalidSubscriber(const ::std::string& reason);
1925 #ifdef ICE_CPP11_COMPILER
1926 InvalidSubscriber(
const InvalidSubscriber&) =
default;
1927 virtual ~InvalidSubscriber();
1929 virtual ~InvalidSubscriber() throw();
1936 virtual ::std::string ice_id()
const;
1941 virtual InvalidSubscriber* ice_clone()
const;
1945 virtual void ice_throw()
const;
1950 ::std::string reason;
1974 explicit BadQoS(const ::std::string& reason);
1976 #ifdef ICE_CPP11_COMPILER
1977 BadQoS(
const BadQoS&) =
default;
1980 virtual ~BadQoS() throw();
1987 virtual ::std::string ice_id()
const;
1992 virtual BadQoS* ice_clone()
const;
1996 virtual void ice_throw()
const;
2001 ::std::string reason;
2014 typedef ::std::map< ::std::string, TopicPrx>
TopicDict;
2030 explicit TopicExists(const ::std::string& name);
2032 #ifdef ICE_CPP11_COMPILER
2033 TopicExists(
const TopicExists&) =
default;
2034 virtual ~TopicExists();
2036 virtual ~TopicExists() throw();
2043 virtual ::std::string ice_id()
const;
2048 virtual TopicExists* ice_clone()
const;
2052 virtual void ice_throw()
const;
2081 explicit NoSuchTopic(const ::std::string& name);
2083 #ifdef ICE_CPP11_COMPILER
2084 NoSuchTopic(
const NoSuchTopic&) =
default;
2085 virtual ~NoSuchTopic();
2087 virtual ~NoSuchTopic() throw();
2094 virtual ::std::string ice_id()
const;
2099 virtual NoSuchTopic* ice_clone()
const;
2103 virtual void ice_throw()
const;
2128 class Callback_Topic_getName_Base :
public virtual ::IceInternal::CallbackBase { };
2129 typedef ::IceUtil::Handle< Callback_Topic_getName_Base> Callback_Topic_getNamePtr;
2136 class Callback_Topic_getPublisher_Base :
public virtual ::IceInternal::CallbackBase { };
2137 typedef ::IceUtil::Handle< Callback_Topic_getPublisher_Base> Callback_Topic_getPublisherPtr;
2144 class Callback_Topic_getNonReplicatedPublisher_Base :
public virtual ::IceInternal::CallbackBase { };
2145 typedef ::IceUtil::Handle< Callback_Topic_getNonReplicatedPublisher_Base> Callback_Topic_getNonReplicatedPublisherPtr;
2152 class Callback_Topic_subscribeAndGetPublisher_Base :
public virtual ::IceInternal::CallbackBase { };
2153 typedef ::IceUtil::Handle< Callback_Topic_subscribeAndGetPublisher_Base> Callback_Topic_subscribeAndGetPublisherPtr;
2160 class Callback_Topic_unsubscribe_Base :
public virtual ::IceInternal::CallbackBase { };
2161 typedef ::IceUtil::Handle< Callback_Topic_unsubscribe_Base> Callback_Topic_unsubscribePtr;
2168 class Callback_Topic_link_Base :
public virtual ::IceInternal::CallbackBase { };
2169 typedef ::IceUtil::Handle< Callback_Topic_link_Base> Callback_Topic_linkPtr;
2176 class Callback_Topic_unlink_Base :
public virtual ::IceInternal::CallbackBase { };
2177 typedef ::IceUtil::Handle< Callback_Topic_unlink_Base> Callback_Topic_unlinkPtr;
2184 class Callback_Topic_getLinkInfoSeq_Base :
public virtual ::IceInternal::CallbackBase { };
2185 typedef ::IceUtil::Handle< Callback_Topic_getLinkInfoSeq_Base> Callback_Topic_getLinkInfoSeqPtr;
2192 class Callback_Topic_getSubscribers_Base :
public virtual ::IceInternal::CallbackBase { };
2193 typedef ::IceUtil::Handle< Callback_Topic_getSubscribers_Base> Callback_Topic_getSubscribersPtr;
2200 class Callback_Topic_destroy_Base :
public virtual ::IceInternal::CallbackBase { };
2201 typedef ::IceUtil::Handle< Callback_Topic_destroy_Base> Callback_Topic_destroyPtr;
2208 class Callback_TopicManager_create_Base :
public virtual ::IceInternal::CallbackBase { };
2209 typedef ::IceUtil::Handle< Callback_TopicManager_create_Base> Callback_TopicManager_createPtr;
2216 class Callback_TopicManager_retrieve_Base :
public virtual ::IceInternal::CallbackBase { };
2217 typedef ::IceUtil::Handle< Callback_TopicManager_retrieve_Base> Callback_TopicManager_retrievePtr;
2224 class Callback_TopicManager_retrieveAll_Base :
public virtual ::IceInternal::CallbackBase { };
2225 typedef ::IceUtil::Handle< Callback_TopicManager_retrieveAll_Base> Callback_TopicManager_retrieveAllPtr;
2232 class Callback_TopicManager_getSliceChecksums_Base :
public virtual ::IceInternal::CallbackBase { };
2233 typedef ::IceUtil::Handle< Callback_TopicManager_getSliceChecksums_Base> Callback_TopicManager_getSliceChecksumsPtr;
2240 class Callback_Finder_getTopicManager_Base :
public virtual ::IceInternal::CallbackBase { };
2241 typedef ::IceUtil::Handle< Callback_Finder_getTopicManager_Base> Callback_Finder_getTopicManagerPtr;
2251 class ICE_CLASS(ICESTORM_API) Topic :
public virtual ::Ice::Proxy<Topic, ::IceProxy::Ice::Object>
2263 return end_getName(_iceI_begin_getName(context, ::IceInternal::dummyCallback, 0,
true));
2274 return _iceI_begin_getName(context, ::IceInternal::dummyCallback, 0);
2299 return _iceI_begin_getName(context, cb, cookie);
2324 return _iceI_begin_getName(context, cb, cookie);
2351 return end_getPublisher(_iceI_begin_getPublisher(context, ::IceInternal::dummyCallback, 0,
true));
2365 return _iceI_begin_getPublisher(context, ::IceInternal::dummyCallback, 0);
2396 return _iceI_begin_getPublisher(context, cb, cookie);
2409 ::Ice::AsyncResultPtr begin_getPublisher(const ::IceStorm::Callback_Topic_getPublisherPtr& cb,
const ::Ice::LocalObjectPtr& cookie = 0)
2427 return _iceI_begin_getPublisher(context, cb, cookie);
2453 return end_getNonReplicatedPublisher(_iceI_begin_getNonReplicatedPublisher(context, ::IceInternal::dummyCallback, 0,
true));
2466 return _iceI_begin_getNonReplicatedPublisher(context, ::IceInternal::dummyCallback, 0);
2495 return _iceI_begin_getNonReplicatedPublisher(context, cb, cookie);
2507 ::Ice::AsyncResultPtr begin_getNonReplicatedPublisher(const ::IceStorm::Callback_Topic_getNonReplicatedPublisherPtr& cb,
const ::Ice::LocalObjectPtr& cookie = 0)
2524 return _iceI_begin_getNonReplicatedPublisher(context, cb, cookie);
2557 return end_subscribeAndGetPublisher(_iceI_begin_subscribeAndGetPublisher(theQoS, subscriber, context, ::IceInternal::dummyCallback, 0,
true));
2572 return _iceI_begin_subscribeAndGetPublisher(theQoS, subscriber, context, ::IceInternal::dummyCallback, 0);
2605 return _iceI_begin_subscribeAndGetPublisher(theQoS, subscriber, context, cb, cookie);
2638 return _iceI_begin_subscribeAndGetPublisher(theQoS, subscriber, context, cb, cookie);
2667 end_unsubscribe(_iceI_begin_unsubscribe(subscriber, context, ::IceInternal::dummyCallback, 0,
true));
2679 return _iceI_begin_unsubscribe(subscriber, context, ::IceInternal::dummyCallback, 0);
2690 ::Ice::AsyncResultPtr begin_unsubscribe(const ::Ice::ObjectPrx& subscriber, const ::Ice::CallbackPtr& cb,
const ::Ice::LocalObjectPtr& cookie = 0)
2706 return _iceI_begin_unsubscribe(subscriber, context, cb, cookie);
2717 ::Ice::AsyncResultPtr begin_unsubscribe(const ::Ice::ObjectPrx& subscriber, const ::IceStorm::Callback_Topic_unsubscribePtr& cb,
const ::Ice::LocalObjectPtr& cookie = 0)
2733 return _iceI_begin_unsubscribe(subscriber, context, cb, cookie);
2759 end_link(_iceI_begin_link(linkTo, cost, context, ::IceInternal::dummyCallback, 0,
true));
2772 return _iceI_begin_link(linkTo, cost, context, ::IceInternal::dummyCallback, 0);
2801 return _iceI_begin_link(linkTo, cost, context, cb, cookie);
2813 ::Ice::AsyncResultPtr begin_link(const ::IceStorm::TopicPrx& linkTo, ::
Ice::Int cost, const ::IceStorm::Callback_Topic_linkPtr& cb,
const ::Ice::LocalObjectPtr& cookie = 0)
2830 return _iceI_begin_link(linkTo, cost, context, cb, cookie);
2855 end_unlink(_iceI_begin_unlink(linkTo, context, ::IceInternal::dummyCallback, 0,
true));
2866 return _iceI_begin_unlink(linkTo, context, ::IceInternal::dummyCallback, 0);
2876 ::Ice::AsyncResultPtr begin_unlink(const ::IceStorm::TopicPrx& linkTo, const ::Ice::CallbackPtr& cb,
const ::Ice::LocalObjectPtr& cookie = 0)
2891 return _iceI_begin_unlink(linkTo, context, cb, cookie);
2901 ::Ice::AsyncResultPtr begin_unlink(const ::IceStorm::TopicPrx& linkTo, const ::IceStorm::Callback_Topic_unlinkPtr& cb,
const ::Ice::LocalObjectPtr& cookie = 0)
2916 return _iceI_begin_unlink(linkTo, context, cb, cookie);
2939 return end_getLinkInfoSeq(_iceI_begin_getLinkInfoSeq(context, ::IceInternal::dummyCallback, 0,
true));
2949 return _iceI_begin_getLinkInfoSeq(context, ::IceInternal::dummyCallback, 0);
2972 return _iceI_begin_getLinkInfoSeq(context, cb, cookie);
2981 ::Ice::AsyncResultPtr begin_getLinkInfoSeq(const ::IceStorm::Callback_Topic_getLinkInfoSeqPtr& cb,
const ::Ice::LocalObjectPtr& cookie = 0)
2995 return _iceI_begin_getLinkInfoSeq(context, cb, cookie);
3018 return end_getSubscribers(_iceI_begin_getSubscribers(context, ::IceInternal::dummyCallback, 0,
true));
3028 return _iceI_begin_getSubscribers(context, ::IceInternal::dummyCallback, 0);
3051 return _iceI_begin_getSubscribers(context, cb, cookie);
3060 ::Ice::AsyncResultPtr begin_getSubscribers(const ::IceStorm::Callback_Topic_getSubscribersPtr& cb,
const ::Ice::LocalObjectPtr& cookie = 0)
3074 return _iceI_begin_getSubscribers(context, cb, cookie);
3096 end_destroy(_iceI_begin_destroy(context, ::IceInternal::dummyCallback, 0,
true));
3106 return _iceI_begin_destroy(context, ::IceInternal::dummyCallback, 0);
3129 return _iceI_begin_destroy(context, cb, cookie);
3152 return _iceI_begin_destroy(context, cb, cookie);
3180 class ICE_CLASS(ICESTORM_API) TopicManager :
public virtual ::Ice::Proxy<TopicManager, ::IceProxy::Ice::Object>
3194 return end_create(_iceI_begin_create(name, context, ::IceInternal::dummyCallback, 0,
true));
3205 return _iceI_begin_create(name, context, ::IceInternal::dummyCallback, 0);
3215 ::Ice::AsyncResultPtr begin_create(const ::std::string& name, const ::Ice::CallbackPtr& cb,
const ::Ice::LocalObjectPtr& cookie = 0)
3230 return _iceI_begin_create(name, context, cb, cookie);
3240 ::Ice::AsyncResultPtr begin_create(const ::std::string& name, const ::IceStorm::Callback_TopicManager_createPtr& cb,
const ::Ice::LocalObjectPtr& cookie = 0)
3255 return _iceI_begin_create(name, context, cb, cookie);
3282 return end_retrieve(_iceI_begin_retrieve(name, context, ::IceInternal::dummyCallback, 0,
true));
3293 return _iceI_begin_retrieve(name, context, ::IceInternal::dummyCallback, 0);
3303 ::Ice::AsyncResultPtr begin_retrieve(const ::std::string& name, const ::Ice::CallbackPtr& cb,
const ::Ice::LocalObjectPtr& cookie = 0)
3318 return _iceI_begin_retrieve(name, context, cb, cookie);
3328 ::Ice::AsyncResultPtr begin_retrieve(const ::std::string& name, const ::IceStorm::Callback_TopicManager_retrievePtr& cb,
const ::Ice::LocalObjectPtr& cookie = 0)
3343 return _iceI_begin_retrieve(name, context, cb, cookie);
3367 return end_retrieveAll(_iceI_begin_retrieveAll(context, ::IceInternal::dummyCallback, 0,
true));
3377 return _iceI_begin_retrieveAll(context, ::IceInternal::dummyCallback, 0);
3400 return _iceI_begin_retrieveAll(context, cb, cookie);
3409 ::Ice::AsyncResultPtr begin_retrieveAll(const ::IceStorm::Callback_TopicManager_retrieveAllPtr& cb,
const ::Ice::LocalObjectPtr& cookie = 0)
3423 return _iceI_begin_retrieveAll(context, cb, cookie);
3446 return end_getSliceChecksums(_iceI_begin_getSliceChecksums(context, ::IceInternal::dummyCallback, 0,
true));
3456 return _iceI_begin_getSliceChecksums(context, ::IceInternal::dummyCallback, 0);
3479 return _iceI_begin_getSliceChecksums(context, cb, cookie);
3488 ::Ice::AsyncResultPtr begin_getSliceChecksums(const ::IceStorm::Callback_TopicManager_getSliceChecksumsPtr& cb,
const ::Ice::LocalObjectPtr& cookie = 0)
3502 return _iceI_begin_getSliceChecksums(context, cb, cookie);
3531 class ICE_CLASS(ICESTORM_API) Finder :
public virtual ::Ice::Proxy<Finder, ::IceProxy::Ice::Object>
3543 return end_getTopicManager(_iceI_begin_getTopicManager(context, ::IceInternal::dummyCallback, 0,
true));
3554 return _iceI_begin_getTopicManager(context, ::IceInternal::dummyCallback, 0);
3579 return _iceI_begin_getTopicManager(context, cb, cookie);
3589 ::Ice::AsyncResultPtr begin_getTopicManager(const ::IceStorm::Callback_Finder_getTopicManagerPtr& cb,
const ::Ice::LocalObjectPtr& cookie = 0)
3604 return _iceI_begin_getTopicManager(context, cb, cookie);
3650 typedef TopicPrx ProxyType;
3651 typedef TopicPtr PointerType;
3655 #ifdef ICE_CPP11_COMPILER
3657 Topic(
const Topic&) =
default;
3658 Topic& operator=(
const Topic&) =
default;
3667 virtual bool ice_isA(const ::std::string&
id, const ::Ice::Current& current = ::
Ice::emptyCurrent)
const;
3674 virtual ::std::vector< ::std::string> ice_ids(const ::Ice::Current& current = ::
Ice::emptyCurrent)
const;
3681 virtual const ::std::string& ice_id(const ::Ice::Current& current = ::
Ice::emptyCurrent)
const;
3687 static const ::std::string& ice_staticId();
3695 virtual ::std::string getName(const ::Ice::Current& current = ::
Ice::emptyCurrent)
const = 0;
3697 bool _iceD_getName(::IceInternal::Incoming&, const ::Ice::Current&)
const;
3709 virtual ::Ice::ObjectPrx getPublisher(const ::Ice::Current& current = ::
Ice::emptyCurrent)
const = 0;
3711 bool _iceD_getPublisher(::IceInternal::Incoming&, const ::Ice::Current&)
const;
3722 virtual ::Ice::ObjectPrx getNonReplicatedPublisher(const ::Ice::Current& current = ::
Ice::emptyCurrent)
const = 0;
3724 bool _iceD_getNonReplicatedPublisher(::IceInternal::Incoming&, const ::Ice::Current&)
const;
3742 virtual ::Ice::ObjectPrx subscribeAndGetPublisher(
const QoS& theQoS, const ::Ice::ObjectPrx& subscriber, const ::Ice::Current& current = ::
Ice::emptyCurrent) = 0;
3744 bool _iceD_subscribeAndGetPublisher(::IceInternal::Incoming&, const ::Ice::Current&);
3753 virtual void unsubscribe(const ::Ice::ObjectPrx& subscriber, const ::Ice::Current& current = ::
Ice::emptyCurrent) = 0;
3755 bool _iceD_unsubscribe(::IceInternal::Incoming&, const ::Ice::Current&);
3769 bool _iceD_link(::IceInternal::Incoming&, const ::Ice::Current&);
3778 virtual void unlink(
const TopicPrx& linkTo, const ::Ice::Current& current = ::
Ice::emptyCurrent) = 0;
3780 bool _iceD_unlink(::IceInternal::Incoming&, const ::Ice::Current&);
3790 bool _iceD_getLinkInfoSeq(::IceInternal::Incoming&, const ::Ice::Current&)
const;
3800 bool _iceD_getSubscribers(::IceInternal::Incoming&, const ::Ice::Current&)
const;
3809 bool _iceD_destroy(::IceInternal::Incoming&, const ::Ice::Current&);
3813 virtual bool _iceDispatch(::IceInternal::Incoming&, const ::Ice::Current&);
3825 inline bool operator==(
const Topic& lhs,
const Topic& rhs)
3830 inline bool operator<(
const Topic& lhs,
const Topic& rhs)
3845 typedef TopicManagerPrx ProxyType;
3846 typedef TopicManagerPtr PointerType;
3848 virtual ~TopicManager();
3850 #ifdef ICE_CPP11_COMPILER
3851 TopicManager() =
default;
3852 TopicManager(
const TopicManager&) =
default;
3853 TopicManager& operator=(
const TopicManager&) =
default;
3862 virtual bool ice_isA(const ::std::string&
id, const ::Ice::Current& current = ::
Ice::emptyCurrent)
const;
3869 virtual ::std::vector< ::std::string> ice_ids(const ::Ice::Current& current = ::
Ice::emptyCurrent)
const;
3876 virtual const ::std::string& ice_id(const ::Ice::Current& current = ::
Ice::emptyCurrent)
const;
3882 static const ::std::string& ice_staticId();
3892 virtual TopicPrx create(const ::std::string& name, const ::Ice::Current& current = ::
Ice::emptyCurrent) = 0;
3894 bool _iceD_create(::IceInternal::Incoming&, const ::Ice::Current&);
3904 virtual TopicPrx retrieve(const ::std::string& name, const ::Ice::Current& current = ::
Ice::emptyCurrent)
const = 0;
3906 bool _iceD_retrieve(::IceInternal::Incoming&, const ::Ice::Current&)
const;
3916 bool _iceD_retrieveAll(::IceInternal::Incoming&, const ::Ice::Current&)
const;
3926 bool _iceD_getSliceChecksums(::IceInternal::Incoming&, const ::Ice::Current&)
const;
3930 virtual bool _iceDispatch(::IceInternal::Incoming&, const ::Ice::Current&);
3942 inline bool operator==(
const TopicManager& lhs,
const TopicManager& rhs)
3947 inline bool operator<(
const TopicManager& lhs,
const TopicManager& rhs)
3964 typedef FinderPrx ProxyType;
3965 typedef FinderPtr PointerType;
3969 #ifdef ICE_CPP11_COMPILER
3971 Finder(
const Finder&) =
default;
3972 Finder& operator=(
const Finder&) =
default;
3981 virtual bool ice_isA(const ::std::string&
id, const ::Ice::Current& current = ::
Ice::emptyCurrent)
const;
3988 virtual ::std::vector< ::std::string> ice_ids(const ::Ice::Current& current = ::
Ice::emptyCurrent)
const;
3995 virtual const ::std::string& ice_id(const ::Ice::Current& current = ::
Ice::emptyCurrent)
const;
4001 static const ::std::string& ice_staticId();
4009 virtual TopicManagerPrx getTopicManager(const ::Ice::Current& current = ::
Ice::emptyCurrent) = 0;
4011 bool _iceD_getTopicManager(::IceInternal::Incoming&, const ::Ice::Current&);
4015 virtual bool _iceDispatch(::IceInternal::Incoming&, const ::Ice::Current&);
4027 inline bool operator==(
const Finder& lhs,
const Finder& rhs)
4032 inline bool operator<(
const Finder& lhs,
const Finder& rhs)
4047 static const StreamHelperCategory helper = StreamHelperCategoryStruct;
4048 static const int minWireSize = 7;
4049 static const bool fixedLength =
false;
4052 template<
typename S>
4055 static void write(S* ostr, const ::IceStorm::LinkInfo& v)
4057 ostr->write(v.theTopic);
4058 ostr->write(v.name);
4059 ostr->write(v.cost);
4063 template<
typename S>
4077 static const StreamHelperCategory helper = StreamHelperCategoryUserException;
4080 template<
typename S>
4083 static void write(S* ostr, const ::IceStorm::LinkExists& v)
4085 ostr->write(v.name);
4089 template<
typename S>
4101 static const StreamHelperCategory helper = StreamHelperCategoryUserException;
4104 template<
typename S>
4107 static void write(S* ostr, const ::IceStorm::NoSuchLink& v)
4109 ostr->write(v.name);
4113 template<
typename S>
4125 static const StreamHelperCategory helper = StreamHelperCategoryUserException;
4131 static const StreamHelperCategory helper = StreamHelperCategoryUserException;
4134 template<
typename S>
4137 static void write(S* ostr, const ::IceStorm::InvalidSubscriber& v)
4139 ostr->write(v.reason);
4143 template<
typename S>
4155 static const StreamHelperCategory helper = StreamHelperCategoryUserException;
4158 template<
typename S>
4161 static void write(S* ostr, const ::IceStorm::BadQoS& v)
4163 ostr->write(v.reason);
4167 template<
typename S>
4179 static const StreamHelperCategory helper = StreamHelperCategoryUserException;
4182 template<
typename S>
4185 static void write(S* ostr, const ::IceStorm::TopicExists& v)
4187 ostr->write(v.name);
4191 template<
typename S>
4203 static const StreamHelperCategory helper = StreamHelperCategoryUserException;
4206 template<
typename S>
4209 static void write(S* ostr, const ::IceStorm::NoSuchTopic& v)
4211 ostr->write(v.name);
4215 template<
typename S>
4236 class CallbackNC_Topic_getName :
public Callback_Topic_getName_Base,
public ::IceInternal::TwowayCallbackNC<T>
4243 typedef void (T::*Sent)(bool);
4244 typedef void (T::*Response)(const ::std::string&);
4246 CallbackNC_Topic_getName(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
4247 : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
4252 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
4258 ret = proxy->end_getName(result);
4262 ::IceInternal::CallbackNC<T>::exception(result, ex);
4267 (::IceInternal::CallbackNC<T>::_callback.get()->*_response)(ret);
4285 template<
class T> Callback_Topic_getNamePtr
4288 return new CallbackNC_Topic_getName<T>(instance, cb, excb, sentcb);
4299 template<
class T> Callback_Topic_getNamePtr
4300 newCallback_Topic_getName(T* instance,
void (T::*cb)(const ::std::string&),
void (T::*excb)(
const ::Ice::Exception&),
void (T::*sentcb)(
bool) = 0)
4302 return new CallbackNC_Topic_getName<T>(instance, cb, excb, sentcb);
4310 template<
class T,
typename CT>
4311 class Callback_Topic_getName :
public Callback_Topic_getName_Base,
public ::IceInternal::TwowayCallback<T, CT>
4318 typedef void (T::*Sent)(bool ,
const CT&);
4319 typedef void (T::*Response)(const ::std::string&,
const CT&);
4321 Callback_Topic_getName(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
4322 : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
4327 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
4333 ret = proxy->end_getName(result);
4337 ::IceInternal::Callback<T, CT>::exception(result, ex);
4342 (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(ret, CT::dynamicCast(result->getCookie()));
4361 template<
class T,
typename CT> Callback_Topic_getNamePtr
4362 newCallback_Topic_getName(
const IceUtil::Handle<T>& instance,
void (T::*cb)(const ::std::string&,
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
4364 return new Callback_Topic_getName<T, CT>(instance, cb, excb, sentcb);
4376 template<
class T,
typename CT> Callback_Topic_getNamePtr
4377 newCallback_Topic_getName(T* instance,
void (T::*cb)(const ::std::string&,
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
4379 return new Callback_Topic_getName<T, CT>(instance, cb, excb, sentcb);
4388 class CallbackNC_Topic_getPublisher :
public Callback_Topic_getPublisher_Base,
public ::IceInternal::TwowayCallbackNC<T>
4395 typedef void (T::*Sent)(bool);
4396 typedef void (T::*Response)(const ::Ice::ObjectPrx&);
4398 CallbackNC_Topic_getPublisher(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
4399 : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
4404 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
4410 ret = proxy->end_getPublisher(result);
4414 ::IceInternal::CallbackNC<T>::exception(result, ex);
4419 (::IceInternal::CallbackNC<T>::_callback.get()->*_response)(ret);
4437 template<
class T> Callback_Topic_getPublisherPtr
4440 return new CallbackNC_Topic_getPublisher<T>(instance, cb, excb, sentcb);
4451 template<
class T> Callback_Topic_getPublisherPtr
4452 newCallback_Topic_getPublisher(T* instance,
void (T::*cb)(const ::Ice::ObjectPrx&),
void (T::*excb)(
const ::Ice::Exception&),
void (T::*sentcb)(
bool) = 0)
4454 return new CallbackNC_Topic_getPublisher<T>(instance, cb, excb, sentcb);
4462 template<
class T,
typename CT>
4463 class Callback_Topic_getPublisher :
public Callback_Topic_getPublisher_Base,
public ::IceInternal::TwowayCallback<T, CT>
4470 typedef void (T::*Sent)(bool ,
const CT&);
4471 typedef void (T::*Response)(const ::Ice::ObjectPrx&,
const CT&);
4473 Callback_Topic_getPublisher(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
4474 : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
4479 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
4485 ret = proxy->end_getPublisher(result);
4489 ::IceInternal::Callback<T, CT>::exception(result, ex);
4494 (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(ret, CT::dynamicCast(result->getCookie()));
4513 template<
class T,
typename CT> Callback_Topic_getPublisherPtr
4514 newCallback_Topic_getPublisher(
const IceUtil::Handle<T>& instance,
void (T::*cb)(const ::Ice::ObjectPrx&,
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
4516 return new Callback_Topic_getPublisher<T, CT>(instance, cb, excb, sentcb);
4528 template<
class T,
typename CT> Callback_Topic_getPublisherPtr
4529 newCallback_Topic_getPublisher(T* instance,
void (T::*cb)(const ::Ice::ObjectPrx&,
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
4531 return new Callback_Topic_getPublisher<T, CT>(instance, cb, excb, sentcb);
4540 class CallbackNC_Topic_getNonReplicatedPublisher :
public Callback_Topic_getNonReplicatedPublisher_Base,
public ::IceInternal::TwowayCallbackNC<T>
4547 typedef void (T::*Sent)(bool);
4548 typedef void (T::*Response)(const ::Ice::ObjectPrx&);
4550 CallbackNC_Topic_getNonReplicatedPublisher(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
4551 : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
4556 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
4562 ret = proxy->end_getNonReplicatedPublisher(result);
4566 ::IceInternal::CallbackNC<T>::exception(result, ex);
4571 (::IceInternal::CallbackNC<T>::_callback.get()->*_response)(ret);
4589 template<
class T> Callback_Topic_getNonReplicatedPublisherPtr
4592 return new CallbackNC_Topic_getNonReplicatedPublisher<T>(instance, cb, excb, sentcb);
4603 template<
class T> Callback_Topic_getNonReplicatedPublisherPtr
4604 newCallback_Topic_getNonReplicatedPublisher(T* instance,
void (T::*cb)(const ::Ice::ObjectPrx&),
void (T::*excb)(
const ::Ice::Exception&),
void (T::*sentcb)(
bool) = 0)
4606 return new CallbackNC_Topic_getNonReplicatedPublisher<T>(instance, cb, excb, sentcb);
4614 template<
class T,
typename CT>
4615 class Callback_Topic_getNonReplicatedPublisher :
public Callback_Topic_getNonReplicatedPublisher_Base,
public ::IceInternal::TwowayCallback<T, CT>
4622 typedef void (T::*Sent)(bool ,
const CT&);
4623 typedef void (T::*Response)(const ::Ice::ObjectPrx&,
const CT&);
4625 Callback_Topic_getNonReplicatedPublisher(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
4626 : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
4631 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
4637 ret = proxy->end_getNonReplicatedPublisher(result);
4641 ::IceInternal::Callback<T, CT>::exception(result, ex);
4646 (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(ret, CT::dynamicCast(result->getCookie()));
4665 template<
class T,
typename CT> Callback_Topic_getNonReplicatedPublisherPtr
4666 newCallback_Topic_getNonReplicatedPublisher(
const IceUtil::Handle<T>& instance,
void (T::*cb)(const ::Ice::ObjectPrx&,
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
4668 return new Callback_Topic_getNonReplicatedPublisher<T, CT>(instance, cb, excb, sentcb);
4680 template<
class T,
typename CT> Callback_Topic_getNonReplicatedPublisherPtr
4681 newCallback_Topic_getNonReplicatedPublisher(T* instance,
void (T::*cb)(const ::Ice::ObjectPrx&,
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
4683 return new Callback_Topic_getNonReplicatedPublisher<T, CT>(instance, cb, excb, sentcb);
4692 class CallbackNC_Topic_subscribeAndGetPublisher :
public Callback_Topic_subscribeAndGetPublisher_Base,
public ::IceInternal::TwowayCallbackNC<T>
4699 typedef void (T::*Sent)(bool);
4700 typedef void (T::*Response)(const ::Ice::ObjectPrx&);
4702 CallbackNC_Topic_subscribeAndGetPublisher(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
4703 : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
4708 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
4714 ret = proxy->end_subscribeAndGetPublisher(result);
4718 ::IceInternal::CallbackNC<T>::exception(result, ex);
4723 (::IceInternal::CallbackNC<T>::_callback.get()->*_response)(ret);
4741 template<
class T> Callback_Topic_subscribeAndGetPublisherPtr
4744 return new CallbackNC_Topic_subscribeAndGetPublisher<T>(instance, cb, excb, sentcb);
4755 template<
class T> Callback_Topic_subscribeAndGetPublisherPtr
4756 newCallback_Topic_subscribeAndGetPublisher(T* instance,
void (T::*cb)(const ::Ice::ObjectPrx&),
void (T::*excb)(
const ::Ice::Exception&),
void (T::*sentcb)(
bool) = 0)
4758 return new CallbackNC_Topic_subscribeAndGetPublisher<T>(instance, cb, excb, sentcb);
4766 template<
class T,
typename CT>
4767 class Callback_Topic_subscribeAndGetPublisher :
public Callback_Topic_subscribeAndGetPublisher_Base,
public ::IceInternal::TwowayCallback<T, CT>
4774 typedef void (T::*Sent)(bool ,
const CT&);
4775 typedef void (T::*Response)(const ::Ice::ObjectPrx&,
const CT&);
4777 Callback_Topic_subscribeAndGetPublisher(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
4778 : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
4783 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
4789 ret = proxy->end_subscribeAndGetPublisher(result);
4793 ::IceInternal::Callback<T, CT>::exception(result, ex);
4798 (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(ret, CT::dynamicCast(result->getCookie()));
4817 template<
class T,
typename CT> Callback_Topic_subscribeAndGetPublisherPtr
4818 newCallback_Topic_subscribeAndGetPublisher(
const IceUtil::Handle<T>& instance,
void (T::*cb)(const ::Ice::ObjectPrx&,
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
4820 return new Callback_Topic_subscribeAndGetPublisher<T, CT>(instance, cb, excb, sentcb);
4832 template<
class T,
typename CT> Callback_Topic_subscribeAndGetPublisherPtr
4833 newCallback_Topic_subscribeAndGetPublisher(T* instance,
void (T::*cb)(const ::Ice::ObjectPrx&,
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
4835 return new Callback_Topic_subscribeAndGetPublisher<T, CT>(instance, cb, excb, sentcb);
4844 class CallbackNC_Topic_unsubscribe :
public Callback_Topic_unsubscribe_Base,
public ::IceInternal::OnewayCallbackNC<T>
4851 typedef void (T::*Sent)(bool);
4852 typedef void (T::*Response)();
4854 CallbackNC_Topic_unsubscribe(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
4855 : ::IceInternal::OnewayCallbackNC<T>(obj, cb, excb, sentcb)
4868 template<
class T> Callback_Topic_unsubscribePtr
4871 return new CallbackNC_Topic_unsubscribe<T>(instance, cb, excb, sentcb);
4881 template<
class T> Callback_Topic_unsubscribePtr
4884 return new CallbackNC_Topic_unsubscribe<T>(instance, 0, excb, sentcb);
4895 template<
class T> Callback_Topic_unsubscribePtr
4896 newCallback_Topic_unsubscribe(T* instance,
void (T::*cb)(),
void (T::*excb)(
const ::Ice::Exception&),
void (T::*sentcb)(
bool) = 0)
4898 return new CallbackNC_Topic_unsubscribe<T>(instance, cb, excb, sentcb);
4908 template<
class T> Callback_Topic_unsubscribePtr
4909 newCallback_Topic_unsubscribe(T* instance,
void (T::*excb)(
const ::Ice::Exception&),
void (T::*sentcb)(
bool) = 0)
4911 return new CallbackNC_Topic_unsubscribe<T>(instance, 0, excb, sentcb);
4919 template<
class T,
typename CT>
4920 class Callback_Topic_unsubscribe :
public Callback_Topic_unsubscribe_Base,
public ::IceInternal::OnewayCallback<T, CT>
4927 typedef void (T::*Sent)(bool ,
const CT&);
4928 typedef void (T::*Response)(
const CT&);
4930 Callback_Topic_unsubscribe(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
4931 : ::IceInternal::OnewayCallback<T, CT>(obj, cb, excb, sentcb)
4945 template<
class T,
typename CT> Callback_Topic_unsubscribePtr
4948 return new Callback_Topic_unsubscribe<T, CT>(instance, cb, excb, sentcb);
4959 template<
class T,
typename CT> Callback_Topic_unsubscribePtr
4962 return new Callback_Topic_unsubscribe<T, CT>(instance, 0, excb, sentcb);
4974 template<
class T,
typename CT> Callback_Topic_unsubscribePtr
4975 newCallback_Topic_unsubscribe(T* instance,
void (T::*cb)(
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
4977 return new Callback_Topic_unsubscribe<T, CT>(instance, cb, excb, sentcb);
4988 template<
class T,
typename CT> Callback_Topic_unsubscribePtr
4989 newCallback_Topic_unsubscribe(T* instance,
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
4991 return new Callback_Topic_unsubscribe<T, CT>(instance, 0, excb, sentcb);
5000 class CallbackNC_Topic_link :
public Callback_Topic_link_Base,
public ::IceInternal::TwowayCallbackNC<T>
5007 typedef void (T::*Sent)(bool);
5008 typedef void (T::*Response)();
5010 CallbackNC_Topic_link(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
5011 : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
5016 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
5021 proxy->end_link(result);
5025 ::IceInternal::CallbackNC<T>::exception(result, ex);
5030 (::IceInternal::CallbackNC<T>::_callback.get()->*_response)();
5048 template<
class T> Callback_Topic_linkPtr
5051 return new CallbackNC_Topic_link<T>(instance, cb, excb, sentcb);
5061 template<
class T> Callback_Topic_linkPtr
5064 return new CallbackNC_Topic_link<T>(instance, 0, excb, sentcb);
5075 template<
class T> Callback_Topic_linkPtr
5076 newCallback_Topic_link(T* instance,
void (T::*cb)(),
void (T::*excb)(
const ::Ice::Exception&),
void (T::*sentcb)(
bool) = 0)
5078 return new CallbackNC_Topic_link<T>(instance, cb, excb, sentcb);
5088 template<
class T> Callback_Topic_linkPtr
5089 newCallback_Topic_link(T* instance,
void (T::*excb)(
const ::Ice::Exception&),
void (T::*sentcb)(
bool) = 0)
5091 return new CallbackNC_Topic_link<T>(instance, 0, excb, sentcb);
5099 template<
class T,
typename CT>
5100 class Callback_Topic_link :
public Callback_Topic_link_Base,
public ::IceInternal::TwowayCallback<T, CT>
5107 typedef void (T::*Sent)(bool ,
const CT&);
5108 typedef void (T::*Response)(
const CT&);
5110 Callback_Topic_link(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
5111 : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
5116 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
5121 proxy->end_link(result);
5125 ::IceInternal::Callback<T, CT>::exception(result, ex);
5130 (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(CT::dynamicCast(result->getCookie()));
5149 template<
class T,
typename CT> Callback_Topic_linkPtr
5152 return new Callback_Topic_link<T, CT>(instance, cb, excb, sentcb);
5163 template<
class T,
typename CT> Callback_Topic_linkPtr
5166 return new Callback_Topic_link<T, CT>(instance, 0, excb, sentcb);
5178 template<
class T,
typename CT> Callback_Topic_linkPtr
5179 newCallback_Topic_link(T* instance,
void (T::*cb)(
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
5181 return new Callback_Topic_link<T, CT>(instance, cb, excb, sentcb);
5192 template<
class T,
typename CT> Callback_Topic_linkPtr
5193 newCallback_Topic_link(T* instance,
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
5195 return new Callback_Topic_link<T, CT>(instance, 0, excb, sentcb);
5204 class CallbackNC_Topic_unlink :
public Callback_Topic_unlink_Base,
public ::IceInternal::TwowayCallbackNC<T>
5211 typedef void (T::*Sent)(bool);
5212 typedef void (T::*Response)();
5214 CallbackNC_Topic_unlink(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
5215 : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
5220 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
5225 proxy->end_unlink(result);
5229 ::IceInternal::CallbackNC<T>::exception(result, ex);
5234 (::IceInternal::CallbackNC<T>::_callback.get()->*_response)();
5252 template<
class T> Callback_Topic_unlinkPtr
5255 return new CallbackNC_Topic_unlink<T>(instance, cb, excb, sentcb);
5265 template<
class T> Callback_Topic_unlinkPtr
5268 return new CallbackNC_Topic_unlink<T>(instance, 0, excb, sentcb);
5279 template<
class T> Callback_Topic_unlinkPtr
5280 newCallback_Topic_unlink(T* instance,
void (T::*cb)(),
void (T::*excb)(
const ::Ice::Exception&),
void (T::*sentcb)(
bool) = 0)
5282 return new CallbackNC_Topic_unlink<T>(instance, cb, excb, sentcb);
5292 template<
class T> Callback_Topic_unlinkPtr
5293 newCallback_Topic_unlink(T* instance,
void (T::*excb)(
const ::Ice::Exception&),
void (T::*sentcb)(
bool) = 0)
5295 return new CallbackNC_Topic_unlink<T>(instance, 0, excb, sentcb);
5303 template<
class T,
typename CT>
5304 class Callback_Topic_unlink :
public Callback_Topic_unlink_Base,
public ::IceInternal::TwowayCallback<T, CT>
5311 typedef void (T::*Sent)(bool ,
const CT&);
5312 typedef void (T::*Response)(
const CT&);
5314 Callback_Topic_unlink(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
5315 : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
5320 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
5325 proxy->end_unlink(result);
5329 ::IceInternal::Callback<T, CT>::exception(result, ex);
5334 (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(CT::dynamicCast(result->getCookie()));
5353 template<
class T,
typename CT> Callback_Topic_unlinkPtr
5356 return new Callback_Topic_unlink<T, CT>(instance, cb, excb, sentcb);
5367 template<
class T,
typename CT> Callback_Topic_unlinkPtr
5370 return new Callback_Topic_unlink<T, CT>(instance, 0, excb, sentcb);
5382 template<
class T,
typename CT> Callback_Topic_unlinkPtr
5383 newCallback_Topic_unlink(T* instance,
void (T::*cb)(
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
5385 return new Callback_Topic_unlink<T, CT>(instance, cb, excb, sentcb);
5396 template<
class T,
typename CT> Callback_Topic_unlinkPtr
5397 newCallback_Topic_unlink(T* instance,
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
5399 return new Callback_Topic_unlink<T, CT>(instance, 0, excb, sentcb);
5408 class CallbackNC_Topic_getLinkInfoSeq :
public Callback_Topic_getLinkInfoSeq_Base,
public ::IceInternal::TwowayCallbackNC<T>
5415 typedef void (T::*Sent)(bool);
5418 CallbackNC_Topic_getLinkInfoSeq(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
5419 : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
5424 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
5430 ret = proxy->end_getLinkInfoSeq(result);
5434 ::IceInternal::CallbackNC<T>::exception(result, ex);
5439 (::IceInternal::CallbackNC<T>::_callback.get()->*_response)(ret);
5457 template<
class T> Callback_Topic_getLinkInfoSeqPtr
5460 return new CallbackNC_Topic_getLinkInfoSeq<T>(instance, cb, excb, sentcb);
5471 template<
class T> Callback_Topic_getLinkInfoSeqPtr
5474 return new CallbackNC_Topic_getLinkInfoSeq<T>(instance, cb, excb, sentcb);
5482 template<
class T,
typename CT>
5483 class Callback_Topic_getLinkInfoSeq :
public Callback_Topic_getLinkInfoSeq_Base,
public ::IceInternal::TwowayCallback<T, CT>
5490 typedef void (T::*Sent)(bool ,
const CT&);
5491 typedef void (T::*Response)(
const LinkInfoSeq&,
const CT&);
5493 Callback_Topic_getLinkInfoSeq(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
5494 : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
5499 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
5505 ret = proxy->end_getLinkInfoSeq(result);
5509 ::IceInternal::Callback<T, CT>::exception(result, ex);
5514 (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(ret, CT::dynamicCast(result->getCookie()));
5533 template<
class T,
typename CT> Callback_Topic_getLinkInfoSeqPtr
5536 return new Callback_Topic_getLinkInfoSeq<T, CT>(instance, cb, excb, sentcb);
5548 template<
class T,
typename CT> Callback_Topic_getLinkInfoSeqPtr
5549 newCallback_Topic_getLinkInfoSeq(T* instance,
void (T::*cb)(
const LinkInfoSeq&,
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
5551 return new Callback_Topic_getLinkInfoSeq<T, CT>(instance, cb, excb, sentcb);
5560 class CallbackNC_Topic_getSubscribers :
public Callback_Topic_getSubscribers_Base,
public ::IceInternal::TwowayCallbackNC<T>
5567 typedef void (T::*Sent)(bool);
5570 CallbackNC_Topic_getSubscribers(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
5571 : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
5576 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
5582 ret = proxy->end_getSubscribers(result);
5586 ::IceInternal::CallbackNC<T>::exception(result, ex);
5591 (::IceInternal::CallbackNC<T>::_callback.get()->*_response)(ret);
5609 template<
class T> Callback_Topic_getSubscribersPtr
5612 return new CallbackNC_Topic_getSubscribers<T>(instance, cb, excb, sentcb);
5623 template<
class T> Callback_Topic_getSubscribersPtr
5626 return new CallbackNC_Topic_getSubscribers<T>(instance, cb, excb, sentcb);
5634 template<
class T,
typename CT>
5635 class Callback_Topic_getSubscribers :
public Callback_Topic_getSubscribers_Base,
public ::IceInternal::TwowayCallback<T, CT>
5642 typedef void (T::*Sent)(bool ,
const CT&);
5645 Callback_Topic_getSubscribers(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
5646 : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
5651 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
5657 ret = proxy->end_getSubscribers(result);
5661 ::IceInternal::Callback<T, CT>::exception(result, ex);
5666 (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(ret, CT::dynamicCast(result->getCookie()));
5685 template<
class T,
typename CT> Callback_Topic_getSubscribersPtr
5688 return new Callback_Topic_getSubscribers<T, CT>(instance, cb, excb, sentcb);
5700 template<
class T,
typename CT> Callback_Topic_getSubscribersPtr
5703 return new Callback_Topic_getSubscribers<T, CT>(instance, cb, excb, sentcb);
5712 class CallbackNC_Topic_destroy :
public Callback_Topic_destroy_Base,
public ::IceInternal::OnewayCallbackNC<T>
5719 typedef void (T::*Sent)(bool);
5720 typedef void (T::*Response)();
5722 CallbackNC_Topic_destroy(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
5723 : ::IceInternal::OnewayCallbackNC<T>(obj, cb, excb, sentcb)
5736 template<
class T> Callback_Topic_destroyPtr
5739 return new CallbackNC_Topic_destroy<T>(instance, cb, excb, sentcb);
5749 template<
class T> Callback_Topic_destroyPtr
5752 return new CallbackNC_Topic_destroy<T>(instance, 0, excb, sentcb);
5763 template<
class T> Callback_Topic_destroyPtr
5764 newCallback_Topic_destroy(T* instance,
void (T::*cb)(),
void (T::*excb)(
const ::Ice::Exception&),
void (T::*sentcb)(
bool) = 0)
5766 return new CallbackNC_Topic_destroy<T>(instance, cb, excb, sentcb);
5776 template<
class T> Callback_Topic_destroyPtr
5777 newCallback_Topic_destroy(T* instance,
void (T::*excb)(
const ::Ice::Exception&),
void (T::*sentcb)(
bool) = 0)
5779 return new CallbackNC_Topic_destroy<T>(instance, 0, excb, sentcb);
5787 template<
class T,
typename CT>
5788 class Callback_Topic_destroy :
public Callback_Topic_destroy_Base,
public ::IceInternal::OnewayCallback<T, CT>
5795 typedef void (T::*Sent)(bool ,
const CT&);
5796 typedef void (T::*Response)(
const CT&);
5798 Callback_Topic_destroy(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
5799 : ::IceInternal::OnewayCallback<T, CT>(obj, cb, excb, sentcb)
5813 template<
class T,
typename CT> Callback_Topic_destroyPtr
5816 return new Callback_Topic_destroy<T, CT>(instance, cb, excb, sentcb);
5827 template<
class T,
typename CT> Callback_Topic_destroyPtr
5830 return new Callback_Topic_destroy<T, CT>(instance, 0, excb, sentcb);
5842 template<
class T,
typename CT> Callback_Topic_destroyPtr
5843 newCallback_Topic_destroy(T* instance,
void (T::*cb)(
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
5845 return new Callback_Topic_destroy<T, CT>(instance, cb, excb, sentcb);
5856 template<
class T,
typename CT> Callback_Topic_destroyPtr
5857 newCallback_Topic_destroy(T* instance,
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
5859 return new Callback_Topic_destroy<T, CT>(instance, 0, excb, sentcb);
5868 class CallbackNC_TopicManager_create :
public Callback_TopicManager_create_Base,
public ::IceInternal::TwowayCallbackNC<T>
5875 typedef void (T::*Sent)(bool);
5876 typedef void (T::*Response)(
const TopicPrx&);
5878 CallbackNC_TopicManager_create(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
5879 : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
5884 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
5890 ret = proxy->end_create(result);
5894 ::IceInternal::CallbackNC<T>::exception(result, ex);
5899 (::IceInternal::CallbackNC<T>::_callback.get()->*_response)(ret);
5917 template<
class T> Callback_TopicManager_createPtr
5920 return new CallbackNC_TopicManager_create<T>(instance, cb, excb, sentcb);
5931 template<
class T> Callback_TopicManager_createPtr
5932 newCallback_TopicManager_create(T* instance,
void (T::*cb)(
const TopicPrx&),
void (T::*excb)(
const ::Ice::Exception&),
void (T::*sentcb)(
bool) = 0)
5934 return new CallbackNC_TopicManager_create<T>(instance, cb, excb, sentcb);
5942 template<
class T,
typename CT>
5943 class Callback_TopicManager_create :
public Callback_TopicManager_create_Base,
public ::IceInternal::TwowayCallback<T, CT>
5950 typedef void (T::*Sent)(bool ,
const CT&);
5951 typedef void (T::*Response)(
const TopicPrx&,
const CT&);
5953 Callback_TopicManager_create(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
5954 : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
5959 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
5965 ret = proxy->end_create(result);
5969 ::IceInternal::Callback<T, CT>::exception(result, ex);
5974 (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(ret, CT::dynamicCast(result->getCookie()));
5993 template<
class T,
typename CT> Callback_TopicManager_createPtr
5994 newCallback_TopicManager_create(
const IceUtil::Handle<T>& instance,
void (T::*cb)(
const TopicPrx&,
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
5996 return new Callback_TopicManager_create<T, CT>(instance, cb, excb, sentcb);
6008 template<
class T,
typename CT> Callback_TopicManager_createPtr
6009 newCallback_TopicManager_create(T* instance,
void (T::*cb)(
const TopicPrx&,
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
6011 return new Callback_TopicManager_create<T, CT>(instance, cb, excb, sentcb);
6020 class CallbackNC_TopicManager_retrieve :
public Callback_TopicManager_retrieve_Base,
public ::IceInternal::TwowayCallbackNC<T>
6027 typedef void (T::*Sent)(bool);
6028 typedef void (T::*Response)(
const TopicPrx&);
6030 CallbackNC_TopicManager_retrieve(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
6031 : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
6036 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
6042 ret = proxy->end_retrieve(result);
6046 ::IceInternal::CallbackNC<T>::exception(result, ex);
6051 (::IceInternal::CallbackNC<T>::_callback.get()->*_response)(ret);
6069 template<
class T> Callback_TopicManager_retrievePtr
6072 return new CallbackNC_TopicManager_retrieve<T>(instance, cb, excb, sentcb);
6083 template<
class T> Callback_TopicManager_retrievePtr
6084 newCallback_TopicManager_retrieve(T* instance,
void (T::*cb)(
const TopicPrx&),
void (T::*excb)(
const ::Ice::Exception&),
void (T::*sentcb)(
bool) = 0)
6086 return new CallbackNC_TopicManager_retrieve<T>(instance, cb, excb, sentcb);
6094 template<
class T,
typename CT>
6095 class Callback_TopicManager_retrieve :
public Callback_TopicManager_retrieve_Base,
public ::IceInternal::TwowayCallback<T, CT>
6102 typedef void (T::*Sent)(bool ,
const CT&);
6103 typedef void (T::*Response)(
const TopicPrx&,
const CT&);
6105 Callback_TopicManager_retrieve(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
6106 : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
6111 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
6117 ret = proxy->end_retrieve(result);
6121 ::IceInternal::Callback<T, CT>::exception(result, ex);
6126 (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(ret, CT::dynamicCast(result->getCookie()));
6145 template<
class T,
typename CT> Callback_TopicManager_retrievePtr
6146 newCallback_TopicManager_retrieve(
const IceUtil::Handle<T>& instance,
void (T::*cb)(
const TopicPrx&,
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
6148 return new Callback_TopicManager_retrieve<T, CT>(instance, cb, excb, sentcb);
6160 template<
class T,
typename CT> Callback_TopicManager_retrievePtr
6161 newCallback_TopicManager_retrieve(T* instance,
void (T::*cb)(
const TopicPrx&,
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
6163 return new Callback_TopicManager_retrieve<T, CT>(instance, cb, excb, sentcb);
6172 class CallbackNC_TopicManager_retrieveAll :
public Callback_TopicManager_retrieveAll_Base,
public ::IceInternal::TwowayCallbackNC<T>
6179 typedef void (T::*Sent)(bool);
6180 typedef void (T::*Response)(
const TopicDict&);
6182 CallbackNC_TopicManager_retrieveAll(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
6183 : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
6188 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
6194 ret = proxy->end_retrieveAll(result);
6198 ::IceInternal::CallbackNC<T>::exception(result, ex);
6203 (::IceInternal::CallbackNC<T>::_callback.get()->*_response)(ret);
6221 template<
class T> Callback_TopicManager_retrieveAllPtr
6224 return new CallbackNC_TopicManager_retrieveAll<T>(instance, cb, excb, sentcb);
6235 template<
class T> Callback_TopicManager_retrieveAllPtr
6236 newCallback_TopicManager_retrieveAll(T* instance,
void (T::*cb)(
const TopicDict&),
void (T::*excb)(
const ::Ice::Exception&),
void (T::*sentcb)(
bool) = 0)
6238 return new CallbackNC_TopicManager_retrieveAll<T>(instance, cb, excb, sentcb);
6246 template<
class T,
typename CT>
6247 class Callback_TopicManager_retrieveAll :
public Callback_TopicManager_retrieveAll_Base,
public ::IceInternal::TwowayCallback<T, CT>
6254 typedef void (T::*Sent)(bool ,
const CT&);
6255 typedef void (T::*Response)(
const TopicDict&,
const CT&);
6257 Callback_TopicManager_retrieveAll(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
6258 : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
6263 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
6269 ret = proxy->end_retrieveAll(result);
6273 ::IceInternal::Callback<T, CT>::exception(result, ex);
6278 (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(ret, CT::dynamicCast(result->getCookie()));
6297 template<
class T,
typename CT> Callback_TopicManager_retrieveAllPtr
6300 return new Callback_TopicManager_retrieveAll<T, CT>(instance, cb, excb, sentcb);
6312 template<
class T,
typename CT> Callback_TopicManager_retrieveAllPtr
6313 newCallback_TopicManager_retrieveAll(T* instance,
void (T::*cb)(
const TopicDict&,
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
6315 return new Callback_TopicManager_retrieveAll<T, CT>(instance, cb, excb, sentcb);
6324 class CallbackNC_TopicManager_getSliceChecksums :
public Callback_TopicManager_getSliceChecksums_Base,
public ::IceInternal::TwowayCallbackNC<T>
6331 typedef void (T::*Sent)(bool);
6334 CallbackNC_TopicManager_getSliceChecksums(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
6335 : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
6340 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
6346 ret = proxy->end_getSliceChecksums(result);
6350 ::IceInternal::CallbackNC<T>::exception(result, ex);
6355 (::IceInternal::CallbackNC<T>::_callback.get()->*_response)(ret);
6373 template<
class T> Callback_TopicManager_getSliceChecksumsPtr
6376 return new CallbackNC_TopicManager_getSliceChecksums<T>(instance, cb, excb, sentcb);
6387 template<
class T> Callback_TopicManager_getSliceChecksumsPtr
6390 return new CallbackNC_TopicManager_getSliceChecksums<T>(instance, cb, excb, sentcb);
6398 template<
class T,
typename CT>
6399 class Callback_TopicManager_getSliceChecksums :
public Callback_TopicManager_getSliceChecksums_Base,
public ::IceInternal::TwowayCallback<T, CT>
6406 typedef void (T::*Sent)(bool ,
const CT&);
6409 Callback_TopicManager_getSliceChecksums(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
6410 : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
6415 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
6421 ret = proxy->end_getSliceChecksums(result);
6425 ::IceInternal::Callback<T, CT>::exception(result, ex);
6430 (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(ret, CT::dynamicCast(result->getCookie()));
6449 template<
class T,
typename CT> Callback_TopicManager_getSliceChecksumsPtr
6452 return new Callback_TopicManager_getSliceChecksums<T, CT>(instance, cb, excb, sentcb);
6464 template<
class T,
typename CT> Callback_TopicManager_getSliceChecksumsPtr
6467 return new Callback_TopicManager_getSliceChecksums<T, CT>(instance, cb, excb, sentcb);
6476 class CallbackNC_Finder_getTopicManager :
public Callback_Finder_getTopicManager_Base,
public ::IceInternal::TwowayCallbackNC<T>
6483 typedef void (T::*Sent)(bool);
6484 typedef void (T::*Response)(
const TopicManagerPrx&);
6486 CallbackNC_Finder_getTopicManager(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
6487 : ::IceInternal::TwowayCallbackNC<T>(obj, cb != 0, excb, sentcb), _response(cb)
6492 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
6495 TopicManagerPrx ret;
6498 ret = proxy->end_getTopicManager(result);
6502 ::IceInternal::CallbackNC<T>::exception(result, ex);
6507 (::IceInternal::CallbackNC<T>::_callback.get()->*_response)(ret);
6525 template<
class T> Callback_Finder_getTopicManagerPtr
6528 return new CallbackNC_Finder_getTopicManager<T>(instance, cb, excb, sentcb);
6539 template<
class T> Callback_Finder_getTopicManagerPtr
6540 newCallback_Finder_getTopicManager(T* instance,
void (T::*cb)(
const TopicManagerPrx&),
void (T::*excb)(
const ::Ice::Exception&),
void (T::*sentcb)(
bool) = 0)
6542 return new CallbackNC_Finder_getTopicManager<T>(instance, cb, excb, sentcb);
6550 template<
class T,
typename CT>
6551 class Callback_Finder_getTopicManager :
public Callback_Finder_getTopicManager_Base,
public ::IceInternal::TwowayCallback<T, CT>
6558 typedef void (T::*Sent)(bool ,
const CT&);
6559 typedef void (T::*Response)(
const TopicManagerPrx&,
const CT&);
6561 Callback_Finder_getTopicManager(
const TPtr& obj, Response cb,
Exception excb, Sent sentcb)
6562 : ::IceInternal::TwowayCallback<T, CT>(obj, cb != 0, excb, sentcb), _response(cb)
6567 virtual void completed(const ::Ice::AsyncResultPtr& result)
const
6570 TopicManagerPrx ret;
6573 ret = proxy->end_getTopicManager(result);
6577 ::IceInternal::Callback<T, CT>::exception(result, ex);
6582 (::IceInternal::Callback<T, CT>::_callback.get()->*_response)(ret, CT::dynamicCast(result->getCookie()));
6601 template<
class T,
typename CT> Callback_Finder_getTopicManagerPtr
6602 newCallback_Finder_getTopicManager(
const IceUtil::Handle<T>& instance,
void (T::*cb)(
const TopicManagerPrx&,
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
6604 return new Callback_Finder_getTopicManager<T, CT>(instance, cb, excb, sentcb);
6616 template<
class T,
typename CT> Callback_Finder_getTopicManagerPtr
6617 newCallback_Finder_getTopicManager(T* instance,
void (T::*cb)(
const TopicManagerPrx&,
const CT&),
void (T::*excb)(
const ::Ice::Exception&,
const CT&),
void (T::*sentcb)(
bool,
const CT&) = 0)
6619 return new Callback_Finder_getTopicManager<T, CT>(instance, cb, excb, sentcb);