Skip to content
This repository was archived by the owner on Aug 4, 2023. It is now read-only.

Commit 4b8eb6b

Browse files
committed
update nuget versions
1 parent f41503d commit 4b8eb6b

File tree

11 files changed

+43
-21
lines changed

11 files changed

+43
-21
lines changed

.gitignore

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,3 +16,5 @@
1616
/Analogy.Implementation.KafkaProvider.Example/obj
1717
/Analogy.Implementation.KafkaProvider.UnitTests/bin/Release
1818
/Analogy.Implementation.KafkaProvider.UnitTests/obj/Release
19+
/Analogy.Implementation.KafkaProvider/Properties/PublishProfiles
20+
/nuget.exe
Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,18 +2,20 @@
22

33
<PropertyGroup>
44
<TargetFramework>netstandard2.0</TargetFramework>
5-
<Version>0.1.1</Version>
5+
<Version>0.1.2</Version>
66
<Authors>Lior Banai</Authors>
77
<Company>Lior Banai</Company>
88
<Product>Analogy.Implementation.KafkaProvider</Product>
99
</PropertyGroup>
1010

1111
<ItemGroup>
12-
<PackageReference Include="Analogy.LogViewer.Interfaces" Version="2.1.5.1" />
12+
<PackageReference Include="Analogy.LogViewer.Interfaces" Version="2.1.6.1" />
13+
<PackageReference Include="Confluent.Kafka" Version="1.2.2" />
14+
<PackageReference Include="librdkafka.redist" Version="1.2.2" />
1315
</ItemGroup>
1416

1517
<ItemGroup>
16-
<ProjectReference Include="..\Analogy.Implementation.KafkaProvider\Analogy.Implementation.KafkaProvider.csproj" />
18+
<ProjectReference Include="..\Analogy.Implementation.KafkaProvider\Analogy.LogViewer.KafkaProvider.csproj" />
1719
</ItemGroup>
1820

1921
</Project>

Analogy.Implementation.KafkaProvider.Example/AnalogyKafkaExampleDataProvider.cs

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -44,17 +44,21 @@ public void StopReceiving()
4444
Consumer.OnError -= Consumer_OnError;
4545

4646
}
47-
48-
public void InitDataProvider()
47+
48+
public Task InitializeDataProviderAsync()
4949
{
50-
5150
Producer = new KafkaProducer<AnalogyLogMessage>(kafkaUrl, topic, new KafkaSerializer<AnalogyLogMessage>());
5251
Consumer = new KafkaConsumer<AnalogyLogMessage>(groupId, kafkaUrl, topic);
5352
Consumer.OnMessageReady += Consumer_OnMessageReady;
5453
Consumer.OnError += Consumer_OnError;
5554
sim = new TimerMessagesSimulator(async m => { await Producer.PublishAsync(m); });
5655
IsConnected = true;
56+
return Task.CompletedTask;
57+
}
5758

59+
public void MessageOpened(AnalogyLogMessage message)
60+
{
61+
//nop
5862
}
5963

6064
private void Consumer_OnError(object sender, KafkaMessageArgs<string> e)
Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -76,9 +76,9 @@
7676
<None Include="packages.config" />
7777
</ItemGroup>
7878
<ItemGroup>
79-
<ProjectReference Include="..\Analogy.Implementation.KafkaProvider\Analogy.Implementation.KafkaProvider.csproj">
79+
<ProjectReference Include="..\Analogy.Implementation.KafkaProvider\Analogy.LogViewer.KafkaProvider.csproj">
8080
<Project>{512d664a-7f6f-412c-b47c-78c4f6d7bdaa}</Project>
81-
<Name>Analogy.Implementation.KafkaProvider</Name>
81+
<Name>Analogy.LogViewer.KafkaProvider</Name>
8282
</ProjectReference>
8383
</ItemGroup>
8484
<Import Project="$(VSToolsPath)\TeamTest\Microsoft.TestTools.targets" Condition="Exists('$(VSToolsPath)\TeamTest\Microsoft.TestTools.targets')" />
Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2,12 +2,13 @@
22
<package xmlns="http://schemas.microsoft.com/packaging/2010/07/nuspec.xsd">
33
<metadata>
44
<id>Analogy.LogViewer.KafkaProvider</id>
5-
<version>0.1.4</version>
5+
<version>0.1.5</version>
66
<title>Analogy Log Viewer Kafka Provider</title>
77
<authors>Lior Banai</authors>
88
<owners>Lior Banai</owners>
99
<license type="expression">MIT</license>
10-
<projectUrl>https://github.com/LiorBanai/Analogy.LogViewer.KafkaProvider</projectUrl>
10+
<projectUrl>https://github.com/Analogy-LogViewer/Analogy.LogViewer.KafkaProvider</projectUrl>
11+
<repository type="git" url="https://github.com/Analogy-LogViewer/Analogy.LogViewer.KafkaProvider"/>
1112
<icon>icon.png</icon>
1213
<requireLicenseAcceptance>false</requireLicenseAcceptance>
1314
<description>Analogy Log Viewer Kafka Provider</description>
@@ -16,14 +17,15 @@
1617
<tags></tags>
1718
<dependencies>
1819
<group targetFramework="netstandard2.0">
19-
<dependency id="Analogy.LogViewer.Interfaces" version="2.1.5" />
20+
<dependency id="Analogy.LogViewer.Interfaces" version="2.1.6.1" />
2021
<dependency id="Confluent.Kafka" version="1.2.2" />
22+
<dependency id="librdkafka.redist" version="1.2.2" />
2123
</group>
2224
</dependencies>
2325
</metadata>
2426
<files>
25-
<file src="bin\Release\netstandard2.0\Analogy.Implementation.KafkaProvider.dll" target="lib\netstandard2.0\Analogy.Implementation.KafkaProvider.dll" />
26-
<file src="bin\Release\netstandard2.0\Analogy.Implementation.KafkaProvider.deps.json" target="lib\netstandard2.0\Analogy.Implementation.KafkaProvider.deps.json" />
27+
<file src="Analogy.Implementation.KafkaProvider\bin\Release\netstandard2.0\Analogy.LogViewer.KafkaProvider.dll" target="lib\netstandard2.0\Analogy.LogViewer.KafkaProvider.dll" />
28+
<file src="Analogy.Implementation.KafkaProvider\bin\Release\netstandard2.0\Analogy.LogViewer.KafkaProvider.deps.json" target="lib\netstandard2.0\Analogy.LogViewer.KafkaProvider.deps.json" />
2729
<file src="icon.png" target="" />
2830
</files>
2931
</package>

