You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by "entvex (via GitHub)" <gi...@apache.org> on 2023/07/05 13:26:29 UTC
[GitHub] [pulsar-dotpulsar] entvex commented on a diff in pull request #162: Partitioned topic support
entvex commented on code in PR #162:
URL: https://github.com/apache/pulsar-dotpulsar/pull/162#discussion_r1253108841
##########
src/DotPulsar/Internal/Consumer.cs:
##########
@@ -17,56 +17,103 @@ namespace DotPulsar.Internal;
using DotPulsar.Abstractions;
using DotPulsar.Exceptions;
using DotPulsar.Internal.Abstractions;
+using DotPulsar.Internal.Compression;
using DotPulsar.Internal.Events;
using DotPulsar.Internal.Extensions;
using DotPulsar.Internal.PulsarApi;
using Microsoft.Extensions.ObjectPool;
using System;
+using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
-public sealed class Consumer<TMessage> : IContainsChannel, IConsumer<TMessage>
+public sealed class Consumer<TMessage> : IConsumer<TMessage>
{
- private readonly Guid _correlationId;
- private readonly IRegisterEvent _eventRegister;
- private IConsumerChannel<TMessage> _channel;
- private readonly ObjectPool<CommandAck> _commandAckPool;
+ private readonly IConnectionPool _connectionPool;
+ private readonly ProcessManager _processManager;
+ private readonly StateManager<ConsumerState> _state;
+ private readonly ConsumerOptions<TMessage> _options;
+ private readonly ConcurrentDictionary<string, SubConsumer<TMessage>> _subConsumers;
+ private readonly CancellationTokenSource _cts;
+ private readonly IHandleException _exceptionHandler;
private readonly IExecute _executor;
- private readonly IStateChanged<ConsumerState> _state;
- private readonly IConsumerChannelFactory<TMessage> _factory;
private int _isDisposed;
- private Exception? _faultException;
+ private bool _isPartitioned;
+ private uint _numberOfPartitions;
+ private Task<IMessage<TMessage>>?[] _receiveTaskQueueForSubConsumers;
+ private int _subConsumerIndex;
+ private Exception? _faultException; //TODO This is not used. Is that bad ?
Review Comment:
This can be removed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org