RTI Routing Service Adapter API

This module describes the C Adapter API. More...

Data Structures
struct	RTI_RoutingServiceStreamReaderListener
	StreamReader listener used to notify Routing Service that new data is available. More...
struct	RTI_RoutingServiceAdapterPlugin
	Adapter plugin. More...

Macros
#define	RTI_RoutingServiceAdapterPlugin_initialize(adapter)
	Initializes the adapter plugin structure.

Typedefs
typedef void *	RTI_RoutingServiceStreamWriter
	StreamWriter.
typedef int(*	RTI_RoutingServiceStreamWriter_WriteFcn )(RTI_RoutingServiceStreamWriter stream_writer, const RTI_RoutingServiceSample *sample_list, const RTI_RoutingServiceSampleInfo *info_list, int count, RTI_RoutingServiceEnvironment *env)
	Prototype of the function that writes a collection of data samples to an output stream.
typedef void *	RTI_RoutingServiceStreamReader
	StreamReader.
typedef void(*	RTI_RoutingServiceStreamReaderListener_OnDataAvailableCallback )(RTI_RoutingServiceStreamReader stream_reader, void *listener_data)
	Prototype of the callback used to notify of new samples.
typedef void(*	RTI_RoutingServiceStreamReader_ReadFcn )(RTI_RoutingServiceStreamReader stream_reader, RTI_RoutingServiceSample **sample_list, RTI_RoutingServiceSampleInfo **info_list, int *count, RTI_RoutingServiceEnvironment *env)
	Prototype of the function that reads a collection of data samples and sample infos from an input stream.
typedef void(*	RTI_RoutingServiceStreamReader_ReturnLoanFcn )(RTI_RoutingServiceStreamReader stream_reader, RTI_RoutingServiceSample *sample_list, RTI_RoutingServiceSampleInfo *info_list, int count, RTI_RoutingServiceEnvironment *env)
	Prototype of the function that returns the loan on the read samples and infos.
typedef void *	RTI_RoutingServiceSession
	Session.
typedef void *	RTI_RoutingServiceConnection
	Connection.
typedef RTI_RoutingServiceSession(*	RTI_RoutingServiceConnection_CreateSessionFcn )(RTI_RoutingServiceConnection connection, const struct RTI_RoutingServiceProperties *properties, RTI_RoutingServiceEnvironment *env)
	Prototype of the function that creates a Session.
typedef void(*	RTI_RoutingServiceConnection_DeleteSessionFcn )(RTI_RoutingServiceConnection connection, RTI_RoutingServiceSession session, RTI_RoutingServiceEnvironment *env)
	Prototype of the function that deletes a Session.
typedef RTI_RoutingServiceStreamReader(*	RTI_RoutingServiceConnection_CreateStreamReaderFcn )(RTI_RoutingServiceConnection connection, RTI_RoutingServiceSession session, const struct RTI_RoutingServiceStreamInfo *stream_info, const struct RTI_RoutingServiceProperties *properties, const struct RTI_RoutingServiceStreamReaderListener *listener, RTI_RoutingServiceEnvironment *env)
	Prototype of the function that creates a StreamReader.
typedef void(*	RTI_RoutingServiceConnection_DeleteStreamReaderFcn )(RTI_RoutingServiceConnection connection, RTI_RoutingServiceStreamReader stream_reader, RTI_RoutingServiceEnvironment *env)
	Prototype of the function that deletes a StreamReader.
typedef RTI_RoutingServiceStreamWriter(*	RTI_RoutingServiceConnection_CreateStreamWriterFcn )(RTI_RoutingServiceConnection connection, RTI_RoutingServiceSession session, const struct RTI_RoutingServiceStreamInfo *stream_info, const struct RTI_RoutingServiceProperties *properties, RTI_RoutingServiceEnvironment *env)
	Prototype of the function that creates a StreamWriter.
typedef void(*	RTI_RoutingServiceConnection_DeleteStreamWriterFcn )(RTI_RoutingServiceConnection connection, RTI_RoutingServiceStreamWriter stream_writer, RTI_RoutingServiceEnvironment *env)
	Prototype of the function that deletes a StreamWriter.
typedef RTI_RoutingServiceStreamReader(*	RTI_RoutingServiceConnection_GetDiscoveryReaderFcn )(RTI_RoutingServiceConnection connection, RTI_RoutingServiceEnvironment *env)
	Prototype of the function that gets a built-in discovery StreamReader.
