要使用 Event Store .NET API 訂閱並監聽 Stream 的變化,可以使用 PersistentSubscriptionSettings.Create 設定訂閱,然後調用 Connection.CreatePersistentSubscriptionAsync 方法建立 Persistent Subscriptions。
1 | ... |
建立後可在 Web interface 看到對應的 Persistent Subscriptions。
接著透過 Connection.ConnectToPersistentSubscription 訂閱 Persistent Subscriptions,指定 Stream 的名稱、Group 的名稱、收到訂閱要做的處理…等即可。
1 | conn.ConnectToPersistentSubscription(streamName, groupName, (_, x) => |
像是下面這邊筆者建立了一個名為 MyGroup 的訂閱,訂閱的來源來自 MyStream,建立訂閱後連結訂閱,然後將收到的訂閱訊息顯示出來。
1 | using EventStore.ClientAPI; |
這邊可以將程式運行起來。
透過 Web interface 發送 Event。
就會看到程式這邊收到並顯示了訂閱的訊息。