Subscribe to all events from the aggregate
I'm using Cirqus (https://github.com/d60/Cirqus) framework for a CQRS/Event Sourced application
In all of my implementations of IViewInstance I would like to update a LastChange (DateTime) property when each event is received. At the moment I have to update this property on each IViewInstance by handling it for each and all the events as follows:
public void Handle(IViewContext context, MyEvent e) {
LastChange = DateTime.Parse(e.Meta["time_utc"]);
//...other code
}
But this troublesome since I have to repeat this for all the event handlers on each IViewInstance, plus if I forget then the LastChange property will be wrong. There is other data that I might also want to persist to the IViewInstance from the events metadata like the userId, etc
Is there a way to update this LastChange property without having to repeat this code in all the event handlers?
I'm thinking whether there is a way to subscribe to any and all events via a 'global' event handler from the aggregate (like this DomainEvent)
like this:
public class MyAggregateView : IViewInstance<InstancePerAggregateRootLocator>,
ISubscribeTo<DomainEvent<MyAggregate> {
//etc...
Then implement the 'global' event handler as follows:
public void Handle(IViewContext context, DomainEvent<MyAggregate> e)
=> LastChange = DateTime.Parse(e.Meta["time_utc"]);
Alternatively, I could add a property to the IViewInstance and then populate it myself (similar to how the LastGlobalSequenceNumber property is updated), but then I would need to modify the cirqus internals
c# cqrs event-sourcing cirqus
asked Nov 13 '18 at 12:01
BrettBrett
63
add a comment |
I'm using Cirqus (https://github.com/d60/Cirqus) framework for a CQRS/Event Sourced application
In all of my implementations of IViewInstance I would like to update a LastChange (DateTime) property when each event is received. At the moment I have to update this property on each IViewInstance by handling it for each and all the events as follows:
public void Handle(IViewContext context, MyEvent e) {
LastChange = DateTime.Parse(e.Meta["time_utc"]);
//...other code
}
But this troublesome since I have to repeat this for all the event handlers on each IViewInstance, plus if I forget then the LastChange property will be wrong. There is other data that I might also want to persist to the IViewInstance from the events metadata like the userId, etc
Is there a way to update this LastChange property without having to repeat this code in all the event handlers?
I'm thinking whether there is a way to subscribe to any and all events via a 'global' event handler from the aggregate (like this DomainEvent)
like this:
public class MyAggregateView : IViewInstance<InstancePerAggregateRootLocator>,
ISubscribeTo<DomainEvent<MyAggregate> {
//etc...
Then implement the 'global' event handler as follows:
public void Handle(IViewContext context, DomainEvent<MyAggregate> e)
=> LastChange = DateTime.Parse(e.Meta["time_utc"]);
Alternatively, I could add a property to the IViewInstance and then populate it myself (similar to how the LastGlobalSequenceNumber property is updated), but then I would need to modify the cirqus internals
c# cqrs event-sourcing cirqus
asked Nov 13 '18 at 12:01
BrettBrett
63
add a comment |
I'm using Cirqus (https://github.com/d60/Cirqus) framework for a CQRS/Event Sourced application
In all of my implementations of IViewInstance I would like to update a LastChange (DateTime) property when each event is received. At the moment I have to update this property on each IViewInstance by handling it for each and all the events as follows:
public void Handle(IViewContext context, MyEvent e) {
LastChange = DateTime.Parse(e.Meta["time_utc"]);
//...other code
}
But this troublesome since I have to repeat this for all the event handlers on each IViewInstance, plus if I forget then the LastChange property will be wrong. There is other data that I might also want to persist to the IViewInstance from the events metadata like the userId, etc
Is there a way to update this LastChange property without having to repeat this code in all the event handlers?
I'm thinking whether there is a way to subscribe to any and all events via a 'global' event handler from the aggregate (like this DomainEvent)
like this:
public class MyAggregateView : IViewInstance<InstancePerAggregateRootLocator>,
ISubscribeTo<DomainEvent<MyAggregate> {
//etc...
Then implement the 'global' event handler as follows:
public void Handle(IViewContext context, DomainEvent<MyAggregate> e)
=> LastChange = DateTime.Parse(e.Meta["time_utc"]);
Alternatively, I could add a property to the IViewInstance and then populate it myself (similar to how the LastGlobalSequenceNumber property is updated), but then I would need to modify the cirqus internals
c# cqrs event-sourcing cirqus
asked Nov 13 '18 at 12:01
BrettBrett
63
I'm using Cirqus (https://github.com/d60/Cirqus) framework for a CQRS/Event Sourced application
In all of my implementations of IViewInstance I would like to update a LastChange (DateTime) property when each event is received. At the moment I have to update this property on each IViewInstance by handling it for each and all the events as follows:
public void Handle(IViewContext context, MyEvent e) {
LastChange = DateTime.Parse(e.Meta["time_utc"]);
//...other code
}
But this troublesome since I have to repeat this for all the event handlers on each IViewInstance, plus if I forget then the LastChange property will be wrong. There is other data that I might also want to persist to the IViewInstance from the events metadata like the userId, etc
Is there a way to update this LastChange property without having to repeat this code in all the event handlers?
I'm thinking whether there is a way to subscribe to any and all events via a 'global' event handler from the aggregate (like this DomainEvent)
like this:
public class MyAggregateView : IViewInstance<InstancePerAggregateRootLocator>,
ISubscribeTo<DomainEvent<MyAggregate> {
//etc...
Then implement the 'global' event handler as follows:
public void Handle(IViewContext context, DomainEvent<MyAggregate> e)
=> LastChange = DateTime.Parse(e.Meta["time_utc"]);
Alternatively, I could add a property to the IViewInstance and then populate it myself (similar to how the LastGlobalSequenceNumber property is updated), but then I would need to modify the cirqus internals
c# cqrs event-sourcing cirqus
c# cqrs event-sourcing cirqus
asked Nov 13 '18 at 12:01
BrettBrett
63
asked Nov 13 '18 at 12:01
BrettBrett
63
edited Nov 14 '18 at 1:01
Brett
asked Nov 13 '18 at 12:01
BrettBrett
63
asked Nov 13 '18 at 12:01
BrettBrett
63
asked Nov 13 '18 at 12:01
BrettBrett
63
63
add a comment |
add a comment |
0
active
oldest
votes
Your Answer
StackExchange.ifUsing("editor", function () {
StackExchange.using("externalEditor", function () {
StackExchange.using("snippets", function () {
StackExchange.snippets.init();
});
});
}, "code-snippets");
StackExchange.ready(function() {
var channelOptions = {
tags: "".split(" "),
id: "1"
};
initTagRenderer("".split(" "), "".split(" "), channelOptions);
StackExchange.using("externalEditor", function() {
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled) {
StackExchange.using("snippets", function() {
createEditor();
});
}
else {
createEditor();
}
});
function createEditor() {
StackExchange.prepareEditor({
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader: {
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
},
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
});
}
});
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53280617%2fsubscribe-to-all-events-from-the-aggregate%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
0
active
oldest
votes
0
active
oldest
votes
active
oldest
votes
active
oldest
votes
Thanks for contributing an answer to Stack Overflow!
- Please be sure to answer the question. Provide details and share your research!
But avoid …
- Asking for help, clarification, or responding to other answers.
- Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53280617%2fsubscribe-to-all-events-from-the-aggregate%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
