MessageBus.h

Go to the documentation of this file.

// Copyright Epic Games, Inc. All Rights Reserved.
 
#pragma once
 
#include "CoreMinimal.h"
#include "IMessageContext.h"
#include "IMessageSubscription.h"
#include "IMessageAttachment.h"
#include "IMessageInterceptor.h"
#include "IAuthorizeMessageRecipients.h"
#include "IMessageTracer.h"
#include "IMessageBus.h"
 
class FMessageRouter;
class IMessageReceiver;
class IMessageSender;
 
class FMessageBus
    : public TSharedFromThis<FMessageBus, ESPMode::ThreadSafe>
    , public IMessageBus
{
public:
    
    FMessageBus(FString InName, const TSharedPtr<IAuthorizeMessageRecipients>& InRecipientAuthorizer);
 
    virtual ~FMessageBus();
 
public:
 
    //~ IMessageBus interface
 
    virtual void Forward(const TSharedRef<IMessageContext, ESPMode::ThreadSafe>& Context, const TArray<FMessageAddress>& Recipients, const FTimespan& Delay, const TSharedRef<IMessageSender, ESPMode::ThreadSafe>& Forwarder) override;
    virtual TSharedRef<IMessageTracer, ESPMode::ThreadSafe> GetTracer() override;
    virtual void Intercept(const TSharedRef<IMessageInterceptor, ESPMode::ThreadSafe>& Interceptor, const FTopLevelAssetPath& MessageType) override;
    virtual FOnMessageBusShutdown& OnShutdown() override;
    virtual void Publish(void* Message, UScriptStruct* TypeInfo, EMessageScope Scope, const TMap<FName, FString>& Annotations, const FTimespan& Delay, const FDateTime& Expiration, const TSharedRef<IMessageSender, ESPMode::ThreadSafe>& Publisher) override;
    virtual void Register(const FMessageAddress& Address, const TSharedRef<IMessageReceiver, ESPMode::ThreadSafe>& Recipient) override;
    virtual void Send(void* Message, UScriptStruct* TypeInfo, EMessageFlags Flags, const TMap<FName, FString>& Annotations, const TSharedPtr<IMessageAttachment, ESPMode::ThreadSafe>& Attachment, const TArray<FMessageAddress>& Recipients, const FTimespan& Delay, const FDateTime& Expiration, const TSharedRef<IMessageSender, ESPMode::ThreadSafe>& Sender) override;
    virtual void Shutdown() override;
    virtual TSharedPtr<IMessageSubscription, ESPMode::ThreadSafe> Subscribe(const TSharedRef<IMessageReceiver, ESPMode::ThreadSafe>& Subscriber, const FTopLevelAssetPath& MessageType, const FMessageScopeRange& ScopeRange) override;
    virtual void Unintercept(const TSharedRef<IMessageInterceptor, ESPMode::ThreadSafe>& Interceptor, const FTopLevelAssetPath& MessageType) override;
    virtual void Unregister(const FMessageAddress& Address) override;
    virtual void Unsubscribe(const TSharedRef<IMessageReceiver, ESPMode::ThreadSafe>& Subscriber, const FTopLevelAssetPath& MessageType) override;
 
    virtual void AddNotificationListener(const TSharedRef<IBusListener, ESPMode::ThreadSafe>& Listener) override;
    virtual void RemoveNotificationListener(const TSharedRef<IBusListener, ESPMode::ThreadSafe>& Listener) override;
    virtual const FString& GetName() const override;
 
private:
    const FString Name;
 
    FMessageRouter* Router;
 
    FRunnableThread* RouterThread;
 
    TSharedPtr<IAuthorizeMessageRecipients> RecipientAuthorizer;
 
    FOnMessageBusShutdown ShutdownDelegate;
};