11 #ifndef RTI_ROUTING_ADAPTER_CONNECTION_HPP_ 12 #define RTI_ROUTING_ADAPTER_CONNECTION_HPP_ 14 #include <rti/routing/PropertySet.hpp> 15 #include <rti/routing/UpdatableEntity.hpp> 16 #include <rti/routing/adapter/Session.hpp> 17 #include <rti/routing/adapter/StreamWriter.hpp> 18 #include <rti/routing/adapter/StreamReader.hpp> 19 #include <rti/routing/StreamInfo.hpp> 20 #include <rti/routing/adapter/DiscoveryStreamReader.hpp> 21 #include <rti/routing/adapter/StreamReaderListener.hpp> 23 namespace rti {
namespace routing {
namespace adapter {
138 (void) stream_writer;
203 (void) stream_reader;
263 #endif // RTI_ROUTING_ADAPTER_CONNECTION_HPP_ virtual StreamWriter * create_stream_writer(Session *session, const StreamInfo &stream_info, const PropertySet &properties)
Creates a StreamWriter.
Definition: Connection.hpp:109
virtual ~Connection()
Virtual destructor.
Definition: Connection.hpp:255
Definition of the stream information that RTI Routing Service needs to manage user data streams...
Definition: StreamInfo.hpp:106
Definition of a special StreamReader to read information about data streams.
Definition: DiscoveryStreamReader.hpp:34
virtual void delete_stream_reader(StreamReader *stream_reader)
Deletes a StreamReader.
Definition: Connection.hpp:200
virtual Session * create_session(const PropertySet &properties)
Creates a Session.
Definition: Connection.hpp:57
Listener representation used by StreamReader to notify RTI Routing Service when new data is available...
Defines a common interface for all the pluggable entities that can be updated at runtime.
Definition: UpdatableEntity.hpp:34
Provides a way to read samples of a specific type from a data domain. In the XML configuration file...
Definition: StreamReader.hpp:45
virtual void delete_stream_writer(StreamWriter *stream_writer)
Deletes a StreamWriter.
Definition: Connection.hpp:135
virtual void delete_session(Session *session)
Deletes a Session.
Definition: Connection.hpp:77
std::map< std::string, std::string > PropertySet
The definition of a pluggable entity’s configuration properties.
Definition: PropertySet.hpp:60
virtual StreamReader * create_stream_reader(Session *session, const StreamInfo &stream_info, const PropertySet &properties, StreamReaderListener *listener)
Creates a StreamReader.
Definition: Connection.hpp:172
Definition: AdapterPlugin.hpp:25
virtual DiscoveryStreamReader * input_stream_discovery_reader()
Gets the input stream discovery StreamReader.
Definition: Connection.hpp:224
Provides a way to write samples of a specific type in a data domain.
Definition: StreamWriter.hpp:36
virtual DiscoveryStreamReader * output_stream_discovery_reader()
Gets the output stream discovery StreamReader.
Definition: Connection.hpp:247
Definition: Session.hpp:28
A Connection provides access to a data domain (such as a DDS domain or a JMS network provider)...
Definition: Connection.hpp:35