Skip to content

Commit

Permalink
_clientCnx.Ask<AskResponse>(payload, TimeSpan.FromSeconds(5))
Browse files Browse the repository at this point in the history
  • Loading branch information
eaba committed Jul 23, 2022
1 parent 80cc881 commit c710a10
Show file tree
Hide file tree
Showing 4 changed files with 8 additions and 8 deletions.
2 changes: 1 addition & 1 deletion SharpPulsar/BinaryProtoLookupService.cs
Original file line number Diff line number Diff line change
Expand Up @@ -315,7 +315,7 @@ private async ValueTask GetPartitionedTopicMetadata(TopicName topicName, TimeSpa
var time = timeout;
var request = Commands.NewPartitionMetadataRequest(topicName.ToString(), _requestId);
var payload = new Payload(request, _requestId, "NewPartitionMetadataRequest");
var askResponse = await _clientCnx.Ask<AskResponse>(payload/*, TimeSpan.FromSeconds(5)*/);
var askResponse = await _clientCnx.Ask<AskResponse>(payload, TimeSpan.FromSeconds(5));
while (true)
{
if (askResponse.Failed)
Expand Down
8 changes: 4 additions & 4 deletions SharpPulsar/SharpPulsar.csproj
Original file line number Diff line number Diff line change
Expand Up @@ -14,18 +14,18 @@
</PropertyGroup>

<ItemGroup>
<PackageReference Include="akka" Version="1.4.39" />
<PackageReference Include="akka" Version="1.4.40" />
<PackageReference Include="Akka.Logger.NLog" Version="1.4.10" />
<PackageReference Include="Apache.Avro" Version="1.11.0" />
<PackageReference Include="App.Metrics.Concurrency" Version="4.3.0" />
<PackageReference Include="AvroSchemaGenerator" Version="2.6.0" />
<PackageReference Include="AvroSchemaGenerator" Version="2.7.0" />
<PackageReference Include="DotNetty.Common" Version="0.7.2" />
<PackageReference Include="Google.Protobuf" Version="3.21.2" />
<PackageReference Include="Google.Protobuf" Version="3.21.3" />
<PackageReference Include="IdentityModel" Version="6.0.0" />
<PackageReference Include="JsonSubTypes" Version="1.9.0" />
<PackageReference Include="K4os.Compression.LZ4" Version="1.2.16" />
<PackageReference Include="Microsoft.CSharp" Version="4.7.0" />
<PackageReference Include="Microsoft.Extensions.ApiDescription.Client" Version="6.0.6">
<PackageReference Include="Microsoft.Extensions.ApiDescription.Client" Version="6.0.7">
<PrivateAssets>all</PrivateAssets>
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
</PackageReference>
Expand Down
4 changes: 2 additions & 2 deletions Tests/SharpPulsar.Test/SharpPulsar.Test.csproj
Original file line number Diff line number Diff line change
Expand Up @@ -20,9 +20,9 @@
</ItemGroup>

<ItemGroup>
<PackageReference Include="Akka.TestKit.Xunit2" Version="1.4.39" />
<PackageReference Include="Akka.TestKit.Xunit2" Version="1.4.40" />
<PackageReference Include="Castle.Core" Version="5.0.0" />
<PackageReference Include="docker.dotnet" Version="3.125.5" />
<PackageReference Include="docker.dotnet" Version="3.125.10" />
<PackageReference Include="FluentAssertions" Version="6.7.0" />
<PackageReference Include="GitHubActionsTestLogger" Version="2.0.1">
<PrivateAssets>all</PrivateAssets>
Expand Down
2 changes: 1 addition & 1 deletion build/_build.csproj
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
</PackageReference>
<PackageReference Include="Microsoft.Azure.Management.AppService.Fluent" Version="1.38.1" />
<PackageReference Include="Nuke.Common" Version="6.1.2" />
<PackageReference Include="docfx.console" Version="2.59.2" ExcludeAssets="build" />
<PackageReference Include="docfx.console" Version="2.59.3" ExcludeAssets="build" />
<PackageReference Include="xunit.runner.console" Version="2.4.1">
<PrivateAssets>all</PrivateAssets>
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
Expand Down

0 comments on commit c710a10

Please sign in to comment.