Hello, I have a saga like this
public class MySaga
: ISaga<MySagaState>,
InitiatedBy<Start>,
Orchestrates<Timeout>
{
readonly IServiceBus _bus;
public MySagaState State { get; set; }
public Guid Id { get; set; }
public bool IsCompleted { get; set; }
public MySaga(IServiceBus bus)
{
_bus = bus;
this.State = new MySagaState();
}
public void Consume(Start message)
{
State.ActivityId = message.ActivityId;
_bus.DelaySendToSelf(DateTime.Now.AddSeconds(10), new Timeout()
{ CorrelationId = this.Id });
}
public void Consume(Timeout message)
{
_bus.Publish(new Expired() { ActivityId = State.ActivityId });
IsCompleted = true;
}
}
The problem I'm having is that the saga never consumes the Timeout message.
the timeout message finishes in the discarded subqueue.
The logs says that it did not get processed because there were no cosumers
for it.
I'm really confused.
P.S.
I'm using an InMemorySagaPersister to test this saga.
--
You received this message because you are subscribed to the Google Groups
"Rhino Tools Dev" group.
To view this discussion on the web visit
https://groups.google.com/d/msg/rhino-tools-dev/-/ZXvSpUGLfIMJ.
To post to this group, send email to [email protected].
To unsubscribe from this group, send email to
[email protected].
For more options, visit this group at
http://groups.google.com/group/rhino-tools-dev?hl=en.
