Eventstore:如何正确设置持久订阅客户端

Question

我正在使用EventStoreDB V20，并试图在本地开发机器上设置持久订阅。在仪表板上，我可以看到列出的持久订阅，但从未调用过处理程序。

我正在使用这些裸体：https://www.nuget.org/packages/EventStore.Client.Grpc/https://www.nuget.org/packages/EventStore.Client.Grpc.PersistentSubscriptions/20.10.0

我在docker:中运行EventStore

docker run --name esdb-node -it -p 2113:2113 -p 1113:1113 -e EVENTSTORE_DEV=true eventstore/eventstore:latest --insecure --run-projections=All --enable-atom-pub-over-http

对于附加事件，我会：

await eventStoreClient.AppendToStreamAsync(
aggregate.Id.ToString(),
aggregate.Version == 0 ? StreamRevision.None : StreamRevision.FromInt64(aggregate.Version),                            events);

创建并订阅持久订阅：

var client = new EventStorePersistentSubscriptionsClient(new EventStoreClientSettings {
CreateHttpMessageHandler = () =>
new HttpClientHandler
{
ServerCertificateCustomValidationCallback =
(message, certificate2, x509Chain, sslPolicyErrors) => true // ignore https
},
ConnectivitySettings = new EventStoreClientConnectivitySettings
{
Address = new Uri("http://127.0.0.1:2113?Tls=false&TlsVerifyCert=false")
}});
await client.CreateAsync("all", "TestGroup", new PersistentSubscriptionSettings(startFrom: StreamPosition.End));
await SubscribeAsync(client);
Console.ReadLine();
}
private static Task<PersistentSubscription> SubscribeAsync(EventStorePersistentSubscriptionsClient client)
{
return client.SubscribeAsync("all", "TestGroup",
(subscription, evt, retryCount, cancelToken) =>
{
Console.WriteLine("Received: " + Encoding.UTF8.GetString(evt.Event.Data.Span));
return Task.CompletedTask;
});
}

Console.WriteLine从不被调用。我需要更改什么？

Answer 1

一切似乎都设置正确，但我怀疑您是否拥有名称为all的流。如果您正在尝试为$all流创建持久订阅，则这是不可能的。您只能对$all流进行追赶订阅。