Skip to content

Commit

Permalink
Updated ProducerConsumer to 0.2.0.49 [skip ci]
Browse files Browse the repository at this point in the history
  • Loading branch information
@Kralizek
Kralizek committed Sep 14, 2015
1 parent b62e86b commit 9415d32
Show file tree
Hide file tree
Showing 10 changed files with 45 additions and 45 deletions.
1 change: 1 addition & 0 deletions samples/ProducerConsumer/Consumer/AppInstaller.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
using Nybus;
using Nybus.Configuration;
using Nybus.Container;
using Nybus.Logging;
using Nybus.MassTransit;

namespace Consumer
Expand Down
13 changes: 5 additions & 8 deletions samples/ProducerConsumer/Consumer/ConsoleLogger.cs
View file
Original file line number Diff line number Diff line change
@@ -1,20 +1,17 @@
using System;
using System.Threading.Tasks;
using Nybus.Configuration;
using Nybus.Logging;

namespace Consumer
{
public class ConsoleLogger : ILogger
public class ConsoleLogger : LoggerBase
{
public Task LogAsync(LogLevel level, string message, object data = null)
{
Log(level, message, data);
return Task.FromResult(0);
}

public void Log(LogLevel level, string message, object data = null)
protected override Task LogEvent(LogLevel level, string message, object data, string callerMemberName)
{
Console.WriteLine($"\t{level:G} {message}");

return Task.CompletedTask;
}
}
}
16 changes: 8 additions & 8 deletions samples/ProducerConsumer/Consumer/Consumer.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -57,20 +57,20 @@
<HintPath>..\..\..\Packages\Newtonsoft.Json.6.0.6\lib\net45\Newtonsoft.Json.dll</HintPath>
<Private>True</Private>
</Reference>
<Reference Include="Nybus.CastleWindsor, Version=0.0.33.0, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.Castle.Windsor.0.0.33.0\lib\net46\Nybus.CastleWindsor.dll</HintPath>
<Reference Include="Nybus.CastleWindsor, Version=0.2.0.49, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.Castle.Windsor.0.2.0.49\lib\net46\Nybus.CastleWindsor.dll</HintPath>
<Private>True</Private>
</Reference>
<Reference Include="Nybus.Core, Version=0.0.33.0, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.Core.0.0.33.0\lib\net46\Nybus.Core.dll</HintPath>
<Reference Include="Nybus.Core, Version=0.2.0.49, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.Core.0.2.0.49\lib\net46\Nybus.Core.dll</HintPath>
<Private>True</Private>
</Reference>
<Reference Include="Nybus.Interfaces, Version=0.0.33.0, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.Interfaces.0.0.33.0\lib\net46\Nybus.Interfaces.dll</HintPath>
<Reference Include="Nybus.Interfaces, Version=0.2.0.49, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.Interfaces.0.2.0.49\lib\net46\Nybus.Interfaces.dll</HintPath>
<Private>True</Private>
</Reference>
<Reference Include="Nybus.MassTransit, Version=0.0.33.0, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.MassTransit.0.0.33.0\lib\net46\Nybus.MassTransit.dll</HintPath>
<Reference Include="Nybus.MassTransit, Version=0.2.0.49, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.MassTransit.0.2.0.49\lib\net46\Nybus.MassTransit.dll</HintPath>
<Private>True</Private>
</Reference>
<Reference Include="RabbitMQ.Client, Version=3.4.3.0, Culture=neutral, PublicKeyToken=89e7d7c5feba84ce, processorArchitecture=MSIL">
Expand Down
8 changes: 4 additions & 4 deletions samples/ProducerConsumer/Consumer/packages.config
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,9 +6,9 @@
<package id="MassTransit" version="2.10.1" targetFramework="net46" />
<package id="MassTransit.RabbitMQ" version="2.10.1" targetFramework="net46" />
<package id="Newtonsoft.Json" version="6.0.6" targetFramework="net46" />
<package id="Nybus.Castle.Windsor" version="0.0.33.0" targetFramework="net46" />
<package id="Nybus.Core" version="0.0.33.0" targetFramework="net46" />
<package id="Nybus.Interfaces" version="0.0.33.0" targetFramework="net46" />
<package id="Nybus.MassTransit" version="0.0.33.0" targetFramework="net46" />
<package id="Nybus.Castle.Windsor" version="0.2.0.49" targetFramework="net46" />
<package id="Nybus.Core" version="0.2.0.49" targetFramework="net46" />
<package id="Nybus.Interfaces" version="0.2.0.49" targetFramework="net46" />
<package id="Nybus.MassTransit" version="0.2.0.49" targetFramework="net46" />
<package id="RabbitMQ.Client" version="3.4.3" targetFramework="net46" />
</packages>
4 changes: 2 additions & 2 deletions samples/ProducerConsumer/Messages/Messages.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,8 @@
<WarningLevel>4</WarningLevel>
</PropertyGroup>
<ItemGroup>
<Reference Include="Nybus.Interfaces, Version=0.0.33.0, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.Interfaces.0.0.33.0\lib\net46\Nybus.Interfaces.dll</HintPath>
<Reference Include="Nybus.Interfaces, Version=0.2.0.49, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.Interfaces.0.2.0.49\lib\net46\Nybus.Interfaces.dll</HintPath>
<Private>True</Private>
</Reference>
<Reference Include="System" />
Expand Down
2 changes: 1 addition & 1 deletion samples/ProducerConsumer/Messages/packages.config
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,5 +2,5 @@
<packages>
<package id="Castle.Core" version="3.3.3" targetFramework="net46" />
<package id="Castle.Windsor" version="3.3.0" targetFramework="net46" />
<package id="Nybus.Interfaces" version="0.0.33.0" targetFramework="net46" />
<package id="Nybus.Interfaces" version="0.2.0.49" targetFramework="net46" />
</packages>
8 changes: 7 additions & 1 deletion samples/ProducerConsumer/Producer/AppInstaller.cs
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
using System;
using System.Threading.Tasks;
using Castle.MicroKernel;
using Castle.MicroKernel.Registration;
using Castle.MicroKernel.SubSystems.Configuration;
Expand All @@ -7,6 +8,7 @@
using Nybus;
using Nybus.Configuration;
using Nybus.Container;
using Nybus.Logging;
using Nybus.MassTransit;

