I hope you’ll bear with my newbie questions here.
Going by this post, I understand that if I have a service that is interested in orders (with event types OrderCreated and OrderUpdated) then I want to subscribe to the “$ce-orders” projection:
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))
{
publisher.Publish(new InvalidMessage(resolvedEvent.OriginalEvent));
}
}
}
``
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?