RSB
0.7.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 (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. | |
virtual | ~OutConnector () |
virtual void | activate () |
virtual void | deactivate () |
void | setQualityOfServiceSpecs (const QualityOfServiceSpec &specs) |
Requests new QoS settings for publishing events. | |
void | handle (EventPtr e) |
Handle event. | |
Public Member Functions inherited from rsb::transport::socket::ConnectorBase | |
ConnectorBase (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. | |
virtual | ~ConnectorBase () |
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. | |
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 | ( | 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 55 of file OutConnector.cpp.
|
virtual |
Reimplemented from rsb::transport::OutConnector.
Definition at line 64 of file OutConnector.cpp.
|
virtual |
Reimplemented from rsb::transport::socket::ConnectorBase.
Definition at line 68 of file OutConnector.cpp.
|
static |
|
virtual |
Reimplemented from rsb::transport::socket::ConnectorBase.
Definition at line 72 of file OutConnector.cpp.
|
virtual |
Handle event.
event | The event that should be handled. |
Implements rsb::eventprocessing::Handler.
Definition at line 80 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 76 of file OutConnector.cpp.
References logger.
|
private |
Definition at line 72 of file OutConnector.h.
Referenced by setQualityOfServiceSpecs().