typedef RTI_RoutingServiceTypeRepresentation(*	RTI_RoutingServiceConnection_CopyTypeRepresentationFcn )(RTI_RoutingServiceConnection connection, RTI_RoutingServiceTypeRepresentationKind type_representation_kind, RTI_RoutingServiceTypeRepresentation type_representation, RTI_RoutingServiceEnvironment *env)
	Prototype of the function that copies a type representation.
typedef void(*	RTI_RoutingServiceConnection_DeleteTypeRepresentationFcn )(RTI_RoutingServiceConnection connection, RTI_RoutingServiceTypeRepresentationKind type_representation_kind, RTI_RoutingServiceTypeRepresentation type_representation, RTI_RoutingServiceEnvironment *env)
	Prototype of the function that deletes a type representation.
typedef void *	RTI_RoutingServiceAdapterEntity
	Adapter entity.
typedef void(*	RTI_RoutingServiceAdapterEntity_UpdateFcn )(RTI_RoutingServiceAdapterEntity entity, const struct RTI_RoutingServiceProperties *properties, RTI_RoutingServiceEnvironment *env)
	Prototype of the function that updates the configuration of an adapter entity.
typedef void(*	RTI_RoutingServiceAdapterPlugin_DeleteFcn )(struct RTI_RoutingServiceAdapterPlugin *plugin, RTI_RoutingServiceEnvironment *env)
	Prototype of the function that deletes an adapter plugin.
typedef struct RTI_RoutingServiceAdapterPlugin *(*	RTI_RoutingServiceAdapterPlugin_CreateFcn )(const struct RTI_RoutingServiceProperties *properties, RTI_RoutingServiceEnvironment *env)
	Prototype of the function that creates an adapter plugin.

Variables
RTI_RoutingServiceStreamReaderListener_OnDataAvailableCallback	RTI_RoutingServiceStreamReaderListener::on_data_available
	Prototype of the callback used to notify of new samples.

Detailed Description

This module describes the C Adapter API.

Adapters are pluggable components that allow RTI Routing Service to consume and produce data for different data domains (e.g., Connext DDS, MQTT, Socket, etc.).

By default, Routing Service is distributed with a builtin DDS adapter. Any other adapter plugins must be provided as external components registered through the XML configuration or through the service API.

The following figure shows an overview of the Routing Service adapter.

Input adapters are used to collect data samples from different data domains, such as DDS or MQTT. The input samples are processed by the Routing Service engine and are passed along to output adapters through the Processor, applying any Transformation beforehand if present.

For additional details about Adapter configuration see the RTI Routing Service User's Manual.

Development Requirements

	UNIX-based Systems	Windows Systems
Shared Libraries	librtirsinfrastructure.so	rtirsinfrastructure.dll
^	libnddsc.so	nddsc.dll
^	libnddscore.so	nddscore.dll
Headers	routingservice_adapter.h

Architecture

The Adapter architecture is shown in the class diagram below.

The sequence diagram in this figure shows when the different adapter entities are created.

• An RTI_RoutingServiceAdapterPlugin object is created as soon as RTI Routing Service starts and finds out about the plug-ins that will be used by underlying DomainRoute connections.

• A RTI_RoutingServiceConnection object is created when the DomainRoute (<domain_route>) that contain it is enabled.

• A RTI_RoutingServiceSession object is created when the associated service Session (<session>) is enabled.

• An input’s RTI_RoutingServiceStreamReader is created if the Route is enabled and the ‘creation mode’ condition associated with the <input> tag becomes true.

• An output’s RTI_RoutingServiceStreamWriter is created if the route is enabled and the ‘creation mode’ condition associated with the <output> tag becomes true.

Stream Discovery

A Route cannot forward data until the type representations (e.g., TypeCode) associated with the input and output streams are available.

If a Route refers to types that are not defined in the configuration file, RTI Routing Service has to discover their type representation (e.g., TypeCode) before creating the RTI_RoutingServiceStreamReader and RTI_RoutingServiceStreamWriter. The adapter discovery API is used to provide stream and type information in a data domain to Routing Service.

The discovery API consists of the following methods:

• RTI_RoutingServiceAdapterPlugin::connection_get_input_stream_discovery_reader
• RTI_RoutingServiceAdapterPlugin::connection_get_output_stream_discovery_reader

These methods provide access to RTI_RoutingServiceStreamReader used to discover streams in the data domain associated with a connection.

