RTI Routing Service Version 7.1.0
Connection.hpp
1/*
2 * (c) Copyright, Real-Time Innovations, 2017.
3 * All rights reserved.
4 *
5 * No duplications, whole or partial, manual or electronic, may be made
6 * without express written permission. Any such copies, or
7 * revisions thereof, must display this notice unaltered.
8 * This code contains trade secrets of Real-Time Innovations, Inc.
9 */
10
11#ifndef RTI_ROUTING_ADAPTER_CONNECTION_HPP_
12#define RTI_ROUTING_ADAPTER_CONNECTION_HPP_
13
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>
22
23namespace rti { namespace routing { namespace adapter {
24
36
37public:
58 const PropertySet& properties)
59 {
60 (void) properties;
61
62 return NULL;
63 }
64
77 virtual void delete_session(Session *session)
78 {
79 (void) session;
80 }
81
110 Session *session,
111 const StreamInfo& stream_info,
112 const PropertySet& properties)
113 {
114 (void) session;
115 (void) stream_info;
116 (void) properties;
117
118 return NULL;
119 }
120
136 StreamWriter *stream_writer)
137 {
138 (void) stream_writer;
139 }
140
173 Session *session,
174 const StreamInfo& stream_info,
175 const PropertySet& properties,
176 StreamReaderListener *listener)
177 {
178 (void) session;
179 (void) stream_info;
180 (void) properties;
181 (void) listener;
182
183 return NULL;
184 }
185
201 StreamReader *stream_reader)
202 {
203 (void) stream_reader;
204 }
205
225 {
226 return NULL;
227 }
228
248 {
249 return NULL;
250 }
251
255 virtual ~Connection()
256 {
257 }
258
259};
260
261}}}
262
263#endif // RTI_ROUTING_ADAPTER_CONNECTION_HPP_
Definition of the stream information that RTI Routing Service needs to manage user data streams.
Definition: StreamInfo.hpp:106
Defines a common interface for all the pluggable entities that can be updated at runtime.
Definition: UpdatableEntity.hpp:34
A Connection provides access to a data domain (such as a DDS domain or a JMS network provider).
Definition: Connection.hpp:35
virtual ~Connection()
Virtual destructor.
Definition: Connection.hpp:255
virtual void delete_stream_reader(StreamReader *stream_reader)
Deletes a StreamReader.
Definition: Connection.hpp:200
virtual StreamReader * create_stream_reader(Session *session, const StreamInfo &stream_info, const PropertySet &properties, StreamReaderListener *listener)
Creates a StreamReader.
Definition: Connection.hpp:172
virtual DiscoveryStreamReader * output_stream_discovery_reader()
Gets the output stream discovery StreamReader.
Definition: Connection.hpp:247
virtual void delete_session(Session *session)
Deletes a Session.
Definition: Connection.hpp:77
virtual Session * create_session(const PropertySet &properties)
Creates a Session.
Definition: Connection.hpp:57
virtual DiscoveryStreamReader * input_stream_discovery_reader()
Gets the input stream discovery StreamReader.
Definition: Connection.hpp:224
virtual void delete_stream_writer(StreamWriter *stream_writer)
Deletes a StreamWriter.
Definition: Connection.hpp:135
virtual StreamWriter * create_stream_writer(Session *session, const StreamInfo &stream_info, const PropertySet &properties)
Creates a StreamWriter.
Definition: Connection.hpp:109
Definition of a special StreamReader to read information about data streams.
Definition: DiscoveryStreamReader.hpp:34
Definition: Session.hpp:28
Provides a way to read samples of a specific type from a data domain. In the XML configuration file,...
Definition: StreamReader.hpp:45
Provides a way to write samples of a specific type in a data domain.
Definition: StreamWriter.hpp:36
std::map< std::string, std::string > PropertySet
The definition of a pluggable entity’s configuration properties.
Definition: PropertySet.hpp:60