I am trying to use manual acknowledge with competitive consumers
I use latest code from gihub repository
both server and client are built from it.
I also tried to make it work few weeks ago with then latest code.
This is the code I use to connect to subscription:
_Connection.ConnectToPersistentSubscription(
_ReadModelStream, // “all”
_ReadModelVersion, // “process_manager_kirill”
EventAppeared,
SubscriptionDropped,
GetCredentials(),
10, // bufferSize
false // autoAck
);
this is EventAppeared method:
private void EventAppeared(EventStorePersistentSubscriptionBase subscription, ResolvedEvent e)
{
try
{
Process(GetEvents(e));
subscription.Acknowledge(e);
}
catch (Exception ex)
{
subscription.Fail(e, PersistentSubscriptionNakEventAction.Park, ex.ToString());
}
}
But what I get is - In Flight column inside “Competing Consumers” tab in EventStore web interface shows that buffer is full - “10”
and new messages are not being processed.
I think this is because it does not respect “Acknowledge” sent manually
Is there any sample of code that guides how to use manual acknowledge?
