mookid8000

namespace Web.Installers
{
    public class MongoInstaller : IWindsorInstaller
    {
        public void Install(IWindsorContainer container, IConfigurationStore store)
        {
            container
                .Register(AllTypes.FromThisAssembly()
                              .BasedOn<IIndexCreationTask>()
                              .WithService.Base(),

mookid8000

        [Test]
        public void AssertIgnorance()
        {
            var ignoredTestCases = Assembly.GetExecutingAssembly().GetTypes()
                .SelectMany(t => t.GetMethods())
                .Where(m => m.GetCustomAttributes(typeof (IgnoreAttribute), false).Any())
                .ToList();

            Assert.That(ignoredTestCases.Any(), Is.False, @"The following tests have been IGNORED:

mookid8000

var adapter = new MyContainerAdapter(favoriteContainer);

Configure.With(adapter)
    .Transport(t => t.UseMsmq("some_input_queue"))
    .Serialization(s => s.UseJsonSerializer())
    .Sagas(s => s.StoreInSqlServer(connectionstring, "saga_table", "saga_index_table"))
    .Subscriptions(s => s.StoreInSqlServer(connectionstring, "subscriptions"))
    .SpecifyOrderOfHandlers(h => h.First<SomeType>().Then<AnotherType>())
    .Logging(l => l.Log4Net())
    .DetermineEndpoints(d => d.FromRebusMappingsSection())

mookid8000

static readonly Regex TagsRegex = new Regex(@"(?:(?<=\s)|^)#(\w*[A-Za-z_]+\w*)");
static readonly Regex MentionsRegex = new Regex(@"(?:(?<=\s)|^)\@(\w*[A-Za-z_]+\w*)");

mookid8000

public interface ICommand : IMessage {}
public interface IEvent : IMessage {}
public interface IRequest : IMessage {}
public interface IReply : IMessage {}

mookid8000

    public class EndpointConfiguration : IConfigureThisEndpoint,
        AsA_Server, 
        IWantCustomInitialization, 
        IWantToRunAtStartup
    {
        readonly IWindsorContainer container;

        public EndpointConfiguration()
        {
            container = new WindsorContainerDecorator()

mookid8000

    public class EndpointConfiguration : IConfigureThisEndpoint, 
        IWantCustomLogging,
        IWantCustomInitialization
    {
        public void Init()
        {
            Configure.With()
                .DefaultBuilder()
                .XmlSerializer()
                .MsmqTransport()

mookid8000

var bus = Configure.With()
	.DefaultBuilder()
	.XmlSerializer()
	.MsmqTransport().IsTransactional(false)
	.UnicastBus().LoadMessageHandlers()
	.CreateBus()
	.Start();

mookid8000

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <configSections>
    <section name="MsmqTransportConfig" type="NServiceBus.Config.MsmqTransportConfig, NServiceBus.Core" />
    <section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core" />
  </configSections>
    
  <MsmqTransportConfig InputQueue="someClient"
                       ErrorQueue="error"
                       NumberOfWorkerThreads="1"

mookid8000

foreach(var derivedMessageType in GetAllMessageTypes().Where(t => typeof(IBaseMessage).IsAssignableFrom(t))
{
    bus.GetType().GetMethod("Subscribe").MakeGenericMethod(derivedMessageType).Invoke(bus, new object[0]);
}