List of all members | Public Types | Public Member Functions | Static Public Member Functions | Protected Member Functions | Protected Attributes
Subscriber Class Referenceabstract

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

+ Inheritance diagram for Subscriber:

Public Types

enum  SubscriberState { SubscriberStateOnline, SubscriberStateOffline, SubscriberStateError, SubscriberStateReaped }
 

Public Member Functions

void completed (const Ice::AsyncResultPtr &)
 
void destroy ()
 
void error (bool, const Ice::Exception &)
 
bool errored () const
 
virtual void flush ()=0
 
Ice::Identity id () const
 
Ice::ObjectPrx proxy () const
 
bool queue (bool, const EventDataSeq &)
 
bool reap ()
 
IceStorm::SubscriberRecord record () const
 
void resetIfReaped ()
 
void shutdown ()
 
void updateObserver ()
 

Static Public Member Functions

static SubscriberPtr create (const InstancePtr &, const IceStorm::SubscriberRecord &)
 

Protected Member Functions

void setState (SubscriberState)
 
 Subscriber (const InstancePtr &, const IceStorm::SubscriberRecord &, const Ice::ObjectPrx &, int, int)
 

Protected Attributes

int _currentRetry
 
EventDataSeq _events
 
const InstancePtr _instance
 
IceUtil::Monitor< IceUtil::RecMutex > _lock
 
const int _maxOutstanding
 
IceUtil::Time _next
 
IceInternal::ObserverHelperT< IceStorm::Instrumentation::SubscriberObserver > _observer
 
int _outstanding
 
int _outstandingCount
 
const Ice::ObjectPrx _proxy
 
const Ice::ObjectPrx _proxyReplica
 
const IceStorm::SubscriberRecord _rec
 
const int _retryCount
 
bool _shutdown
 
SubscriberState _state
 

Detailed Description

Definition at line 28 of file Subscriber.h.

Member Enumeration Documentation

◆ SubscriberState

enum SubscriberState
Enumerator
SubscriberStateOnline 
SubscriberStateOffline 
SubscriberStateError 
SubscriberStateReaped 

Definition at line 54 of file Subscriber.h.

Constructor & Destructor Documentation

◆ Subscriber()

Subscriber ( const InstancePtr &  instance,
const IceStorm::SubscriberRecord &  rec,
const Ice::ObjectPrx &  proxy,
int  retryCount,
int  maxOutstanding 
)
protected

Definition at line 965 of file Subscriber.cpp.

Member Function Documentation

◆ completed()

void completed ( const Ice::AsyncResultPtr &  result)

Definition at line 898 of file Subscriber.cpp.

◆ create()

SubscriberPtr create ( const InstancePtr &  instance,
const IceStorm::SubscriberRecord &  rec 
)
static

Definition at line 522 of file Subscriber.cpp.

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ destroy()

void destroy ( )

Definition at line 759 of file Subscriber.cpp.

◆ error()

void error ( bool  dec,
const Ice::Exception &  e 
)

Definition at line 785 of file Subscriber.cpp.

+ Here is the call graph for this function:

◆ errored()

bool errored ( ) const

Definition at line 752 of file Subscriber.cpp.

◆ flush()

virtual void flush ( )
pure virtual

◆ id()

Ice::Identity id ( ) const

Definition at line 651 of file Subscriber.cpp.

◆ proxy()

Ice::ObjectPrx proxy ( ) const

Definition at line 645 of file Subscriber.cpp.

◆ queue()

bool queue ( bool  forwarded,
const EventDataSeq &  events 
)

Definition at line 663 of file Subscriber.cpp.

◆ reap()

bool reap ( )

Definition at line 729 of file Subscriber.cpp.

◆ record()

SubscriberRecord record ( ) const

Definition at line 657 of file Subscriber.cpp.

◆ resetIfReaped()

void resetIfReaped ( )

Definition at line 742 of file Subscriber.cpp.

◆ setState()

void setState ( Subscriber::SubscriberState  state)
protected

Definition at line 1025 of file Subscriber.cpp.

+ Here is the call graph for this function:

◆ shutdown()

void shutdown ( )

Definition at line 936 of file Subscriber.cpp.

◆ updateObserver()

void updateObserver ( )

Definition at line 950 of file Subscriber.cpp.

Member Data Documentation

◆ _currentRetry

int _currentRetry
protected

Definition at line 90 of file Subscriber.h.

◆ _events

EventDataSeq _events
protected

Definition at line 86 of file Subscriber.h.

◆ _instance

const InstancePtr _instance
protected

Definition at line 71 of file Subscriber.h.

◆ _lock

IceUtil::Monitor<IceUtil::RecMutex> _lock
protected

Definition at line 78 of file Subscriber.h.

◆ _maxOutstanding

const int _maxOutstanding
protected

Definition at line 74 of file Subscriber.h.

◆ _next

IceUtil::Time _next
protected

Definition at line 89 of file Subscriber.h.

◆ _observer

IceInternal::ObserverHelperT<IceStorm::Instrumentation::SubscriberObserver> _observer
protected

Definition at line 92 of file Subscriber.h.

◆ _outstanding

int _outstanding
protected

Definition at line 84 of file Subscriber.h.

◆ _outstandingCount

int _outstandingCount
protected

Definition at line 85 of file Subscriber.h.

◆ _proxy

const Ice::ObjectPrx _proxy
protected

Definition at line 75 of file Subscriber.h.

◆ _proxyReplica

const Ice::ObjectPrx _proxyReplica
protected

Definition at line 76 of file Subscriber.h.

◆ _rec

const IceStorm::SubscriberRecord _rec
protected

Definition at line 72 of file Subscriber.h.

◆ _retryCount

const int _retryCount
protected

Definition at line 73 of file Subscriber.h.

◆ _shutdown

bool _shutdown
protected

Definition at line 80 of file Subscriber.h.

◆ _state

SubscriberState _state
protected

Definition at line 82 of file Subscriber.h.

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