The input stream discovery RTI_RoutingServiceStreamReader provides information about input streams. An input stream is a stream from which an input's RTI_RoutingServiceStreamReader reads data. Notification of disposed scenarios, where an input stream disappears, are also made using the input stream discovery StreamReader.

In the builtin DDS adapter, the input stream discovery StreamReader is associated with the publication builtin DataReader of the DomainParticipant.

The output stream discovery RTI_RoutingServiceStreamReader provides information about output streams. An output stream is a stream to which an output's RTI_RoutingServiceStreamWriter can write data. Notification of disposed scenarios, where an output stream disappears, are also made using the output stream discovery StreamReader.

In the builtin DDS adapter, the output stream discovery StreamReader is associated with the subscription builtin DataReader of the DomainParticipant.

The samples provided by the stream discovery StreamReaders have the type RTI_RoutingServiceStreamInfo.

Macro Definition Documentation

#define RTI_RoutingServiceAdapterPlugin_initialize

(

adapter

)

Initializes the adapter plugin structure.

This macro must be called to initialize the return value of RTI_RoutingServiceAdapterPlugin_CreateFcn

Parameters

adapter

Pointer to the adapter plugin structure

See Also

RTI_RoutingServiceAdapterPlugin_CreateFcn

Typedef Documentation

typedef void* RTI_RoutingServiceStreamWriter

StreamWriter.

A StreamWriter provides a way to write samples of a specific type in a data domain.

In the XML configuration file, StreamWriters are associated with the tag <output> within <route> and <auto_route>.

The StreamWriter type is a typedef to a 'void *' pointer. The concrete implementation is up to the adapter implementor.

typedef int(* RTI_RoutingServiceStreamWriter_WriteFcn)(RTI_RoutingServiceStreamWriter stream_writer, const RTI_RoutingServiceSample *sample_list, const RTI_RoutingServiceSampleInfo *info_list, int count, RTI_RoutingServiceEnvironment *env)

Prototype of the function that writes a collection of data samples to an output stream.

Required: Only when the adapter is used to write data.

Parameters

stream_writer	<<in>> Stream writer.
sample_list	<<in>> Array of samples. The data representation associated with the samples will be given by the value of the connection attribute com.rti.routingservice.adapter.data_representation_kind that is obtained using the associated RTI_RoutingServiceStreamInfo.
info_list	<<in>> Array of sample infos. The info representation associated with the sample infos will be given by the value of the connection attribute com.rti.routingservice.adapter.info_representation_kind that is obtained using the associated RTI_RoutingServiceStreamInfo.
count	<<in>> Number of samples in the sample list
env	<<inout>> Environment for error indications.

Returns

Number of samples written.

typedef void* RTI_RoutingServiceStreamReader

StreamReader.

A StreamReader provides a way to read samples of a specific type from a data domain.

In the XML configuration file, StreamReaders are associated with the tag <input> within <route> and <auto_route>.

The StreamReader type is a typedef to a 'void *' pointer. The concrete implementation is up to the adapter implementor.

typedef void(* RTI_RoutingServiceStreamReaderListener_OnDataAvailableCallback)(RTI_RoutingServiceStreamReader stream_reader, void *listener_data)

Prototype of the callback used to notify of new samples.

When a StreamReader receives new data, it will use this callback to notify RTI Routing Service that there are new samples.

Required: Only when the adapter is used to read data.

Parameters

stream_reader	<<in>> Stream reader.
listener_data	<<inout>> Data associated with the listener when the listener is set.

typedef void(* RTI_RoutingServiceStreamReader_ReadFcn)(RTI_RoutingServiceStreamReader stream_reader, RTI_RoutingServiceSample **sample_list, RTI_RoutingServiceSampleInfo **info_list, int *count, RTI_RoutingServiceEnvironment *env)

Prototype of the function that reads a collection of data samples and sample infos from an input stream.

When RTI Routing Service is done using the samples, it will 'return the loan' to the StreamReader by calling RTI_RoutingServiceStreamReader_ReturnLoanFcn.

Required: Only when the adapter is used to read data.

Parameters

stream_reader	<<in>> Stream reader.
sample_list	<<out>> Array that will hold the output samples. This array will be provided by the StreamReader. The contents of the array are typically structures of the type DDS_DynamicData (see the RTI Connext documentation). But in general, the data representation associated with the output samples will be given by the value of the connection attribute com.rti.routingservice.adapter.data_representation_kind that is obtained using the associated RTI_RoutingServiceStreamInfo.
info_list	<<out>> Array that will hold the output sample infos. This array will be provided by the StreamReader. It can be NULL if there is no info associated to the samples. The contents of the array are typically structures of the type DDS_SampleInfo (see the RTI Connext documentation). But in general the info representation associated with the output sample infos will be given by the value of the connection attribute com.rti.routingservice.adapter.info_representation_kind that is obtained using the associated RTI_RoutingServiceStreamInfo.
count	<<out>> Number of output samples. The value must be greater than or equal to zero.
env	<<inout>> Environment for error indications.

