File size: 1,699 Bytes
053b80b |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 |
#ifndef _I_ROUTER_CLIENT_H_
#define _I_ROUTER_CLIENT_H_
#include <string>
#include <future>
#include <functional>
#include <exception>
#include "messages/Frame.pb.h"
#include "ITransportClient.h"
#include "common/KError.h"
using namespace std;
namespace Kinova
{
namespace Api
{
typedef std::function<void (const Kinova::Api::Frame&)> MessageCallback;
typedef struct
{
bool andForget;
uint32_t delay_ms;
uint32_t timeout_ms;
} RouterClientSendOptions;
class IRouterClient
{
public:
virtual ~IRouterClient() {}
virtual void reset() = 0;
virtual void registerBridgingCallback(std::function<void (Frame &)> bridgingCallback) = 0;
virtual void registerNotificationCallback( uint32_t serviceId, function<Error (Frame&)> ) = 0;
virtual void registerErrorCallback( function<void(KError)> callback ) = 0;
virtual void registerHitCallback(std::function<void (FrameTypes)> hitSessionCallback) = 0;
virtual future<Frame> send(const std::string& txPayload, uint32_t serviceVersion, uint32_t funcId, uint32_t deviceId, const RouterClientSendOptions& options ) = 0;
virtual Error sendWithCallback(const std::string& txPayload, uint32_t serviceVersion, uint32_t funcId, uint32_t deviceId, MessageCallback callback) = 0;
virtual Error sendMsgFrame(const Frame& msgFrame) = 0;
virtual uint16_t getConnectionId() = 0;
virtual void SetActivationStatus(bool isActive) = 0;
virtual ITransportClient* getTransport() = 0;
};
} // namespace Api
} // namespace Kinova
#endif // _I_ROUTER_CLIENT_H_
|