Instance Class Reference

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

+ Inheritance diagram for Instance:

Public Types

enum  SendQueueSizeMaxPolicy { RemoveSubscriber , DropEvents }
 

Public Member Functions

IceUtil::TimerPtr batchFlusher () const
 
Ice::CommunicatorPtr communicator () const
 
virtual void destroy ()
 
IceUtil::Time discardInterval () const
 
IceUtil::Time flushInterval () const
 
 Instance (const std::string &, const std::string &, const Ice::CommunicatorPtr &, const Ice::ObjectAdapterPtr &, const Ice::ObjectAdapterPtr &, const Ice::ObjectAdapterPtr &=0, const IceStormElection::NodePrx &=0)
 
std::string instanceName () const
 
IceStormElection::NodeIPtr node () const
 
Ice::ObjectAdapterPtr nodeAdapter () const
 
IceStormElection::NodePrx nodeProxy () const
 
IceStorm::Instrumentation::TopicManagerObserverPtr observer () const
 
IceStormElection::ObserversPtr observers () const
 
Ice::PropertiesPtr properties () const
 
Ice::ObjectAdapterPtr publishAdapter () const
 
Ice::ObjectPrx publisherReplicaProxy () const
 
int sendQueueSizeMax () const
 
SendQueueSizeMaxPolicy sendQueueSizeMaxPolicy () const
 
int sendTimeout () const
 
std::string serviceName () const
 
void setNode (const IceStormElection::NodeIPtr &)
 
void shutdown ()
 
IceUtil::TimerPtr timer () const
 
Ice::ObjectAdapterPtr topicAdapter () const
 
TopicReaperPtr topicReaper () const
 
Ice::ObjectPrx topicReplicaProxy () const
 
TraceLevelsPtr traceLevels () const
 

Member Enumeration Documentation

◆ SendQueueSizeMaxPolicy

Enumerator
RemoveSubscriber 
DropEvents 

Constructor & Destructor Documentation

◆ Instance()

Instance ( const std::string & ,
const std::string & ,
const Ice::CommunicatorPtr & ,
const Ice::ObjectAdapterPtr & ,
const Ice::ObjectAdapterPtr & ,
const Ice::ObjectAdapterPtr & = 0,
const IceStormElection::NodePrx & = 0 )

Member Function Documentation

◆ batchFlusher()

IceUtil::TimerPtr batchFlusher ( ) const

◆ communicator()

Ice::CommunicatorPtr communicator ( ) const

◆ destroy()

void destroy ( )
virtual

Reimplemented in PersistentInstance.

◆ discardInterval()

IceUtil::Time discardInterval ( ) const

◆ flushInterval()

IceUtil::Time flushInterval ( ) const

◆ instanceName()

string instanceName ( ) const

◆ node()

NodeIPtr node ( ) const

◆ nodeAdapter()

Ice::ObjectAdapterPtr nodeAdapter ( ) const

◆ nodeProxy()

NodePrx nodeProxy ( ) const

◆ observer()

◆ observers()

ObserversPtr observers ( ) const

◆ properties()

Ice::PropertiesPtr properties ( ) const

◆ publishAdapter()

Ice::ObjectAdapterPtr publishAdapter ( ) const

◆ publisherReplicaProxy()

Ice::ObjectPrx publisherReplicaProxy ( ) const

◆ sendQueueSizeMax()

int sendQueueSizeMax ( ) const

◆ sendQueueSizeMaxPolicy()

Instance::SendQueueSizeMaxPolicy sendQueueSizeMaxPolicy ( ) const

◆ sendTimeout()

int sendTimeout ( ) const

◆ serviceName()

string serviceName ( ) const

◆ setNode()

void setNode ( const IceStormElection::NodeIPtr & node)

◆ shutdown()

void shutdown ( )

◆ timer()

IceUtil::TimerPtr timer ( ) const

◆ topicAdapter()

Ice::ObjectAdapterPtr topicAdapter ( ) const

◆ topicReaper()

IceStorm::TopicReaperPtr topicReaper ( ) const

◆ topicReplicaProxy()

Ice::ObjectPrx topicReplicaProxy ( ) const

◆ traceLevels()

TraceLevelsPtr traceLevels ( ) const

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