[GitHub] [pulsar-dotpulsar] dionjansen commented on a change in pull request #67: Support for (optional) ack timeout and nack delay for consumers

dionjansen commented on a change in pull request #67: URL: https://github.com/apache/pulsar-dotpulsar/pull/67#discussion_r558418524 ## File path: src/DotPulsar/Internal/MessageQueue.cs ## @@ -0,0 +1,53 @@ +/* + * Licensed under the Apache License, Version 2.0 (the "License"); +

[GitHub] [pulsar-dotpulsar] dionjansen commented on a change in pull request #67: Support for (optional) ack timeout and nack delay for consumers

dionjansen commented on a change in pull request #67: URL: https://github.com/apache/pulsar-dotpulsar/pull/67#discussion_r558418667 ## File path: src/DotPulsar/Internal/UnackedMessageTracker.cs ## @@ -0,0 +1,115 @@ +/* + * Licensed under the Apache License, Version 2.0 (the "L

[GitHub] [pulsar-dotpulsar] dionjansen commented on a change in pull request #67: Support for (optional) ack timeout and nack delay for consumers

dionjansen commented on a change in pull request #67: URL: https://github.com/apache/pulsar-dotpulsar/pull/67#discussion_r558418794 ## File path: tests/DotPulsar.Tests/Internal/MessageAcksTrackerTests.cs ## @@ -0,0 +1,158 @@ +/* + * Licensed under the Apache License, Version 2.

[GitHub] [pulsar-dotpulsar] dionjansen commented on a change in pull request #67: Support for (optional) ack timeout and nack delay for consumers

dionjansen commented on a change in pull request #67: URL: https://github.com/apache/pulsar-dotpulsar/pull/67#discussion_r558433871 ## File path: src/DotPulsar/Internal/InactiveUnackedMessageTracker.cs ## @@ -0,0 +1,31 @@ +namespace DotPulsar.Internal +{ +using System.Thre

[GitHub] [pulsar-dotpulsar] dionjansen commented on a change in pull request #67: Support for (optional) ack timeout and nack delay for consumers

dionjansen commented on a change in pull request #67: URL: https://github.com/apache/pulsar-dotpulsar/pull/67#discussion_r558434707 ## File path: src/DotPulsar/Internal/ConsumerChannel.cs ## @@ -108,6 +108,9 @@ public async Task Send(CommandAck command, CancellationToken cance

[GitHub] [pulsar-dotpulsar] dionjansen commented on a change in pull request #67: Support for (optional) ack timeout and nack delay for consumers

dionjansen commented on a change in pull request #67: URL: https://github.com/apache/pulsar-dotpulsar/pull/67#discussion_r558440605 ## File path: src/DotPulsar/Internal/UnackedMessageTracker.cs ## @@ -0,0 +1,101 @@ +namespace DotPulsar.Internal +{ +using Abstractions; +

[GitHub] [pulsar-dotpulsar] dionjansen commented on pull request #67: Support for (optional) ack timeout and nack delay for consumers

dionjansen commented on pull request #67: URL: https://github.com/apache/pulsar-dotpulsar/pull/67#issuecomment-761063358 @blankensteiner sorry for the delay, I addressed all your remarks, let me know what you think! This is

[Success Story] How Pulsar Helps Iterable Scale its Customer Engagement Platform

Hi Pulsar enthusiasts, Hope you are doing well. Recently, we have a fresh Pulsar use case: Iterable had been using RabbitMQ heavily and relied on its features to handle internal messaging. The transition to Pulsar has been interesting and sometimes challenging, but quite successful so far. Cu