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; }