I hope you’ll bear with my newbie questions here.
connection.ConnectToPersistentSubscription(aggregateStream, subscriptionGroup, EventAppeared, SubscriptionDropped);
I listen for events on this projection with my callback EventAppeared and dispatch them to the appropriate handler using the EventType:
private void EventAppeared(EventStorePersistentSubscriptionBase @base, ResolvedEvent resolvedEvent)
if (!resolvedEvent.Event.IsJson || !dispatcher.Dispatch(resolvedEvent))
However, what I find is that when I get events from “$ce-orders” the EventType in OriginalEvent is “$>” which means that I can’t (using this approach) dispatch an event to the appropriate handler.
What am I doing wrong here? Should I, in fact, be listening for event types (e.g on “$et-OrderUpdated”) rather than aggregate types?