An observable µService bus .NET library that wraps the complexities of your particular transport in simple Rx based interfaces.
christopherread on master
Monorepo readme update Merge pull request #9 from mega… (compare)
megakid on master
Correct RepositoryUrl (compare)
megakid on master
Get rid of warnings and fix bu… (compare)
megakid on master
Fix license and dependencies (compare)
megakid on master
Fix licenses Fix build badge F… (compare)
megakid on master
add source link (compare)
megakid on master
Add symbol package type flag (compare)
megakid on master
Update dotnet.yml (compare)
megakid on master
Update dotnet.yml (compare)
megakid on master
add tag trigger (compare)
megakid on v6.0.0
megakid on 6.0.0
megakid on master
Add Directory.Build.props for c… Remove appveyor.yml add symbols to packages (compare)
megakid on master
Introduce new AllMessages optio… ServiceBus now uses an IService… Removed Subscribe() from IServi… and 2 more (compare)
@/all thanks to @megakid we have Obvs v4.0 on nuget, updated to System.Reactive 3.1.1
https://www.nuget.org/packages/Obvs
The other packages that have been updated so far are Obvs.ActiveMQ and Obvs.Serialization. The others will be updated soon.
JamesConnor
private static IServiceBusClient CreateServiceBusClient()
{
return ServiceBus.Configure()
.WithRabbitMQEndpoints<IABCMessage>()
.Named("ABCServiceObvs")
.ConnectToBroker("amqp://localhost:5672")
//.SerializedAsJson()
.SerializedAsProtoBuf()
.AsClient()
.UsingConsoleLogging()
.CreateClient();
}
<?xml version="1.0" encoding="utf-8"?>
<packages>
<package id="Microsoft.Diagnostics.Tracing.EventSource.Redist" version="1.1.28" targetFramework="net472" />
<package id="Obvs" version="5.0.0.26" targetFramework="net472" />
<package id="Obvs.RabbitMQ" version="4.1.0.5" targetFramework="net472" />
<package id="Obvs.Serialization.ProtoBuf" version="5.0.0.22" targetFramework="net472" />
<package id="protobuf-net" version="2.4.0" targetFramework="net472" />
<package id="RabbitMQ.Client" version="5.1.0" targetFramework="net472" />
<package id="System.Reactive" version="4.2.0-preview.102" targetFramework="net472" />
<package id="System.Reactive.Core" version="4.2.0-preview.102" targetFramework="net472" />
<package id="System.Reactive.Linq" version="4.2.0-preview.102" targetFramework="net472" />
<package id="System.Runtime.CompilerServices.Unsafe" version="4.5.2" targetFramework="net472" />
<package id="System.Threading.Tasks.Extensions" version="4.5.2" targetFramework="net472" />
<package id="System.ValueTuple" version="4.5.0" targetFramework="net472" />
</packages>