Analogy.Implementation.KafkaProvider/Analogy.Implementation.KafkaProvider.csproj renamed to Analogy.Implementation.KafkaProvider/Analogy.LogViewer.KafkaProvider.csproj

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,16 +2,18 @@
22

33
<PropertyGroup>
44
<TargetFramework>netstandard2.0</TargetFramework>
5-
<Version>0.1.4</Version>
5+
<Version>0.1.5</Version>
66
<Authors>Lior Banai</Authors>
77
<Company>Lior Banai</Company>
88
<Product>Analogy.Implementation.KafkaProvider</Product>
99
<ApplicationIcon>Analogy_logo1.ico</ApplicationIcon>
10+
<PackageId>Analogy.LogViewer.KafkaProvider</PackageId>
1011
</PropertyGroup>
1112

1213
<ItemGroup>
13-
<PackageReference Include="Analogy.LogViewer.Interfaces" Version="2.1.5.1" />
14+
<PackageReference Include="Analogy.LogViewer.Interfaces" Version="2.1.6.1" />
1415
<PackageReference Include="Confluent.Kafka" Version="1.2.2" />
16+
<PackageReference Include="librdkafka.redist" Version="1.2.2" />
1517
</ItemGroup>
1618

1719
</Project>
Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
<?xml version="1.0" encoding="utf-8"?>
2+
<Project ToolsVersion="Current" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
3+
<PropertyGroup>
4+
<_LastSelectedProfileId>E:\files\Programming\Analogy.LogViewer.KafkaProvider\Analogy.Implementation.KafkaProvider\Properties\PublishProfiles\FolderProfile1.pubxml</_LastSelectedProfileId>
5+
</PropertyGroup>
6+
</Project>

Analogy.Implementation.KafkaProvider/AnalogyKafkaDataProvider.cs

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,15 +35,19 @@ public void StopReceiving()
3535
Consumer.StopConsuming();
3636
}
3737

38-
public void InitDataProvider()
38+
39+
public Task InitializeDataProviderAsync()
3940
{
40-
4141
Consumer = new KafkaConsumer<AnalogyLogMessage>(groupId, kafkaUrl, topic);
4242
Consumer.OnMessageReady += Consumer_OnMessageReady;
4343
IsConnected = true;
44-
44+
return Task.CompletedTask;
4545
}
4646

47+
public void MessageOpened(AnalogyLogMessage message)
48+
{
49+
//nop
50+
}
4751
private void Consumer_OnMessageReady(object sender, KafkaMessageArgs<AnalogyLogMessage> e)
4852
{
4953
OnMessageReady?.Invoke(sender, new AnalogyLogMessageArgs(e.Message, Environment.MachineName, Environment.MachineName, ID));
-257 KB
Binary file not shown.

Analogy.LogViewer.KafkaProvider.sln

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,11 +2,11 @@ Microsoft Visual Studio Solution File, Format Version 12.00
22
# Visual Studio Version 16
33
VisualStudioVersion = 16.0.29411.108
44
MinimumVisualStudioVersion = 10.0.40219.1
5-
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Analogy.Implementation.KafkaProvider", "Analogy.Implementation.KafkaProvider\Analogy.Implementation.KafkaProvider.csproj", "{512D664A-7F6F-412C-B47C-78C4F6D7BDAA}"
5+
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Analogy.LogViewer.KafkaProvider", "Analogy.Implementation.KafkaProvider\Analogy.LogViewer.KafkaProvider.csproj", "{512D664A-7F6F-412C-B47C-78C4F6D7BDAA}"
66
EndProject
7-
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Analogy.Implementation.KafkaProvider.UnitTests", "Analogy.Implementation.KafkaProvider.UnitTests\Analogy.Implementation.KafkaProvider.UnitTests.csproj", "{6A9A54EE-2F10-4EC6-8340-E923AD027137}"
7+
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Analogy.LogViewer.KafkaProvider.UnitTests", "Analogy.Implementation.KafkaProvider.UnitTests\Analogy.LogViewer.KafkaProvider.UnitTests.csproj", "{6A9A54EE-2F10-4EC6-8340-E923AD027137}"
88
EndProject
9-
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Analogy.Implementation.KafkaProvider.Example", "Analogy.Implementation.KafkaProvider.Example\Analogy.Implementation.KafkaProvider.Example.csproj", "{AEB13663-8261-46DB-923F-A9C51B05D7E9}"
9+
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Analogy.LogViewer.KafkaProvider.Example", "Analogy.Implementation.KafkaProvider.Example\Analogy.LogViewer.KafkaProvider.Example.csproj", "{AEB13663-8261-46DB-923F-A9C51B05D7E9}"
1010
ProjectSection(ProjectDependencies) = postProject
1111
{512D664A-7F6F-412C-B47C-78C4F6D7BDAA} = {512D664A-7F6F-412C-B47C-78C4F6D7BDAA}
1212
EndProjectSection

0 commit comments

Comments
 (0)