Sorry for the email, I clicked the wrong button somewhere :)
Here is the BootStrapper:
public class BootStrapper : AutofacBootStrapper
{
protected override void ConfigureContainer()
{
base.ConfigureContainer();
var builder = new ContainerBuilder();
builder.RegisterGeneric(typeof(InMemorySagaPersister<>)).As(typeof(ISagaPersister<>));
builder.Update(Container);
}
protected override void OnBeginStart()
{
base.OnBeginStart();
XmlConfigurator.Configure();
}
}
and here is the configuration of the bus
<?xml version="1.0" encoding="utf-8" ?>
<configuration>
<configSections>
<section name="rhino.esb"
type="Rhino.ServiceBus.Config.BusConfigurationSection, Rhino.ServiceBus"/>
<section name="log4net"
type="log4net.Config.Log4NetConfigurationSectionHandler, log4net"/>
</configSections>
<rhino.esb>
<bus threadCount="1" numberOfRetries="5"
endpoint="msmq://localhost/rsb-retention" transactional="false" />
<messages>
<add name="MyNamespace.Timeout"
endpoint="msmq://localhost/rsb-retention" transactional="false" />
</messages>
</rhino.esb>
<log4net>
<appender name="ConsoleAppender"
type="log4net.Appender.ConsoleAppender">
<layout type="log4net.Layout.PatternLayout">
<conversionPattern value="%date [%thread] %-5level [%ndc] -
%message%newline"/>
</layout>
</appender>
<root>
<level value="DEBUG"/>
<appender-ref ref="ConsoleAppender"/>
</root>
</log4net>
<runtime>
<assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">
<dependentAssembly>
<assemblyIdentity name="Rhino.Queues"
publicKeyToken="0b3305902db7183f" culture="neutral" />
<bindingRedirect oldVersion="0.0.0.0-1.4.1.0" newVersion="1.4.2.0"/>
</dependentAssembly>
</assemblyBinding>
</runtime>
</configuration>
The assembly binding is because Rhino.ServiceBus.Host.exe works with
Rhino.Qieies 1.4.1.0 :)
Regards, Ivica
Dana utorak, 10. srpnja 2012. 16:43:33 UTC+2, korisnik Corey napisao je:
>
> Which container? How are the consumers getting registered? Test code? Your
> sample *should* work fine so the problem is likely with the container or
> test code.
>
> On Tue, Jul 10, 2012 at 8:20 AM, Ivica Munitic <[email protected]> wrote:
>
>> 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.
>>
>
>
--
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/-/Q8Z-L8ElGhgJ.
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.
