From 460a2d7b7667f1ff0138ec80b00eb5587a5ddeed Mon Sep 17 00:00:00 2001 From: Samson Amaugo Date: Wed, 26 Jun 2024 21:34:43 +0100 Subject: [PATCH] done --- Provider/RedisStreamAdapter.cs | 2 +- Provider/RedisStreamReceiver.cs | 2 +- Provider/RedisStreamSequenceToken.cs | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/Provider/RedisStreamAdapter.cs b/Provider/RedisStreamAdapter.cs index 50575ba..c46cf61 100644 --- a/Provider/RedisStreamAdapter.cs +++ b/Provider/RedisStreamAdapter.cs @@ -6,7 +6,7 @@ using System.Text.Json; namespace Provider { - internal class RedisStreamAdapter : IQueueAdapter + public class RedisStreamAdapter : IQueueAdapter { private readonly IDatabase _database; private readonly string _providerName; diff --git a/Provider/RedisStreamReceiver.cs b/Provider/RedisStreamReceiver.cs index f5019cd..b6372df 100644 --- a/Provider/RedisStreamReceiver.cs +++ b/Provider/RedisStreamReceiver.cs @@ -5,7 +5,7 @@ using StackExchange.Redis; namespace Provider { - internal class RedisStreamReceiver : IQueueAdapterReceiver + public class RedisStreamReceiver : IQueueAdapterReceiver { private readonly QueueId _queueId; private readonly IDatabase _database; diff --git a/Provider/RedisStreamSequenceToken.cs b/Provider/RedisStreamSequenceToken.cs index 53b7190..cd2fcc5 100644 --- a/Provider/RedisStreamSequenceToken.cs +++ b/Provider/RedisStreamSequenceToken.cs @@ -4,7 +4,7 @@ using StackExchange.Redis; namespace Provider { [GenerateSerializer] - internal class RedisStreamSequenceToken : StreamSequenceToken + public class RedisStreamSequenceToken : StreamSequenceToken { [Id(0)] public override long SequenceNumber { get; protected set; }