Subscriber Class Reference

#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

Member Enumeration Documentation

SubscriberState

enum SubscriberState

Enumerator
SubscriberStateOnline
SubscriberStateOffline
SubscriberStateError
SubscriberStateReaped

Constructor & Destructor Documentation

Subscriber()

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

protected

Member Function Documentation

completed()

void completed

(

const Ice::AsyncResultPtr &

result

)

create()

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

static

destroy()

void destroy

(

)

error()

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

errored()

bool errored

(

)

const

flush()

virtual void flush ( )

pure virtual

id()

Ice::Identity id

(

)

const

proxy()

Ice::ObjectPrx proxy

(

)

const

queue()

bool queue	(	bool	forwarded,
		const EventDataSeq &	events )

reap()

bool reap

(

)

record()

SubscriberRecord record

(

)

const

resetIfReaped()

void resetIfReaped

(

)

setState()

void setState ( Subscriber::SubscriberState state )

protected

shutdown()

void shutdown

(

)

updateObserver()

void updateObserver

(

)

Member Data Documentation

_currentRetry

int _currentRetry

protected

_events

EventDataSeq _events

protected

_instance

const InstancePtr _instance

protected

_lock

IceUtil::Monitor<IceUtil::RecMutex> _lock

protected

_maxOutstanding

const int _maxOutstanding

protected

_next

IceUtil::Time _next

protected

_observer

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

protected

_outstanding

int _outstanding

protected

_outstandingCount

int _outstandingCount

protected

_proxy

const Ice::ObjectPrx _proxy

protected

_proxyReplica

const Ice::ObjectPrx _proxyReplica

protected

_rec

const IceStorm::SubscriberRecord _rec

protected

_retryCount

const int _retryCount

protected

_shutdown

bool _shutdown

protected

_state

SubscriberState _state

protected

---

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

• ArmarXCore/applications/ArmarXStorm/IceStorm/Subscriber.h
• ArmarXCore/applications/ArmarXStorm/IceStorm/Subscriber.cpp