Subscription subscription = CatchupSubscriptionBuilder.Create("$ce-SalesTransactionAggregate")
                                                                  .SetName("CatchupTest1")
                                                                  .UseConnection(eventStoreConnection)
                                                                  .AddEventAppearedHandler((upSubscription,
                                                                                            @event) =>
                                                                                           {
                                                                                               this.TestsFixture.LogMessageToTrace($"Event appeared {@event.OriginalEventNumber}");
                                                                                           })
                                                                  .AddLogger(this.Logger)
                                                                  .AddLastCheckPointChanged((s,
                                                                                             l) =>
                                                                                            {
                                                                                                this.TestsFixture.LogMessageToTrace($"LastCheckPoint changed {l}");

                                                                                                lastCheckpointBroadcasts++;
                                                                                                lastCheckpoint = l;
                                                                                            }, checkPointBroadcastFrequency)
                                                                  .AddLiveProcessingStartedHandler((upSubscription =>
                                                                                                    {
                                                                                                        this.TestsFixture.LogMessageToTrace($"LiveProcessingStarted");

                                                                                                        //Just signal we caught up.
                                                                                                        manualResetEvent.Set();
                                                                                                    }))

                                                                  .Build();