Sha256: efeadcc2a0f94589374387bb1f896270a58b0272c0061377bfb90ad70554ce6a
Contents?: true
Size: 836 Bytes
Versions: 5
Compression:
Stored size: 836 Bytes
Contents
using System;
using FubuTransportation;
using FubuTransportation.Configuration;
namespace %NAMESPACE%
{
public class BusSettings
{
public BusSettings()
{
Inbound = new Uri("lq.tcp://localhost:2200/inbound");
Outbound = new Uri("lq.tcp://localhost:2201/outbound");
}
public Uri Inbound { get; set; }
public Uri Outbound { get; set; }
}
public class %TRANSPORT_REGISTRY% : FubuTransportRegistry<BusSettings>
{
public %TRANSPORT_REGISTRY%()
{
// More options are available for thread or task scheduling
Channel(x => x.Inbound).ReadIncoming();
// Static subscriptions
Channel(x => x.Outbound)
.AcceptsMessages(x => true);
}
}
}
Version data entries
5 entries across 5 versions & 1 rubygems