See Also

RTI_RoutingServiceStreamReader_ReturnLoanFcn

typedef void(* RTI_RoutingServiceStreamReader_ReturnLoanFcn)(RTI_RoutingServiceStreamReader stream_reader, RTI_RoutingServiceSample *sample_list, RTI_RoutingServiceSampleInfo *info_list, int count, RTI_RoutingServiceEnvironment *env)

Prototype of the function that returns the loan on the read samples and infos.

RTI Routing Service calls this method to indicate that it is done accessing the collection of data samples and sample infos obtained by an earlier invocation of RTI_RoutingServiceStreamReader_ReadFcn.

Required: Only when the adapter is used to read data.

Parameters

stream_reader	<<in>> Stream reader.
sample_list	<<in>> Array of samples.
info_list	<<in>> Array of infos.
count	<<in>> Number of samples in the sample list.
env	<<inout>> Environment for error indications.

See Also

RTI_RoutingServiceStreamReader_ReadFcn

typedef void* RTI_RoutingServiceSession

Session.

A Session is a concurrency unit within a connection that has an associated set of StreamReaders and StreamWriters. Access to the StreamReaders and StreamWriters in the same Session is serialized by RTI Routing Service.

In the XML configuration file, Sessions are associated with the tag <session> within a domain route. For each <session> tag, RTI Routing Service will create two adapter Sessions, one per connection.

The Session type is a typedef to a 'void *' pointer. The concrete implementation is up to the adapter implementor.

typedef void* RTI_RoutingServiceConnection

Connection.

A Connection object provides access to a data domain (such as a DDS domain or a JMS network provider).

In the XML configuration file, Connections are created using the tag <connection> within a DomainRoute.

The Connection type is a typedef to a 'void *' pointer. The concrete implementation is up to the adapter implementor.

typedef RTI_RoutingServiceSession(* RTI_RoutingServiceConnection_CreateSessionFcn)(RTI_RoutingServiceConnection connection, const struct RTI_RoutingServiceProperties *properties, RTI_RoutingServiceEnvironment *env)

Prototype of the function that creates a Session.

A Session is a concurrency unit within a Connection that has an associated set of StreamReaders and StreamWriters. Access to the StreamReaders and StreamWriters in the same Session is serialized by RTI Routing Service.

Session objects are created when the associated routing service sessions are enabled.

In the XML configuration file, Sessions are associated with the tag <session> within a domain route.

Required: No

Parameters

connection	<<in>> Connection.
properties	<<in>> Configuration properties for the Session.
env	<<inout>> Environment for error indications.

Returns

New Session if successful. Otherwise, NULL.

See Also

RTI_RoutingServiceConnection_DeleteSessionFcn

typedef void(* RTI_RoutingServiceConnection_DeleteSessionFcn)(RTI_RoutingServiceConnection connection, RTI_RoutingServiceSession session, RTI_RoutingServiceEnvironment *env)

Prototype of the function that deletes a Session.

Session objects are deleted when the routing service sessions that contain them are disabled.

Required: No

Parameters

connection	<<in>> Connection.
session	<<in>> Session to be deleted.
env	<<inout>> Environment for error indications.

See Also

RTI_RoutingServiceConnection_CreateSessionFcn

typedef RTI_RoutingServiceStreamReader(* RTI_RoutingServiceConnection_CreateStreamReaderFcn)(RTI_RoutingServiceConnection connection, RTI_RoutingServiceSession session, const struct RTI_RoutingServiceStreamInfo *stream_info, const struct RTI_RoutingServiceProperties *properties, const struct RTI_RoutingServiceStreamReaderListener *listener, RTI_RoutingServiceEnvironment *env)

Prototype of the function that creates a StreamReader.

A StreamReader provides a way to read samples of a specific type from a data domain.

In the XML configuration file, StreamReaders are associated with the tag <input> within <route> or <auto_route>.

This function is called when the route is enabled and the 'creation mode' condition associated with the route's input becomes true.

Required: Only when the adapter is used to read data.

Parameters

connection	<<in>> Connection.
session	<<in>> Session associated with the StreamReader. This parameter is NULL if Sessions are not used by the adapter.
stream_info	<<in>> Name of the stream and type representation.
properties	<<in>> Configuration properties for the StreamReader.
listener	<<in>> The listener of the StreamReader used to notify the routing service when new data is available.
env	<<inout>> Environment for error indications.

Returns

New StreamReader if successful. Otherwise, NULL.

See Also

RTI_RoutingServiceConnection_DeleteStreamReaderFcn

typedef void(* RTI_RoutingServiceConnection_DeleteStreamReaderFcn)(RTI_RoutingServiceConnection connection, RTI_RoutingServiceStreamReader stream_reader, RTI_RoutingServiceEnvironment *env)

Prototype of the function that deletes a StreamReader.

A StreamReader object is deleted when the route that contains it is disabled, when the 'creation mode' condition associated with the route's input becomes false or when RTI Routing Service is closed.

Required: Only when the adapter is used to read data.

Parameters

connection	<<in>> Connection.
stream_reader	<<in>> StreamReader to be deleted.
env	<<inout>> Environment for error indications.

See Also

RTI_RoutingServiceConnection_CreateStreamReaderFcn

typedef RTI_RoutingServiceStreamWriter(* RTI_RoutingServiceConnection_CreateStreamWriterFcn)(RTI_RoutingServiceConnection connection, RTI_RoutingServiceSession session, const struct RTI_RoutingServiceStreamInfo *stream_info, const struct RTI_RoutingServiceProperties *properties, RTI_RoutingServiceEnvironment *env)

Prototype of the function that creates a StreamWriter.

A StreamWriter provides a way to write samples of a specific type in a data domain.

In the XML configuration file, StreamWriters are associated with the tag <output> within <route> or <auto_route>.

This function is called when the route is enabled and the 'creation mode' condition associated with the route's output becomes true.

Required: Only when the adapter is used to write data.

Parameters

connection	<<in>> Connection.
session	<<in>> Session associated with the StreamWriter. This parameter is NULL if Sessions are not used by the adapter.
stream_info	<<in>> Name of the stream and type representation.
properties	<<in>> Configuration properties for the StreamWriter.
env	<<inout>> Environment for error indications.

Returns

New StreamWriter if successful. Otherwise, NULL.

See Also

RTI_RoutingServiceConnection_DeleteStreamWriterFcn

typedef void(* RTI_RoutingServiceConnection_DeleteStreamWriterFcn)(RTI_RoutingServiceConnection connection, RTI_RoutingServiceStreamWriter stream_writer, RTI_RoutingServiceEnvironment *env)

Prototype of the function that deletes a StreamWriter.

A StreamWriter object is deleted when the route or domain route that contains it is disabled, when the 'creation mode' condition associated with the route's output becomes false or when RTI Routing Service is closed.

Required: Only when the adapter is used to write data.

Parameters

connection	<<in>> Connection.
stream_writer	<<in>> StreamWriter to be deleted.
env	<<inout>> Environment for error indications.

See Also

RTI_RoutingServiceConnection_CreateStreamWriterFcn

typedef RTI_RoutingServiceStreamReader(* RTI_RoutingServiceConnection_GetDiscoveryReaderFcn)(RTI_RoutingServiceConnection connection, RTI_RoutingServiceEnvironment *env)

Prototype of the function that gets a built-in discovery StreamReader.

There are two built-in discovery StreamReaders:

The first StreamReader provides information about output streams. An output stream is a stream to which StreamWriters can write data. Disposed scenarios, where an output streams dissapears, are also notified using this StreamReader.

The second StreamReader provides information about input streams. An input stream is a stream from which StreamReaders can read data. Disposed scenarios, where an output streams dissapears, are also notified using this StreamReader.

The StreamReaderListeners associated with the built-in discovery StreamReaders are provided as parameters to RTI_RoutingServiceAdapterPlugin_CreateConnectionFcn.

Required: No

The implementation of this function is optional. However, if none of the adapters in a domain route implement the discovery API, the routes' types must be declared in the XML configuration file.

Parameters

connection	<<in>> Connection.
env	<<inout>> Environment for error indications.

Returns

Built-in dicovery StreamReader if successful. Otherwise, NULL.

typedef RTI_RoutingServiceTypeRepresentation(* RTI_RoutingServiceConnection_CopyTypeRepresentationFcn)(RTI_RoutingServiceConnection connection, RTI_RoutingServiceTypeRepresentationKind type_representation_kind, RTI_RoutingServiceTypeRepresentation type_representation, RTI_RoutingServiceEnvironment *env)

Prototype of the function that copies a type representation.

This function is part of the adapter discovery API and is used by RTI Routing Service to copy the type representation associated with the discovered streams.

Required: No (Tied to the implementation RTI_RoutingServiceConnection_GetDiscoveryReaderFcn).

Parameters

connection	<<in>> Connection.
type_representation_kind	<<in>> Type representation kind.
type_representation	<<in>> Type representation to be copied.
env	<<inout>> Environment for error indications.

See Also

Standard Type Representation Kinds

RTI_RoutingServiceConnection_DeleteTypeRepresentationFcn

typedef void(* RTI_RoutingServiceConnection_DeleteTypeRepresentationFcn)(RTI_RoutingServiceConnection connection, RTI_RoutingServiceTypeRepresentationKind type_representation_kind, RTI_RoutingServiceTypeRepresentation type_representation, RTI_RoutingServiceEnvironment *env)

Prototype of the function that deletes a type representation.

This function is part of the adapter discovery API.

Required: No (Tied to the implementation RTI_RoutingServiceConnection_GetDiscoveryReaderFcn).

Parameters

connection	<<in>> Connection.
type_representation_kind	<<in>> Type representation kind.
type_representation	<<in>> Type representation to be deleted.
env	<<inout>> Environment for error indications.

See Also

Standard Type Representation Kinds

RTI_RoutingServiceConnection_CopyTypeRepresentationFcn

typedef void* RTI_RoutingServiceAdapterEntity

Adapter entity.

The adapter entities are:

• Connection
• Session
• StreamReader
• StreamWriter

typedef void(* RTI_RoutingServiceAdapterEntity_UpdateFcn)(RTI_RoutingServiceAdapterEntity entity, const struct RTI_RoutingServiceProperties *properties, RTI_RoutingServiceEnvironment *env)

Prototype of the function that updates the configuration of an adapter entity.

This function is called when remote administration is used.

Adapter entities that can be updated are:

• Connection
• Session
• StreamReader
• StreamWriter

Required: No. Implement this function only when remote configuration is needed.

Parameters

entity	<<in>> Entity.
properties	<<in>> New configuration properties.
env	<<inout>> Environment for error indications.

typedef void(* RTI_RoutingServiceAdapterPlugin_DeleteFcn)(struct RTI_RoutingServiceAdapterPlugin *plugin, RTI_RoutingServiceEnvironment *env)

Prototype of the function that deletes an adapter plugin.

Adapter plugins are deleted when RTI Routing Service is closed.

Required: yes

Parameters

plugin	<<in>> Adapter plugin to be deleted.
env	<<inout>> Environment for error indications.

See Also

RTI_RoutingServiceAdapterPlugin_DeleteFcn

typedef struct RTI_RoutingServiceAdapterPlugin*(* RTI_RoutingServiceAdapterPlugin_CreateFcn)(const struct RTI_RoutingServiceProperties *properties, RTI_RoutingServiceEnvironment *env)

read

Prototype of the function that creates an adapter plugin.

The name of the function that implements this prototype must be provided to RTI Routing Service using the tag <create_function> when the adapter plugin is registered. For example:

<dds>
    ...
    <plugin_library name="MyAdapterLib">
        <adapter_plugin name="MyAdapterPlugin">
           <dll>mycadapter</dll>
           <create_function>
               MyAdapterPlugin_create
           </create_function>
        </adapter_plugin>
        ...
    </plugin_library>
    ...
    <routing_service>
    ...
    </routing_service>
    ...
</dds>

Required: yes

Parameters

properties	Configuration properties for the adapter.
env	<<inout>> Environment for error indications.

Returns

New plugin instance if successful. Otherwise, NULL.

See Also

RTI_RoutingServiceAdapterPlugin_DeleteFcn

RTI_RoutingServiceAdapterPlugin_initialize

Variable Documentation

RTI_RoutingServiceStreamReaderListener_OnDataAvailableCallback RTI_RoutingServiceStreamReaderListener::on_data_available

Prototype of the callback used to notify of new samples.

When a StreamReader receives new data, it will use this callback to notify RTI Routing Service that there are new samples.

Required: Only when the adapter is used to read data.

Parameters

stream_reader	<<in>> Stream reader.
listener_data	<<inout>> Data associated with the listener when the listener is set.