RSB
0.7.0
|
Namespaces | |
namespace | converter |
namespace | detail |
namespace | eventprocessing |
namespace | filter |
namespace | inprocess |
namespace | patterns |
namespace | protocol |
namespace | spread |
namespace | transport |
namespace | util |
Classes | |
class | CommException |
General exception thrown upon communication errors. More... | |
class | Event |
Basic message that is exchanged between informers and listeners. More... | |
class | EventId |
A unique ID for events in RSB. More... | |
class | EventQueuePushHandler |
A rsb::Handler for rsb::Listener s that pushes all received events on a rsc::SynchronizedQueue. More... | |
class | Exception |
class | Factory |
Factory for RSB user-level domain objects for communication patterns. More... | |
class | Handler |
Asynchronously called handler interface on the client level. More... | |
class | EventFunctionHandler |
A utility class to simplify event handling in ordinary functions or member functions. More... | |
class | DataFunctionHandler |
A utility class to simplify data handling by automatically passing the data of the desired type to a function. More... | |
class | DataHandler |
A Handler that automatically performs the desired type casting. More... | |
class | FilteringHandler |
A utility class that forwards events to another rsb::Handler object if they match a given rsb::filter::Filter. More... | |
class | AnyType |
A tag type for constructing Informer instances that can publish data of arbitrary types. More... | |
class | InformerBase |
A informer to publish data. More... | |
class | Informer |
A informer to publish data of a specified type expressed through the template parameter. More... | |
class | Listener |
A Listener receives events published by rsb::Informer objects by participating in a channel with a suitable scope. More... | |
class | LocalService |
A Service implementation that structures services locally. More... | |
class | MetaData |
Framework-supplied meta data attached to each event that give information e.g. More... | |
class | Participant |
Objects of this class participate in the exchange of notifications on one channel of the bus. More... | |
class | ParticipantConfig |
A class describing the configuration of Participant instances. More... | |
class | QualityOfServiceSpec |
Specification of desired quality of service settings for sending and receiving events. More... | |
class | QueuePushHandler |
A rsb::Handler for rsb::Listener s that pushes all received data on a rsc::SynchronizedQueue. More... | |
class | Reader |
A Reader receives events published by a informers by participating in a channel with a suitable scope. More... | |
class | Scope |
Scope is a descriptor for a hierarchical channel of the unified bus. More... | |
class | Service |
A service provides a hierarchical structure for organizing participants. More... | |
class | UnsupportedQualityOfServiceException |
An exception indicating that a desired QualityOfServiceSpec cannot be reached by a transport. More... |
Typedefs | |
typedef boost::shared_ptr < EventId > | EventIdPtr |
typedef boost::shared_ptr< Scope > | ScopePtr |
typedef boost::shared_ptr< void > | VoidPtr |
typedef boost::shared_ptr< Event > | EventPtr |
typedef std::pair< std::string, boost::shared_ptr< void > > | AnnotatedData |
A combination of data type and the actual data. | |
typedef std::map< rsb::Scope, std::vector< rsb::EventPtr > > | EventsByScopeMap |
typedef boost::shared_ptr < Handler > | HandlerPtr |
typedef boost::function< void(EventPtr)> | EventFunction |
typedef boost::shared_ptr < InformerBase > | InformerBasePtr |
typedef boost::shared_ptr < Listener > | ListenerPtr |
typedef boost::shared_ptr < Participant > | ParticipantPtr |
typedef boost::shared_ptr< Reader > | ReaderPtr |
typedef boost::shared_ptr < Service > | ServicePtr |
Functions | |
InformerBasePtr | crateInformerBase (const Scope &scope, const std::string &dataType, const ParticipantConfig &config=Factory::getInstance().getDefaultParticipantConfig()) |
Creates and returns a new Informer that publishes Event s under the Scope scope. | |
ListenerPtr | createListener (const Scope &scope, const ParticipantConfig &config=Factory::getInstance().getDefaultParticipantConfig()) |
Creates and returns a new Listener for the Scope scope. | |
ReaderPtr | createReader (const Scope &scope, const ParticipantConfig &config=Factory::getInstance().getDefaultParticipantConfig()) |
Creates and returns a new Reader object for Scope scope. | |
ServicePtr | createService (const Scope &scope) |
Creates and returns a Service instance operating on Scope scope. | |
patterns::ServerPtr | createServer (const Scope &scope) |
Creates and returns a Server object that exposes methods under the Scope scope. | |
patterns::RemoteServerPtr | createRemoteServer (const Scope &scope) |
Creates and returns a RemoteServer object for the server at Scope scope. | |
template<class DataType > | |
Informer< DataType >::Ptr | createInformer (const Scope &scope, const ParticipantConfig &config=Factory::getInstance().getDefaultParticipantConfig(), const std::string &dataType=detail::TypeName< DataType >()()) |
Creates and returns a new Informer that publishes Event s under the Scope scope. | |
ostream & | operator<< (ostream &stream, const MetaData &meta) |
ostream & | operator<< (ostream &stream, const QualityOfServiceSpec &spec) |
void | verifyAndSplit (const string &s, vector< string > &components, string &normalizedString) |
Validate that s satisfies the regular expression /([a-zA-Z0-9]+/)* and split at '/' characters. | |
ostream & | operator<< (ostream &stream, const Scope &scope) |
typedef std::pair<std::string, boost::shared_ptr<void> > rsb::AnnotatedData |
typedef boost::function<void(EventPtr)> rsb::EventFunction |
typedef boost::shared_ptr< EventId > rsb::EventIdPtr |
typedef boost::shared_ptr< Event > rsb::EventPtr |
typedef std::map<rsb::Scope, std::vector<rsb::EventPtr> > rsb::EventsByScopeMap |
Definition at line 44 of file EventCollections.h.
typedef boost::shared_ptr< Handler > rsb::HandlerPtr |
typedef boost::shared_ptr<InformerBase> rsb::InformerBasePtr |
Definition at line 208 of file Informer.h.
typedef boost::shared_ptr<Listener> rsb::ListenerPtr |
Definition at line 150 of file Listener.h.
typedef boost::shared_ptr<Participant> rsb::ParticipantPtr |
Definition at line 97 of file Participant.h.
typedef boost::shared_ptr<Reader> rsb::ReaderPtr |
typedef boost::shared_ptr< Scope > rsb::ScopePtr |
typedef boost::shared_ptr<Service> rsb::ServicePtr |
typedef boost::shared_ptr<void> rsb::VoidPtr |
RSB_EXPORT InformerBasePtr rsb::crateInformerBase | ( | const Scope & | scope, |
const std::string & | dataType, | ||
const ParticipantConfig & | config = Factory::getInstance().getDefaultParticipantConfig() |
||
) |
Creates and returns a new Informer that publishes Event s under the Scope scope.
scope | The scope of the informer. |
dataType | A string representation of the type of data sent via the new Informer. |
config | The configuration for the informer to use. Defaults to the global default configuration stored in the Factory instance. |
RSBError | If the requested informer cannot be created. |
Definition at line 33 of file CreateFunctions.cpp.
Informer<DataType>::Ptr rsb::createInformer | ( | const Scope & | scope, |
const ParticipantConfig & | config = Factory::getInstance().getDefaultParticipantConfig() , |
||
const std::string & | dataType = detail::TypeName<DataType>()() |
||
) |
Creates and returns a new Informer that publishes Event s under the Scope scope.
DataType | the C++ data type this informer publishes |
scope | The scope of the informer. |
config | The configuration for the informer to use. Defaults to the global default configuration stored in the Factory instance. |
dataType | A string representation of the type of data sent via the new Informer. |
RSBError | If the requested informer cannot be created. |
Definition at line 53 of file CreateFunctions.h.
RSB_EXPORT ListenerPtr rsb::createListener | ( | const Scope & | scope, |
const ParticipantConfig & | config = Factory::getInstance().getDefaultParticipantConfig() |
||
) |
Creates and returns a new Listener for the Scope scope.
scope | The scope of the new listener |
config | The configuration for the listener to use. Defaults to the global default configuration stored in the Factory instance. |
RSBError | If the requested listener cannot be created. |
Definition at line 39 of file CreateFunctions.cpp.
RSB_EXPORT ReaderPtr rsb::createReader | ( | const Scope & | scope, |
const ParticipantConfig & | config = Factory::getInstance().getDefaultParticipantConfig() |
||
) |
Creates and returns a new Reader object for Scope scope.
Reader objects receive event via a pull-style interface by calls to Reader::read.
scope | the scope of the new receiver |
config | The configuration for the reader to use. Defaults to the global default configuration stored in the Factory instance. |
RSBError | If the requested reader cannot be created. |
Definition at line 44 of file CreateFunctions.cpp.
RSB_EXPORT patterns::RemoteServerPtr rsb::createRemoteServer | ( | const Scope & | scope | ) |
Creates and returns a RemoteServer object for the server at Scope scope.
scope | The scope at which the remote server object exposes itself. |
Definition at line 57 of file CreateFunctions.cpp.
RSB_EXPORT patterns::ServerPtr rsb::createServer | ( | const Scope & | scope | ) |
Creates and returns a Server object that exposes methods under the Scope scope.
scope | The scope under which the new server exposes its methods. |
Definition at line 53 of file CreateFunctions.cpp.
RSB_EXPORT ServicePtr rsb::createService | ( | const Scope & | scope | ) |
Creates and returns a Service instance operating on Scope scope.
scope | Parent-scope of the new service. |
Definition at line 49 of file CreateFunctions.cpp.
RSB_EXPORT std::ostream & rsb::operator<< | ( | ostream & | stream, |
const QualityOfServiceSpec & | spec | ||
) |
Definition at line 57 of file QualityOfServiceSpec.cpp.
References rsb::QualityOfServiceSpec::ordering, and rsb::QualityOfServiceSpec::reliability.
RSB_EXPORT std::ostream & rsb::operator<< | ( | ostream & | stream, |
const Scope & | scope | ||
) |
Definition at line 244 of file Scope.cpp.
References rsb::Scope::toString().
RSB_EXPORT std::ostream & rsb::operator<< | ( | ostream & | stream, |
const MetaData & | meta | ||
) |
Definition at line 253 of file MetaData.cpp.
|
inline |
Validate that s satisfies the regular expression /([a-zA-Z0-9]+/)* and split at '/' characters.
s | String representation that should be verified and split. |
components | A vector in which the extracted scope components should be stored |
normalizedString | returns a normalized version of the scope's string representation |
Definition at line 53 of file Scope.cpp.
Referenced by rsb::Scope::Scope().