Sha256: 2817abb2632623d3b226a0a6aefc202b50d4cf147ccc4029515fa595bc11540d
Contents?: true
Size: 866 Bytes
Versions: 5
Compression:
Stored size: 866 Bytes
Contents
using System; using FubuTransportation; using FubuTransportation.Configuration; namespace %NAMESPACE% { public class BusSettings { public BusSettings() { Inbound = "memory://transport/inbound".ToUri(); Outbound = "memory://transport/outbound".ToUri(); } public Uri Inbound { get; set; } public Uri Outbound { get; set; } } public class %TRANSPORT_REGISTRY% : FubuTransportRegistry<BusSettings> { public %TRANSPORT_REGISTRY%() { EnableInMemoryTransport(); // 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