NServicebus Sagas: SagaNotFound warning even though it finds it...
dirk.mcs...@gmail.com
Hi there,
I hope someone can help me with my problem as I have googled it like crazy with no result.
I am trying to implement a saga in NServicebus. The handle method in the saga calls two different handlers through the bus using the bus.Send() method (see the code below). Then, when each handler is done with its work, it sends a notify message in the same way back to the saga. The saga checks its state and calls MarkAsComplete() when all steps are done. I am using one message queue and endpoint for all communication in this saga.
I get the following two warning lines per handler just before reaching the methods public void Handle(Notify1DataMessage message) and public void Handle(Notify2DataMessage message):
----------------------------------
Warn : Could not find a saga for the message type Notify1Message with id [GUID]. Going to invoke SagaNotFoundHandlers.
WARN: NServiceBus.Sagas.SagaPersistenceBehavior: Could not find a saga for the message type namespace.Notify1Message with id [GUID]. Going to invoke SagaNotFoundHandlers.
---------------------------------
What am I doing wrong? Everything works fine, it finds the notify handle methods in the saga, but why is it complaining?
Relevant code:
public class RemovalSaga : Saga<SomeSagaData>,
IAmStartedByMessages<RemoveDataMessage>, IHandleMessages<Notify1DataMessage>, IHandleMessages<Notify2DataMessage>
// The mapping uses a string property called QueueMessage that is unique public override void ConfigureHowToFindSaga() { ConfigureMapping<RemoveDataMessage>(m => m.QueueMessage).ToSaga(saga => saga.QueueMessage); ConfigureMapping<Notify1DataMessage>(m => m.QueueMessage).ToSaga(saga => saga.QueueMessage); ConfigureMapping<Notify2DataMessage>(m => m.QueueMessage).ToSaga(saga => saga.QueueMessage); }
public void Handle(RemoveDataMessage message) { Data.QueueMessage = message.QueueMessage; //...
var message1 = new Handler1DataMessage { QueueMessage = Data.QueueMessage }; _bus.Send(message1);
var message2 = new Handler2DataMessage { QueueMessage = Data.QueueMessage }; _bus.Send(message2); }
// The warning fires just before this Handle method is reached. public void Handle(Notify1DataMessage message) {
//... if (!Data.AllStepsDone) return; MarkAsComplete(); }
// The warning fires just before this Handle method is reached. public void Handle(Notify2DataMessage message) {
//... if (!Data.AllStepsDone) return; MarkAsComplete(); }}
//Both handlers have the same relevant code (showing one of them):public class Handler1 : IHandleMessages<Handler1DataMessage> //...
public void Handle(Handler1DataMessage message) { //... var notifyMessage = new Notify1DataMessage { QueueMessage = message.QueueMessage }; _bus.Send(notifyMessage); }}
//Endpoint configuration:public class EndpointConfig : IConfigureThisEndpoint, AsA_Server, IWantCustomInitialization{ public void Init() { //... Configure.Features.Enable<Sagas>(); Configure.With() .LicensePath(Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "License\\License.xml")) .NinjectBuilder(kernel) .UseTransport<Msmq>() .RavenPersistence() .RavenSagaPersister() .UnicastBus() .LoadMessageHandlers() .UseRavenTimeoutPersister(); }}
//SomeSagaData:public class SomeSagaData : IContainSagaData{ [Unique] public virtual string QueueMessage { get; set; }
public virtual Guid Id { get; set; } public virtual string Originator { get; set; } public virtual string OriginalMessageId { get; set; } //...}
Andreas Öhlund
--
You received this message because you are subscribed to the Google Groups "Particular Software" group.
To unsubscribe from this group and stop receiving emails from it, send an email to particularsoftw...@googlegroups.com.
To post to this group, send email to particula...@googlegroups.com.
Visit this group at http://groups.google.com/group/particularsoftware.
To view this discussion on the web visit https://groups.google.com/d/msgid/particularsoftware/06d8c2ab-0afd-4463-aab2-6e934f6db843%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
dirk.mcs...@gmail.com
To unsubscribe from this group and stop receiving emails from it, send an email to particularsoftware+unsub...@googlegroups.com.
Andreas Öhlund
To unsubscribe from this group and stop receiving emails from it, send an email to particularsoftw...@googlegroups.com.
To post to this group, send email to particula...@googlegroups.com.
Visit this group at http://groups.google.com/group/particularsoftware.
To view this discussion on the web visit https://groups.google.com/d/msgid/particularsoftware/d35388b8-6947-4eb1-8cc9-ecd1a7336e1e%40googlegroups.com.
indu.alagarsamy
public class TestSaga : Saga<TestSagaData>,
IAmStartedByMessages<StartSaga>,
IHandleMessages<ProcessSomething1Response>,
IHandleMessages<ProcessSomething2Response>,
IHandleSagaNotFound
{
public override void ConfigureHowToFindSaga()
{
ConfigureMapping<ProcessSomething1Response>(message => message.MessageId).ToSaga(data => data.MessageId);
ConfigureMapping<ProcessSomething2Response>(message => message.MessageId).ToSaga(data => data.MessageId);
}
public void Handle(StartSaga message)
{
Console.WriteLine("Received message StartSaga");
Data.MessageId = message.MessageId;
Bus.SendLocal(new ProcessSomething1()
{
MessageId = message.MessageId
});
Bus.SendLocal(new ProcessSomething2()
{
MessageId = message.MessageId
});
Console.WriteLine("StartSaga was successfuly processed.");
}
public void Handle(ProcessSomething1Response message)
{
Data.HasResponse1Arrived = true;
Console.WriteLine("Received ProcessSomething1Response");
if (Data.HasAllResponsesArrived())
{
Console.WriteLine("Saga is complete");
MarkAsComplete();
}
}
public void Handle(ProcessSomething2Response message)
{
Data.HasResponse2Arrived = true;
Console.WriteLine("Received ProcessSomething2Response");
if (Data.HasAllResponsesArrived())
{
Console.WriteLine("Saga is complete");
MarkAsComplete();
}
}
public void Handle(object message)
{
Console.WriteLine("Invoked SagaNotFound -- type: {0}", message.GetType());
}
}
public class TestSagaData : ContainSagaData
{
[Unique]
public Guid MessageId { get; set; }
internal bool HasAllResponsesArrived()
{
if (HasResponse1Arrived && HasResponse2Arrived) return true;
return false;
}
public bool HasResponse1Arrived { get; set; }
public bool HasResponse2Arrived { get; set; }
}
dirk.mcs...@gmail.com
To unsubscribe from this group and stop receiving emails from it, send an email to particularsoftware+unsubscribe@googlegroups.com.
To post to this group, send email to particula...@googlegroups.com.
Visit this group at http://groups.google.com/group/particularsoftware.
To view this discussion on the web visit https://groups.google.com/d/msgid/particularsoftware/06d8c2ab-0afd-4463-aab2-6e934f6db843%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
--
You received this message because you are subscribed to the Google Groups "Particular Software" group.
To unsubscribe from this group and stop receiving emails from it, send an email to particularsoftware+unsub...@googlegroups.com.
To post to this group, send email to particula...@googlegroups.com.
Visit this group at http://groups.google.com/group/particularsoftware.
dirk.mcs...@gmail.com
Andreas Öhlund
--
You received this message because you are subscribed to the Google Groups "Particular Software" group.
To unsubscribe from this group and stop receiving emails from it, send an email to particularsoftw...@googlegroups.com.
To post to this group, send email to particula...@googlegroups.com.
Visit this group at http://groups.google.com/group/particularsoftware.
To view this discussion on the web visit https://groups.google.com/d/msgid/particularsoftware/83ba2903-32cf-4511-add2-73191b165d01%40googlegroups.com.
indu.alagarsamy
On Wednesday, October 22, 2014 2:30:05 AM UTC-7, dirk.mcs...@gmail.com wrote: