#include <EventManager.hpp>

Inheritance diagram for kaa::EventManager:

Collaboration diagram for kaa::EventManager:

Public Member Functions
	EventManager (IKaaClientStateStoragePtr status)

virtual void	registerEventFamily (IEventFamily *eventFamily)

virtual void	produceEvent (const std::string &fqn, const std::vector< std::uint8_t > &data, const std::string &target, TransactionIdPtr trxId)

virtual void	onEventsReceived (const EventSyncResponse::events_t &events)

virtual void	onEventListenersReceived (const EventSyncResponse::eventListenersResponses_t &listeners)

virtual std::map< std::int32_t, Event >	releasePendingEvents ()

virtual bool	hasPendingEvents () const

virtual std::map< std::int32_t, std::list< std::string > >	getPendingListenerRequests ()

virtual bool	hasPendingListenerRequests () const

virtual std::int32_t	findEventListeners (const std::list< std::string > &eventFQNs, IFetchEventListenersPtr listener)

virtual void	setTransport (EventTransport *transport)

virtual TransactionIdPtr	beginTransaction ()

virtual void	commit (TransactionIdPtr trxId)

virtual void	rollback (TransactionIdPtr trxId)

Public Member Functions inherited from kaa::IEventManager
virtual	~IEventManager ()

Public Member Functions inherited from kaa::IEventListenersResolver
virtual	~IEventListenersResolver ()

Public Member Functions inherited from kaa::IEventDataProcessor
virtual	~IEventDataProcessor ()

Public Member Functions inherited from kaa::AbstractTransactable< std::list< Event > >
std::list< Event > &	getContainerByTrxId (TransactionIdPtr trxId)

virtual	~AbstractTransactable ()

Public Member Functions inherited from kaa::ITransactable
virtual	~ITransactable ()

Additional Inherited Members
Protected Member Functions inherited from kaa::AbstractTransactable< std::list< Event > >
	KAA_MUTEX_DECLARE (transactionsGuard_)

Protected Attributes inherited from kaa::AbstractTransactable< std::list< Event > >
std::map< TransactionIdPtr, std::list< Event > >	transactions_

Detailed Description

Definition at line 39 of file EventManager.hpp.

Constructor & Destructor Documentation

kaa::EventManager::EventManager ( IKaaClientStateStoragePtr status )

inline

Definition at line 45 of file EventManager.hpp.

Member Function Documentation

virtual TransactionIdPtr kaa::EventManager::beginTransaction ( )

inlinevirtual

Create new transaction.

Returns: TransactionId object which must be used to submit or rollback the transaction.

Reimplemented from kaa::AbstractTransactable< std::list< Event > >.

Definition at line 71 of file EventManager.hpp.

virtual void kaa::EventManager::commit ( TransactionIdPtr trxId )

virtual

Finish the transaction.

Parameters

trxId Identifier of the transaction which must be finished.

Implements kaa::ITransactable.

virtual std::int32_t kaa::EventManager::findEventListeners	(	const std::list< std::string > &	eventFQNs,
		IFetchEventListenersPtr	listener
	)

virtual

Submits an event listeners resolution request

Parameters

eventFQNs	List of event class FQNs which have to be supported by endpoint.
listener	Result listener IFetchEventListeners}

Exceptions

KaaException when data is invalid (empty list or null listener)

Returns: Request ID of submitted request

Implements kaa::IEventListenersResolver.

virtual std::map<std::int32_t, std::list<std::string> > kaa::EventManager::getPendingListenerRequests ( )

virtual

Implements kaa::IEventDataProcessor.

virtual bool kaa::EventManager::hasPendingEvents ( ) const

virtual

Implements kaa::IEventDataProcessor.

virtual bool kaa::EventManager::hasPendingListenerRequests ( ) const

virtual

Implements kaa::IEventDataProcessor.

virtual void kaa::EventManager::onEventListenersReceived ( const EventSyncResponse::eventListenersResponses_t & listeners )

virtual

Implements kaa::IEventDataProcessor.

virtual void kaa::EventManager::onEventsReceived ( const EventSyncResponse::events_t & events )

virtual

Implements kaa::IEventDataProcessor.

virtual void kaa::EventManager::produceEvent	(	const std::string &	fqn,
		const std::vector< std::uint8_t > &	data,
		const std::string &	target,
		TransactionIdPtr	trxId
	)

virtual

Creates an Event and passes it to OPS

Parameters

eventFqn	Fully qualified name of the Event
data	Event data
target	Event target, null for event broadcasting.

Implements kaa::IEventManager.

virtual void kaa::EventManager::registerEventFamily ( IEventFamily * eventFamily )

virtual

Add event family object which can handle specified event.

Parameters

eventFamily event family instance

See also: IEventFamily

Implements kaa::IEventManager.

virtual std::map<std::int32_t, Event> kaa::EventManager::releasePendingEvents ( )

virtual

Implements kaa::IEventDataProcessor.

virtual void kaa::EventManager::rollback ( TransactionIdPtr trxId )

inlinevirtual

Rollback changes for given transaction.

Parameters

trxId Identifier of the transaction which must be removed withot applying changes.

Reimplemented from kaa::AbstractTransactable< std::list< Event > >.

Definition at line 78 of file EventManager.hpp.

virtual void kaa::EventManager::setTransport ( EventTransport * transport )

virtual

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

/var/lib/jenkins/workspace/kaa_stable/client/client-multi/client-cpp/kaa/event/EventManager.hpp

Public Member Functions

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation