Connection.hpp

/*
 * (c) Copyright, Real-Time Innovations, 2017.
 * All rights reserved.
 *
 * No duplications, whole or partial, manual or electronic, may be made
 * without express written permission.  Any such copies, or
 * revisions thereof, must display this notice unaltered.
 * This code contains trade secrets of Real-Time Innovations, Inc.
 */

#ifndef RTI_ROUTING_ADAPTER_CONNECTION_HPP_
#define RTI_ROUTING_ADAPTER_CONNECTION_HPP_

#include <rti/routing/PropertySet.hpp>
#include <rti/routing/UpdatableEntity.hpp>
#include <rti/routing/adapter/Session.hpp>
#include <rti/routing/adapter/StreamWriter.hpp>
#include <rti/routing/adapter/StreamReader.hpp>
#include <rti/routing/StreamInfo.hpp>
#include <rti/routing/adapter/DiscoveryStreamReader.hpp>
#include <rti/routing/adapter/StreamReaderListener.hpp>

namespace rti { namespace routing { namespace adapter {

class Connection : public UpdatableEntity {

public:
    virtual Session * create_session(
            const PropertySet& properties)
    {
        (void) properties;

        return NULL;
    }

    virtual void delete_session(Session *session)
    {
        (void) session;
    }

    virtual StreamWriter * create_stream_writer(
            Session *session,
            const StreamInfo& stream_info,
            const PropertySet& properties)
    {
        (void) session;
        (void) stream_info;
        (void) properties;

        return NULL;
    }

    virtual void delete_stream_writer(
            StreamWriter *stream_writer)
    {
        (void) stream_writer;
    }

    virtual StreamReader * create_stream_reader(
            Session *session,
            const StreamInfo& stream_info,
            const PropertySet& properties,
            StreamReaderListener *listener)
    {
        (void) session;
        (void) stream_info;
        (void) properties;
        (void) listener;

        return NULL;
    }

    virtual void delete_stream_reader(
            StreamReader *stream_reader)
    {
        (void) stream_reader;
    }

    virtual DiscoveryStreamReader * input_stream_discovery_reader()
    {
        return NULL;
    }

    virtual DiscoveryStreamReader * output_stream_discovery_reader()
    {
        return NULL;
    }

    virtual ~Connection()
    {
    }

};

}}}

#endif // RTI_ROUTING_ADAPTER_CONNECTION_HPP_