binaryswitchImpl.h

#ifndef ORCA_BINARYSWITCH_IMPL_H
#define ORCA_BINARYSWITCH_IMPL_H

#include <memory>
#include <orca/binaryswitch.h>
#include <gbxsickacfr/gbxiceutilacfr/store.h>
#include <orcaice/context.h>
#include <orcaice/topichandler.h>

namespace gbxutilacfr { class Stoppable; }

namespace orcaifaceimpl
{

class AbstractBinarySwitchCallback {
public:
    virtual ~AbstractBinarySwitchCallback() {}

    virtual void setData( const orca::BinarySwitchData &data )=0;
};

class BinarySwitchImpl : public IceUtil::Shared
{
friend class BinarySwitchI;

public:
    BinarySwitchImpl( AbstractBinarySwitchCallback &callback,
                      const std::string            &interfaceTag, 
                      const orcaice::Context       &context );
    BinarySwitchImpl( AbstractBinarySwitchCallback &callback,
                      const orcaice::Context       &context,
                      const std::string            &interfaceName );
    ~BinarySwitchImpl();
    
    // local functions
    void initInterface();

    void initInterface( gbxutilacfr::Stoppable* activity, const std::string& subsysName="", int retryInterval=2 );

    void localSet( const orca::BinarySwitchData& data )
    {
        dataStore_.set( data );
    }

    void localSetAndSend( const orca::BinarySwitchData &data );

private:
    void init();

    // remote call implementations, mimic (but do not inherit) the orca interface
    ::orca::BinarySwitchData internalGetData();
    IceStorm::TopicPrx internalSubscribe(const orca::BinarySwitchConsumerPrx& subscriber);

    gbxiceutilacfr::Store<orca::BinarySwitchData> dataStore_;

    typedef orcaice::TopicHandler<orca::BinarySwitchConsumerPrx,orca::BinarySwitchData> BinarySwitchTopicHandler;
    std::auto_ptr<BinarySwitchTopicHandler> topicHandler_;

    AbstractBinarySwitchCallback &callback_;

    Ice::ObjectPtr ptr_;
    const std::string interfaceName_;
    orcaice::Context context_;
};
typedef IceUtil::Handle<BinarySwitchImpl> BinarySwitchImplPtr;

}

#endif