Skip to content
This repository has been archived by the owner on Sep 10, 2021. It is now read-only.

Commit

Permalink
Various fixes
Browse files Browse the repository at this point in the history
- Fixed exclusive queues not consuming exclusively
- Fixed two reply queues being created
- Moved to 0.1.8
  • Loading branch information
alandoherty committed Jan 17, 2019
1 parent 6a19d0d commit b0184ad
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 8 deletions.
4 changes: 2 additions & 2 deletions samples/Example.General/Program.cs
Original file line number Diff line number Diff line change
Expand Up @@ -77,9 +77,9 @@ static async Task AsyncMain(string[] args) {
});

// attach
Service service = await TestNode.AttachAsync("auth:login", RpcBehaviour.Bind<ITest001>(new Test001(Guid.NewGuid())));
//Service service = await TestNode.AttachAsync("auth:login", RpcBehaviour.Bind<ITest001>(new Test001(Guid.NewGuid())));

service.Dispose();
//service.Dispose();

await Task.Delay(50000);
}
Expand Down
6 changes: 3 additions & 3 deletions src/Holon/Holon.csproj
Original file line number Diff line number Diff line change
Expand Up @@ -2,19 +2,19 @@

<PropertyGroup>
<TargetFramework>netstandard1.6</TargetFramework>
<Version>0.1.7.1</Version>
<Version>0.1.8</Version>
<Authors>Alan Doherty</Authors>
<Company>Alan Doherty</Company>
<Description>A minimal service and event bus with additional support for RPC</Description>
<Copyright>BattleCrate Ltd 2018</Copyright>
<PackageProjectUrl>https://github.com/alandoherty/holon-net</PackageProjectUrl>
<RepositoryUrl>https://github.com/alandoherty/holon-net</RepositoryUrl>
<RepositoryType>git</RepositoryType>
<AssemblyVersion>0.1.7.1</AssemblyVersion>
<AssemblyVersion>0.1.8.0</AssemblyVersion>
<PackageLicenseUrl>https://github.com/alandoherty/holon-net/blob/master/LICENSE</PackageLicenseUrl>
<GeneratePackageOnBuild>true</GeneratePackageOnBuild>
<PackageIconUrl>https://s3-eu-west-1.amazonaws.com/assets.alandoherty.co.uk/github/holon-net-nuget.png</PackageIconUrl>
<FileVersion>0.1.7.1</FileVersion>
<FileVersion>0.1.8.0</FileVersion>
</PropertyGroup>

<PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">
Expand Down
2 changes: 0 additions & 2 deletions src/Holon/Node.cs
Original file line number Diff line number Diff line change
Expand Up @@ -791,8 +791,6 @@ public Task<EventSubscription> SubscribeAsync(string addr) {
// try and find broker endpoint
if (endpoint == null && configuration.Namespaces.Length == 0)
throw new ArgumentNullException("The environment does not contain any namespaces");
else if (endpoint != null)
configuration.Namespaces = configuration.Namespaces.Concat(new NamespaceEndpoint[] { new NamespaceEndpoint("*", new Uri(endpoint)) }).ToArray();

return CreateAsync(endpoint, configuration);
}
Expand Down
2 changes: 1 addition & 1 deletion src/Holon/Protocol/Broker.cs
Original file line number Diff line number Diff line change
Expand Up @@ -181,7 +181,7 @@ public async Task<BrokerQueue> CreateQueueAsync(string name = "", bool durable =

try {
consumerTag = (string)await _ctx.AskWork(delegate () {
return _channel.BasicConsume(name, autoAck, "", false, false, null, consumer);
return _channel.BasicConsume(name, autoAck, "", false, exclusive, null, consumer);
}).ConfigureAwait(false);
} catch (Exception) {
throw;
Expand Down

0 comments on commit b0184ad

Please sign in to comment.