RSB
0.19.0
|
Instances of this connector class push events into Bus objects which take care of socket-based broadcast and delivery. More...
#include <OutConnector.h>
Public Member Functions | |
OutConnector (FactoryPtr factory, ConverterSelectionStrategyPtr converters, const std::string &host, unsigned int port, Server server, bool tcpnodelay) | |
Creates a connector for the given combination of host, port and server. More... | |
virtual | ~OutConnector () |
virtual void | setScope (const Scope &scope) |
virtual void | activate () |
virtual void | deactivate () |
void | setQualityOfServiceSpecs (const QualityOfServiceSpec &specs) |
Requests new QoS settings for publishing events. More... | |
void | handle (EventPtr e) |
Handle event. More... | |
virtual const std::string | getTransportURL () const |
Public Member Functions inherited from rsb::transport::socket::ConnectorBase | |
ConnectorBase (FactoryPtr factory, ConverterSelectionStrategyPtr converters, const std::string &host, unsigned int port, Server server, bool tcpnodelay) | |
Creates a connector for the given combination of host, port and server. More... | |
virtual | ~ConnectorBase () |
virtual Scope | getScope () const |
Public Member Functions inherited from rsb::transport::Connector | |
virtual | ~Connector () |
Public Member Functions inherited from rsb::eventprocessing::Handler | |
virtual | ~Handler () |
Static Public Member Functions | |
static transport::OutConnector * | create (const rsc::runtime::Properties &args) |
Private Attributes | |
rsc::logging::LoggerPtr | logger |
Additional Inherited Members | |
Public Types inherited from rsb::transport::ConverterSelectingConnector< std::string > | |
typedef converter::Converter< std::string >::Ptr | ConverterPtr |
typedef converter::ConverterSelectionStrategy< std::string >::Ptr | ConverterSelectionStrategyPtr |
Public Types inherited from rsb::transport::OutConnector | |
typedef boost::shared_ptr< OutConnector > | Ptr |
Protected Member Functions inherited from rsb::transport::socket::ConnectorBase | |
BusPtr | getBus () |
Return the Bus object through which this connector is connected to a socket-based bus. More... | |
Protected Member Functions inherited from rsb::transport::ConverterSelectingConnector< std::string > | |
ConverterSelectingConnector (ConverterSelectionStrategyPtr converters) | |
ConverterPtr | getConverter (const std::string &key) const |
Try to find a suitable converter for key . More... | |
Protected Attributes inherited from rsb::transport::socket::ConnectorBase | |
volatile bool | active |
Instances of this connector class push events into Bus objects which take care of socket-based broadcast and delivery.
Definition at line 49 of file OutConnector.h.
rsb::transport::socket::OutConnector::OutConnector | ( | FactoryPtr | factory, |
ConverterSelectionStrategyPtr | converters, | ||
const std::string & | host, | ||
unsigned int | port, | ||
Server | server, | ||
bool | tcpnodelay | ||
) |
Creates a connector for the given combination of host, port and server.
converters | A strategy for converter selection within the newly created connector. |
host | The host of the socket through which the newly created connector will operate. |
port | The port of the socket through which the newly created connector will operate. |
server | Controls whether the newly created connector should create a listening socket and wait for connections (value SERVER_YES), connect to an existing listen socket (value SERVER_NO) or try to automatically determine whether there already is a listening socket and create one only if necessary (value SERVER_AUTO). |
tcpnodelay | Controls whether the TCP_NODELAY socket option should be set for the socket implementing the communication of the newly created connector. Setting this option trades decreased latency for decreased throughput. |
Definition at line 56 of file OutConnector.cpp.
|
virtual |
Reimplemented from rsb::transport::OutConnector.
Definition at line 66 of file OutConnector.cpp.
|
virtual |
Reimplemented from rsb::transport::socket::ConnectorBase.
Definition at line 74 of file OutConnector.cpp.
References rsb::transport::socket::ConnectorBase::activate().
|
static |
|
virtual |
Reimplemented from rsb::transport::socket::ConnectorBase.
Definition at line 78 of file OutConnector.cpp.
References rsb::transport::socket::ConnectorBase::deactivate().
|
virtual |
Reimplemented from rsb::transport::socket::ConnectorBase.
Definition at line 99 of file OutConnector.cpp.
References rsb::transport::socket::ConnectorBase::getTransportURL().
|
virtual |
Handle event.
event | The event that should be handled. |
Implements rsb::eventprocessing::Handler.
Definition at line 86 of file OutConnector.cpp.
References rsb::transport::socket::ConnectorBase::getBus(), and rsb::transport::ConverterSelectingConnector< std::string >::getConverter().
|
virtual |
Requests new QoS settings for publishing events.
Does not influence the receiving part.
specs | QoS specification |
UnsupportedQualityOfServiceException | requirements cannot be met |
Implements rsb::transport::Connector.
Definition at line 82 of file OutConnector.cpp.
|
virtual |
Reimplemented from rsb::transport::socket::ConnectorBase.
Definition at line 70 of file OutConnector.cpp.
References rsb::transport::socket::ConnectorBase::setScope().
|
private |
Definition at line 78 of file OutConnector.h.