From 8c5537c33dca305bd91802f74aaf74155ef0182e Mon Sep 17 00:00:00 2001
From: Brandon Thomas <echelon@gmail.com>
Date: Thu, 18 Feb 2021 04:31:40 -0500
Subject: [PATCH] Can't reconnect to Redis, and it randomly dies... ugh

The pattern of unsubscribe/subscribe seems to segfault, as do reconnect,
etc. This Redis plugin isn't durable.
---
 Source/EventCenterPlugin/Private/EventSourceActor.cpp | 11 +++++++++++
 Source/EventCenterPlugin/Public/EventSourceActor.h    |  3 +++
 2 files changed, 14 insertions(+)

diff --git a/Source/EventCenterPlugin/Private/EventSourceActor.cpp b/Source/EventCenterPlugin/Private/EventSourceActor.cpp
index e30017c..c47f8f2 100644
--- a/Source/EventCenterPlugin/Private/EventSourceActor.cpp
+++ b/Source/EventCenterPlugin/Private/EventSourceActor.cpp
@@ -34,6 +34,7 @@ void AEventSourceActor::BeginPlay()
 {
 	Super::BeginPlay();
 
+	GEngine->AddOnScreenDebugMessage(-1, 15.0f, FColor::Red, "BeginPlay() - 2");
 	UE_LOG(EventSourceLog, Log, TEXT("BeginPlay()"));
 
 	if (redis == nullptr) {
@@ -55,6 +56,16 @@ void AEventSourceActor::BeginDestroy()
 void AEventSourceActor::Tick(float DeltaTime)
 {
 	Super::Tick(DeltaTime);
+	
+	float time = GetGameTimeSinceCreation();
+
+	if (time - timerLastTime > 15.0) {
+		timerLastTime = time;
+		GEngine->AddOnScreenDebugMessage(-1, 15.0f, FColor::Red, "seconds elapsed");
+		redis->Unsubscribe(TEXT("second"));
+		redis->Subscribe(TEXT("second"));
+	}
+
 
 	// NB: Handled by RedisObject internal delegate
 	//redis->Tick(DeltaTime);
diff --git a/Source/EventCenterPlugin/Public/EventSourceActor.h b/Source/EventCenterPlugin/Public/EventSourceActor.h
index 933c9c2..eb79d3b 100644
--- a/Source/EventCenterPlugin/Public/EventSourceActor.h
+++ b/Source/EventCenterPlugin/Public/EventSourceActor.h
@@ -77,6 +77,9 @@ private:
 	UFUNCTION()
 	void InternalSubscribeCallback(FString Channel, FString Message);
 
+	// For a timer calculation.
+	float timerLastTime = 0.0f;
+
 public:
 	// Called every frame
 	virtual void Tick(float DeltaTime) override;