IStompClient.h

Go to the documentation of this file.

// Copyright Epic Games, Inc. All Rights Reserved.
 
#pragma once
 
#include "CoreMinimal.h"
 
class IStompMessage;
typedef FString FStompSubscriptionId;
typedef TMap<FName,FString> FStompHeader;
typedef TArray<uint8> FStompBuffer;
 
DECLARE_DELEGATE_OneParam(FStompSubscriptionEvent, const IStompMessage& /*Message*/);
DECLARE_DELEGATE_TwoParams(FStompRequestCompleted, bool /*bSuccess*/, const FString& /*Error*/);
 
class IStompClient
{
public:
 
    virtual ~IStompClient()
    { }
 
    virtual void Connect(const FStompHeader& Header=FStompHeader()) = 0;
 
    virtual void Disconnect(const FStompHeader& Header=FStompHeader()) = 0;
 
    virtual bool IsConnected() const = 0;
 
    virtual FStompSubscriptionId Subscribe(const FString& Destination, const FStompSubscriptionEvent& EventCallback, const FStompRequestCompleted& CompletionCallback = FStompRequestCompleted()) = 0;
 
    virtual void Unsubscribe(FStompSubscriptionId Subscription, const FStompRequestCompleted& CompletionCallback = FStompRequestCompleted()) = 0;
 
    virtual void Send(const FString& Destination, const FString& Body, const FStompHeader& Header=FStompHeader(),  const FStompRequestCompleted& CompletionCallback = FStompRequestCompleted())
    {
        FTCHARToUTF8 Convert(*Body);
        FStompBuffer Encoded;
        Encoded.Append((uint8*)Convert.Get(), Convert.Length());
        Send(Destination, Encoded, Header, CompletionCallback);
    }
 
    virtual void Send(const FString& Destination, const FStompBuffer& Body, const FStompHeader& Header=FStompHeader(),  const FStompRequestCompleted& CompletionCallback = FStompRequestCompleted()) = 0;
 
 
    virtual void Send(const FString& Destination, const FString& Body, const FStompRequestCompleted& CompletionCallback)
    {
        Send(Destination, Body, FStompHeader(), CompletionCallback);
    }
 
    virtual void Send(const FString& Destination, const FStompBuffer& Body, const FStompRequestCompleted& CompletionCallback)
    {
        Send(Destination, Body, FStompHeader(), CompletionCallback);
    }
 
    DECLARE_EVENT_ThreeParams(IStompClient, FStompClientConnectedEvent, const FString& /*ProtocolVersion*/, const FString& /*SessionId*/, const FString& /*ServerString*/);
    virtual FStompClientConnectedEvent& OnConnected() = 0;
 
    DECLARE_EVENT_OneParam(IStompClient, FStompClientConnectionErrorEvent, const FString& /* Error */);
    virtual FStompClientConnectionErrorEvent& OnConnectionError() = 0;
 
    DECLARE_EVENT_OneParam(IStompClient, FStompClientErrorEvent, const FString& /* Error */);
    virtual FStompClientErrorEvent& OnError() = 0;
 
    DECLARE_EVENT_OneParam(IStompClient, FStompClientClosedEvent, const FString& /* Reason */);
    virtual FStompClientClosedEvent& OnClosed() = 0;
 
};