namespace Producer
Expand Down Expand Up @@ -45,7 +47,11 @@ public void Install(IWindsorContainer container, IConfigurationStore store)

private void ConfigureSubscriptions(IBusBuilder builder)
{
builder.SubscribeToEvent<ItemProduced>(async ctx => Console.WriteLine($"{ctx.Message.Quantity} of {ctx.Message.ItemId} produced."));
builder.SubscribeToEvent<ItemProduced>(ctx =>
{
Console.WriteLine($"{ctx.Message.Quantity} of {ctx.Message.ItemId} produced.");
return Task.CompletedTask;
});
}
}
}
14 changes: 5 additions & 9 deletions samples/ProducerConsumer/Producer/ConsoleLogger.cs
View file
Original file line number Diff line number Diff line change
@@ -1,20 +1,16 @@
using System;
using System.Threading.Tasks;
using Nybus.Configuration;
using Nybus.Logging;

namespace Producer
{
public class ConsoleLogger : ILogger
public class ConsoleLogger : LoggerBase
{
public Task LogAsync(LogLevel level, string message, object data = null)
{
Log(level, message, data);
return Task.FromResult(0);
}

public void Log(LogLevel level, string message, object data = null)
protected override Task LogEvent(LogLevel level, string message, object data, string callerMemberName)
{
Console.WriteLine($"\t{level:G} {message}");

return Task.CompletedTask;
}
}
}
16 changes: 8 additions & 8 deletions samples/ProducerConsumer/Producer/Producer.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -57,20 +57,20 @@
<HintPath>..\..\..\Packages\Newtonsoft.Json.6.0.6\lib\net45\Newtonsoft.Json.dll</HintPath>
<Private>True</Private>
</Reference>
<Reference Include="Nybus.CastleWindsor, Version=0.0.33.0, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.Castle.Windsor.0.0.33.0\lib\net46\Nybus.CastleWindsor.dll</HintPath>
<Reference Include="Nybus.CastleWindsor, Version=0.2.0.49, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.Castle.Windsor.0.2.0.49\lib\net46\Nybus.CastleWindsor.dll</HintPath>
<Private>True</Private>
</Reference>
<Reference Include="Nybus.Core, Version=0.0.33.0, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.Core.0.0.33.0\lib\net46\Nybus.Core.dll</HintPath>
<Reference Include="Nybus.Core, Version=0.2.0.49, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.Core.0.2.0.49\lib\net46\Nybus.Core.dll</HintPath>
<Private>True</Private>
</Reference>
<Reference Include="Nybus.Interfaces, Version=0.0.33.0, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.Interfaces.0.0.33.0\lib\net46\Nybus.Interfaces.dll</HintPath>
<Reference Include="Nybus.Interfaces, Version=0.2.0.49, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.Interfaces.0.2.0.49\lib\net46\Nybus.Interfaces.dll</HintPath>
<Private>True</Private>
</Reference>
<Reference Include="Nybus.MassTransit, Version=0.0.33.0, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.MassTransit.0.0.33.0\lib\net46\Nybus.MassTransit.dll</HintPath>
<Reference Include="Nybus.MassTransit, Version=0.2.0.49, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\..\Packages\Nybus.MassTransit.0.2.0.49\lib\net46\Nybus.MassTransit.dll</HintPath>
<Private>True</Private>
</Reference>
<Reference Include="RabbitMQ.Client, Version=3.4.3.0, Culture=neutral, PublicKeyToken=89e7d7c5feba84ce, processorArchitecture=MSIL">
Expand Down
8 changes: 4 additions & 4 deletions samples/ProducerConsumer/Producer/packages.config
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,9 +6,9 @@
<package id="MassTransit" version="2.10.1" targetFramework="net46" />
<package id="MassTransit.RabbitMQ" version="2.10.1" targetFramework="net46" />
<package id="Newtonsoft.Json" version="6.0.6" targetFramework="net46" />
<package id="Nybus.Castle.Windsor" version="0.0.33.0" targetFramework="net46" />
<package id="Nybus.Core" version="0.0.33.0" targetFramework="net46" />
<package id="Nybus.Interfaces" version="0.0.33.0" targetFramework="net46" />
<package id="Nybus.MassTransit" version="0.0.33.0" targetFramework="net46" />
<package id="Nybus.Castle.Windsor" version="0.2.0.49" targetFramework="net46" />
<package id="Nybus.Core" version="0.2.0.49" targetFramework="net46" />
<package id="Nybus.Interfaces" version="0.2.0.49" targetFramework="net46" />
<package id="Nybus.MassTransit" version="0.2.0.49" targetFramework="net46" />
<package id="RabbitMQ.Client" version="3.4.3" targetFramework="net46" />
</packages>

0 comments on commit 9415d32

Please sign in to comment.