TopicImpl Class Reference

#include <ArmarXCore/applications/ArmarXStorm/IceStorm/TopicI.h>

+ Inheritance diagram for TopicImpl:

Public Member Functions

void destroy ()
 
bool destroyed () const
 
IceStormElection::TopicContent getContent () const
 
LinkInfoSeq getLinkInfoSeq () const
 
TopicLinkPrx getLinkProxy ()
 
std::string getName () const
 
Ice::ObjectPrx getNonReplicatedPublisher () const
 
Ice::ObjectPrx getPublisher () const
 
Ice::ObjectPtr getServant () const
 
Ice::IdentitySeq getSubscribers () const
 
Ice::Identity id () const
 
void link (const TopicPrx &, Ice::Int)
 
void observerAddSubscriber (const IceStormElection::LogUpdate &, const SubscriberRecord &)
 
void observerDestroyTopic (const IceStormElection::LogUpdate &)
 
void observerRemoveSubscriber (const IceStormElection::LogUpdate &, const Ice::IdentitySeq &)
 
TopicPrx proxy () const
 
void publish (bool, const EventDataSeq &)
 
void reap (const Ice::IdentitySeq &)
 
void shutdown ()
 
Ice::ObjectPrx subscribeAndGetPublisher (const QoS &, const Ice::ObjectPrx &)
 
 TopicImpl (const PersistentInstancePtr &, const std::string &, const Ice::Identity &, const SubscriberRecordSeq &)
 
void unlink (const TopicPrx &)
 
void unsubscribe (const Ice::ObjectPrx &)
 
void update (const SubscriberRecordSeq &)
 
void updateObserver ()
 
void updateSubscriberObservers ()
 

Constructor & Destructor Documentation

◆ TopicImpl()

TopicImpl ( const PersistentInstancePtr & ,
const std::string & ,
const Ice::Identity & ,
const SubscriberRecordSeq &  )

Member Function Documentation

◆ destroy()

void destroy ( )

◆ destroyed()

bool destroyed ( ) const

◆ getContent()

TopicContent getContent ( ) const

◆ getLinkInfoSeq()

LinkInfoSeq getLinkInfoSeq ( ) const

◆ getLinkProxy()

TopicLinkPrx getLinkProxy ( )

◆ getName()

string getName ( ) const

◆ getNonReplicatedPublisher()

Ice::ObjectPrx getNonReplicatedPublisher ( ) const

◆ getPublisher()

Ice::ObjectPrx getPublisher ( ) const

◆ getServant()

Ice::ObjectPtr getServant ( ) const

◆ getSubscribers()

Ice::IdentitySeq getSubscribers ( ) const

◆ id()

Ice::Identity id ( ) const

◆ link()

void link ( const TopicPrx & topic,
Ice::Int cost )

◆ observerAddSubscriber()

void observerAddSubscriber ( const IceStormElection::LogUpdate & llu,
const SubscriberRecord & record )

◆ observerDestroyTopic()

void observerDestroyTopic ( const IceStormElection::LogUpdate & llu)

◆ observerRemoveSubscriber()

void observerRemoveSubscriber ( const IceStormElection::LogUpdate & llu,
const Ice::IdentitySeq & ids )

◆ proxy()

TopicPrx proxy ( ) const

◆ publish()

void publish ( bool forwarded,
const EventDataSeq & events )

◆ reap()

void reap ( const Ice::IdentitySeq & ids)

◆ shutdown()

void shutdown ( )

◆ subscribeAndGetPublisher()

Ice::ObjectPrx subscribeAndGetPublisher ( const QoS & qos,
const Ice::ObjectPrx & obj )

◆ unlink()

void unlink ( const TopicPrx & topic)

◆ unsubscribe()

void unsubscribe ( const Ice::ObjectPrx & subscriber)

◆ update()

void update ( const SubscriberRecordSeq & records)

◆ updateObserver()

void updateObserver ( )

◆ updateSubscriberObservers()

void updateSubscriberObservers ( )

The documentation for this class was generated from the following files: