Skip to content

M
Message-Priority-Queue
Commit 5a9c3975 authored by mohammad.salama's avatar mohammad.salama
Browse files
Options

removed un-necessary projects and methods + edited success reply code

parent a55e48b0
Expand all Show whitespace changes
Inline Side-by-side
Showing with 173 additions and 16899 deletions
CoordinatorOne/CoordinatorOne.csproj deleted 100644 → 0
View file @ a55e48b0
<Project Sdk="Microsoft.NET.Sdk.Worker">
<PropertyGroup>
<TargetFramework>net6.0</TargetFramework>
<Nullable>enable</Nullable>
<ImplicitUsings>enable</ImplicitUsings>
<UserSecretsId>dotnet-CoordinatorOne-143D7A72-DD87-485F-A5C3-B888E6FAE76D</UserSecretsId>
</PropertyGroup>
<ItemGroup>
<None Remove="Protos\schema.proto" />
</ItemGroup>
<ItemGroup>
<PackageReference Include="Microsoft.Extensions.Hosting" Version="6.0.0" />
</ItemGroup>
<ItemGroup>
<PackageReference Include="Grpc.AspNetCore" Version="2.40.0" />
</ItemGroup>
<ItemGroup>
<PackageReference Include="Google.Protobuf" Version="3.27.1" />
<PackageReference Include="Grpc.Net.Client" Version="2.63.0" />
<PackageReference Include="Grpc.Tools" Version="2.64.0">
<PrivateAssets>all</PrivateAssets>
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
</PackageReference>
</ItemGroup>
<PropertyGroup>
<SteeltoeVersion>3.2.6</SteeltoeVersion>
</PropertyGroup>
<ItemGroup>
<PackageReference Include="Swashbuckle.AspNetCore" Version="6.4.*" />
</ItemGroup>
<ItemGroup>
<PackageReference Include="Steeltoe.Connector.ConnectorCore" Version="$(SteeltoeVersion)" />
<PackageReference Include="Steeltoe.Discovery.Eureka" Version="$(SteeltoeVersion)" />
</ItemGroup>
<ItemGroup>
<Protobuf Include="Protos\schema.proto" GrpcServices="Server" />
</ItemGroup>
</Project>
CoordinatorOne/Helper/MessageQueues.cs deleted 100644 → 0
View file @ a55e48b0
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace CoordinatorOne.Helper
{
public static class MessageQueues
{
private const int priority_levels = 6;
private const int sms_rates = 15;
private static Queue<Message>[] messageQueue = new Queue<Message>[priority_levels];
public static void addMessage(Message message)
{
int idx = message.LocalPriority;
idx = Math.Min(idx, priority_levels - 1);
idx = Math.Max(idx, 0);
messageQueue[idx].Enqueue(message);
Console.WriteLine("Message Queud: " + message.MsgId);
}
public static void sendMessages()
{
int x1 = 7, x2 = 5, x3 = 3;
while(x1>0 && messageQueue[1].Count>0)
{
Console.WriteLine(messageQueue[1].Dequeue());
x1--;
}
while (x2 > 0 && messageQueue[1].Count > 0)
{
Console.WriteLine(messageQueue[2].Dequeue());
x2--;
}
while (x3 > 0 && messageQueue[3].Count > 0)
{
Console.WriteLine(messageQueue[3].Dequeue());
x3--;
}
}
}
}
CoordinatorOne/Program.cs deleted 100644 → 0
View file @ a55e48b0
using CoordinatorOne;
using Steeltoe.Discovery.Client;
/*public class Program
{
public static async void main(String[] args)
{
IHost host = Host.CreateDefaultBuilder(args)
.ConfigureServices(services =>
{
services.AddHostedService<Worker>();
services.AddDiscoveryClient();
})
.Build();
await host.RunAsync();
}
}
*/
IHost host = Host.CreateDefaultBuilder(args)
.ConfigureServices(services =>
{
services.AddHostedService<Worker>();
services.AddDiscoveryClient();
services.AddGrpc();
})
.Build();
// i need to MapGrpcService<QMSGSERvice>();
host.Run();
\ No newline at end of file
CoordinatorOne/Properties/launchSettings.json deleted 100644 → 0
View file @ a55e48b0
{
"profiles": {
"CoordinatorOne": {
"commandName": "Project",
"dotnetRunMessages": true,
"applicationUrl": "http://localhost:5259;https://localhost:9090",
"environmentVariables": {
"DOTNET_ENVIRONMENT": "Development"
}
}
}
}
CoordinatorOne/Protos/schema.proto deleted 100644 → 0
View file @ a55e48b0
syntax = "proto3";
option csharp_namespace = "CoordinatorOne";
package Tranmitter;
message Message {
string clientID = 1;
string apiKey = 2;
string msgId = 3;
string phoneNumber = 4;
int32 localPriority = 5;
string text = 6;
}
message Acknowledgement
{
string replyCode = 1;
}
service Queue {
rpc QueueMessage(Message) returns (Acknowledgement);
}
CoordinatorOne/Services/QueueMessageService.cs deleted 100644 → 0
View file @ a55e48b0

using Grpc.Core;
using Steeltoe.Common.Discovery;
using Steeltoe.Discovery;
using CoordinatorOne.Helper;
namespace CoordinatorOne.Services
{
public class QueueMessageService : Queue.QueueBase
{
private readonly ILogger<QueueMessageService> _logger;
private readonly IDiscoveryClient _client;
public QueueMessageService(ILogger<QueueMessageService> logger , IDiscoveryClient client)
{
_logger = logger;
_client = client;
}
public override Task<Acknowledgement> QueueMessage(Message message, ServerCallContext context)
{
MessageQueues.addMessage(message);
return Task.FromResult(new Acknowledgement
{
ReplyCode = "OK on Send " + message.MsgId + ";;"+ message.LocalPriority
});
}
}
}
CoordinatorOne/Worker.cs deleted 100644 → 0
View file @ a55e48b0
using Steeltoe.Discovery;
namespace CoordinatorOne
{
public class Worker : BackgroundService
{
private readonly ILogger<Worker> _logger;
private readonly IDiscoveryClient discoveryClient;
public Worker(ILogger<Worker> logger , IDiscoveryClient client)
{
_logger = logger;
discoveryClient = client;
}
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
/*wile (!stoppingToken.IsCancellationRequested)
{
var x = discoveryClient.Services;
Console.WriteLine(x);
var y = discoveryClient.GetInstances("grpcmessagenode");
var yy = discoveryClient.GetInstances("grpcmessagenod444e");
//_logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now);
await Task.Delay(1000, stoppingToken);
}*/
}
}
}
\ No newline at end of file
CoordinatorOne/appsettings.Development.json deleted 100644 → 0
View file @ a55e48b0
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.Hosting.Lifetime": "Information"
}
}
}
CoordinatorOne/appsettings.json deleted 100644 → 0
View file @ a55e48b0
{
"spring": {
"application": {
"name": "Coordinator"
}
},
"Logging": {
"LogLevel": {
"Default": "Error",
"Microsoft.Hosting.Lifetime": "Error"
}
},
"applicationUrl": "http://localhost:5259;https://localhost:9090",
"eureka": {
"client": {
"serviceUrl": "http://localhost:8761/eureka/",
"shouldFetchRegistry": "true",
"shouldRegisterWithEureka": true,
"validateCertificates": false
}
},
"instance": {},
"AllowedHosts": "*",
"Kestrel": {
"EndpointDefaults": {
"Protocols": "Http2"
}
}
}
\ No newline at end of file
CoordinatorOne/bin/Debug/net6.0/CoordinatorOne.runtimeconfig.json deleted 100644 → 0
View file @ a55e48b0
{
"runtimeOptions": {
"tfm": "net6.0",
"frameworks": [
{
"name": "Microsoft.NETCore.App",
"version": "6.0.0"
},
{
"name": "Microsoft.AspNetCore.App",
"version": "6.0.0"
}
]
}
}
\ No newline at end of file
CoordinatorOne/bin/Debug/net6.0/appsettings.Development.json deleted 100644 → 0
View file @ a55e48b0
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.Hosting.Lifetime": "Information"
}
}
}
CoordinatorOne/bin/Debug/net6.0/appsettings.json deleted 100644 → 0
View file @ a55e48b0
{
"spring": {
"application": {
"name": "Coordinator"
}
},
"Logging": {
"LogLevel": {
"Default": "Error",
"Microsoft.Hosting.Lifetime": "Error"
}
},
"applicationUrl": "http://localhost:5259;https://localhost:9090",
"eureka": {
"client": {
"serviceUrl": "http://localhost:8761/eureka/",
"shouldFetchRegistry": "true",
"shouldRegisterWithEureka": true,
"validateCertificates": false
}
},
"instance": {},
"AllowedHosts": "*",
"Kestrel": {
"EndpointDefaults": {
"Protocols": "Http2"
}
}
}
\ No newline at end of file
CoordinatorOne/obj/CoordinatorOne.csproj.nuget.dgspec.json deleted 100644 → 0
View file @ a55e48b0
{
"format": 1,
"restore": {
"D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\CoordinatorOne\\CoordinatorOne.csproj": {}
},
"projects": {
"D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\CoordinatorOne\\CoordinatorOne.csproj": {
"version": "1.0.0",
"restore": {
"projectUniqueName": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\CoordinatorOne\\CoordinatorOne.csproj",
"projectName": "CoordinatorOne",
"projectPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\CoordinatorOne\\CoordinatorOne.csproj",
"packagesPath": "C:\\Users\\moham\\.nuget\\packages\\",
"outputPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\CoordinatorOne\\obj\\",
"projectStyle": "PackageReference",
"fallbackFolders": [
"C:\\Program Files (x86)\\Microsoft Visual Studio\\Shared\\NuGetPackages"
],
"configFilePaths": [
"C:\\Users\\moham\\AppData\\Roaming\\NuGet\\NuGet.Config",
"C:\\Program Files (x86)\\NuGet\\Config\\Microsoft.VisualStudio.FallbackLocation.config",
"C:\\Program Files (x86)\\NuGet\\Config\\Microsoft.VisualStudio.Offline.config"
],
"originalTargetFrameworks": [
"net6.0"
],
"sources": {
"C:\\Program Files (x86)\\Microsoft SDKs\\NuGetPackages\\": {},
"https://api.nuget.org/v3/index.json": {}
},
"frameworks": {
"net6.0": {
"targetAlias": "net6.0",
"projectReferences": {}
}
},
"warningProperties": {
"warnAsError": [
"NU1605"
]
}
},
"frameworks": {
"net6.0": {
"targetAlias": "net6.0",
"dependencies": {
"Google.Protobuf": {
"target": "Package",
"version": "[3.27.1, )"
},
"Grpc.AspNetCore": {
"target": "Package",
"version": "[2.40.0, )"
},
"Grpc.Net.Client": {
"target": "Package",
"version": "[2.63.0, )"
},
"Grpc.Tools": {
"include": "Runtime, Build, Native, ContentFiles, Analyzers, BuildTransitive",
"suppressParent": "All",
"target": "Package",
"version": "[2.64.0, )"
},
"Microsoft.Extensions.Hosting": {
"target": "Package",
"version": "[6.0.0, )"
},
"Steeltoe.Connector.ConnectorCore": {
"target": "Package",
"version": "[3.2.6, )"
},
"Steeltoe.Discovery.Eureka": {
"target": "Package",
"version": "[3.2.6, )"
},
"Swashbuckle.AspNetCore": {
"target": "Package",
"version": "[6.4.*, )"
}
},
"imports": [
"net461",
"net462",
"net47",
"net471",
"net472",
"net48"
],
"assetTargetFallback": true,
"warn": true,
"frameworkReferences": {
"Microsoft.NETCore.App": {
"privateAssets": "all"
}
},
"runtimeIdentifierGraphPath": "C:\\Program Files\\dotnet\\sdk\\6.0.100\\RuntimeIdentifierGraph.json"
}
}
}
}
}
\ No newline at end of file
CoordinatorOne/obj/CoordinatorOne.csproj.nuget.g.props deleted 100644 → 0
View file @ a55e48b0
<?xml version="1.0" encoding="utf-8" standalone="no"?>
<Project ToolsVersion="14.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
<PropertyGroup Condition=" '$(ExcludeRestorePackageImports)' != 'true' ">
<RestoreSuccess Condition=" '$(RestoreSuccess)' == '' ">True</RestoreSuccess>
<RestoreTool Condition=" '$(RestoreTool)' == '' ">NuGet</RestoreTool>
<ProjectAssetsFile Condition=" '$(ProjectAssetsFile)' == '' ">$(MSBuildThisFileDirectory)project.assets.json</ProjectAssetsFile>
<NuGetPackageRoot Condition=" '$(NuGetPackageRoot)' == '' ">$(UserProfile)\.nuget\packages\</NuGetPackageRoot>
<NuGetPackageFolders Condition=" '$(NuGetPackageFolders)' == '' ">C:\Users\moham\.nuget\packages\;C:\Program Files (x86)\Microsoft Visual Studio\Shared\NuGetPackages</NuGetPackageFolders>
<NuGetProjectStyle Condition=" '$(NuGetProjectStyle)' == '' ">PackageReference</NuGetProjectStyle>
<NuGetToolVersion Condition=" '$(NuGetToolVersion)' == '' ">6.0.0</NuGetToolVersion>
</PropertyGroup>
<ItemGroup Condition=" '$(ExcludeRestorePackageImports)' != 'true' ">
<SourceRoot Include="C:\Users\moham\.nuget\packages\" />
<SourceRoot Include="C:\Program Files (x86)\Microsoft Visual Studio\Shared\NuGetPackages\" />
</ItemGroup>
<ImportGroup Condition=" '$(ExcludeRestorePackageImports)' != 'true' ">
<Import Project="$(NuGetPackageRoot)microsoft.extensions.apidescription.server\6.0.5\build\Microsoft.Extensions.ApiDescription.Server.props" Condition="Exists('$(NuGetPackageRoot)microsoft.extensions.apidescription.server\6.0.5\build\Microsoft.Extensions.ApiDescription.Server.props')" />
<Import Project="$(NuGetPackageRoot)swashbuckle.aspnetcore\6.4.0\build\Swashbuckle.AspNetCore.props" Condition="Exists('$(NuGetPackageRoot)swashbuckle.aspnetcore\6.4.0\build\Swashbuckle.AspNetCore.props')" />
<Import Project="$(NuGetPackageRoot)grpc.tools\2.64.0\build\Grpc.Tools.props" Condition="Exists('$(NuGetPackageRoot)grpc.tools\2.64.0\build\Grpc.Tools.props')" />
</ImportGroup>
<PropertyGroup Condition=" '$(ExcludeRestorePackageImports)' != 'true' ">
<PkgMicrosoft_Extensions_ApiDescription_Server Condition=" '$(PkgMicrosoft_Extensions_ApiDescription_Server)' == '' ">C:\Users\moham\.nuget\packages\microsoft.extensions.apidescription.server\6.0.5</PkgMicrosoft_Extensions_ApiDescription_Server>
<PkgGrpc_Tools Condition=" '$(PkgGrpc_Tools)' == '' ">C:\Users\moham\.nuget\packages\grpc.tools\2.64.0</PkgGrpc_Tools>
</PropertyGroup>
</Project>
\ No newline at end of file
CoordinatorOne/obj/CoordinatorOne.csproj.nuget.g.targets deleted 100644 → 0
View file @ a55e48b0
<?xml version="1.0" encoding="utf-8" standalone="no"?>
<Project ToolsVersion="14.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
<ImportGroup Condition=" '$(ExcludeRestorePackageImports)' != 'true' ">
<Import Project="$(NuGetPackageRoot)microsoft.extensions.apidescription.server\6.0.5\build\Microsoft.Extensions.ApiDescription.Server.targets" Condition="Exists('$(NuGetPackageRoot)microsoft.extensions.apidescription.server\6.0.5\build\Microsoft.Extensions.ApiDescription.Server.targets')" />
<Import Project="$(NuGetPackageRoot)grpc.tools\2.64.0\build\Grpc.Tools.targets" Condition="Exists('$(NuGetPackageRoot)grpc.tools\2.64.0\build\Grpc.Tools.targets')" />
</ImportGroup>
</Project>
\ No newline at end of file
CoordinatorOne/obj/Debug/net6.0/.NETCoreApp,Version=v6.0.AssemblyAttributes.cs deleted 100644 → 0
View file @ a55e48b0
// <autogenerated />
using System;
using System.Reflection;
[assembly: global::System.Runtime.Versioning.TargetFrameworkAttribute(".NETCoreApp,Version=v6.0", FrameworkDisplayName = "")]
CoordinatorOne/obj/Debug/net6.0/12fbc7ffe642ca7e_schema.protodep deleted 100644 → 0
View file @ a55e48b0
obj\Debug\net6.0\Protos/Schema.cs \
obj\Debug\net6.0\Protos/SchemaGrpc.cs: Protos/schema.proto
\ No newline at end of file
CoordinatorOne/obj/Debug/net6.0/CoordinatorOne.AssemblyInfo.cs deleted 100644 → 0
View file @ a55e48b0
//------------------------------------------------------------------------------
// <auto-generated>
// This code was generated by a tool.
// Runtime Version:4.0.30319.42000
//
// Changes to this file may cause incorrect behavior and will be lost if
// the code is regenerated.
// </auto-generated>
//------------------------------------------------------------------------------
using System;
using System.Reflection;
[assembly: Microsoft.Extensions.Configuration.UserSecrets.UserSecretsIdAttribute("dotnet-CoordinatorOne-143D7A72-DD87-485F-A5C3-B888E6FAE76D")]
[assembly: System.Reflection.AssemblyCompanyAttribute("CoordinatorOne")]
[assembly: System.Reflection.AssemblyConfigurationAttribute("Debug")]
[assembly: System.Reflection.AssemblyFileVersionAttribute("1.0.0.0")]
[assembly: System.Reflection.AssemblyInformationalVersionAttribute("1.0.0")]
[assembly: System.Reflection.AssemblyProductAttribute("CoordinatorOne")]
[assembly: System.Reflection.AssemblyTitleAttribute("CoordinatorOne")]
[assembly: System.Reflection.AssemblyVersionAttribute("1.0.0.0")]
// Generated by the MSBuild WriteCodeFragment class.
CoordinatorOne/obj/Debug/net6.0/CoordinatorOne.GeneratedMSBuildEditorConfig.editorconfig deleted 100644 → 0
View file @ a55e48b0
is_global = true
build_property.TargetFramework = net6.0
build_property.TargetPlatformMinVersion =
build_property.UsingMicrosoftNETSdkWeb =
build_property.ProjectTypeGuids =
build_property.InvariantGlobalization =
build_property.PlatformNeutralAssembly =
build_property._SupportedPlatformList = Linux,macOS,Windows
build_property.RootNamespace = CoordinatorOne
build_property.ProjectDir = D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\
CoordinatorOne/obj/Debug/net6.0/CoordinatorOne.GlobalUsings.g.cs deleted 100644 → 0
View file @ a55e48b0
// <auto-generated/>
global using global::Microsoft.Extensions.Configuration;
global using global::Microsoft.Extensions.DependencyInjection;
global using global::Microsoft.Extensions.Hosting;
global using global::Microsoft.Extensions.Logging;
global using global::System;
global using global::System.Collections.Generic;
global using global::System.IO;
global using global::System.Linq;
global using global::System.Net.Http;
global using global::System.Threading;
global using global::System.Threading.Tasks;
CoordinatorOne/obj/Debug/net6.0/CoordinatorOne.csproj.FileListAbsolute.txt deleted 100644 → 0
View file @ a55e48b0
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\obj\Debug\net6.0\CoordinatorOne.csproj.AssemblyReference.cache
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\obj\Debug\net6.0\CoordinatorOne.GeneratedMSBuildEditorConfig.editorconfig
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\obj\Debug\net6.0\CoordinatorOne.AssemblyInfoInputs.cache
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\obj\Debug\net6.0\CoordinatorOne.AssemblyInfo.cs
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\obj\Debug\net6.0\CoordinatorOne.csproj.CoreCompileInputs.cache
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\appsettings.Development.json
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\appsettings.json
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\CoordinatorOne.exe
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\CoordinatorOne.deps.json
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\CoordinatorOne.runtimeconfig.json
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\CoordinatorOne.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\ref\CoordinatorOne.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\CoordinatorOne.pdb
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Google.Protobuf.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Grpc.AspNetCore.Server.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Grpc.AspNetCore.Server.ClientFactory.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Grpc.Core.Api.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Grpc.Net.Client.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Grpc.Net.ClientFactory.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Grpc.Net.Common.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Microsoft.OpenApi.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Steeltoe.Common.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Steeltoe.Common.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Steeltoe.Common.Http.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Steeltoe.Connector.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Steeltoe.Connector.ConnectorBase.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Steeltoe.Connector.ConnectorCore.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Steeltoe.Discovery.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Steeltoe.Discovery.ClientBase.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Steeltoe.Discovery.Eureka.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Steeltoe.Extensions.Configuration.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Swashbuckle.AspNetCore.Swagger.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Swashbuckle.AspNetCore.SwaggerGen.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\Swashbuckle.AspNetCore.SwaggerUI.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\bin\Debug\net6.0\System.Reflection.MetadataLoadContext.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\obj\Debug\net6.0\CoordinatorOne.csproj.CopyComplete
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\obj\Debug\net6.0\CoordinatorOne.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\obj\Debug\net6.0\ref\CoordinatorOne.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\obj\Debug\net6.0\CoordinatorOne.pdb
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\CoordinatorOne\obj\Debug\net6.0\CoordinatorOne.genruntimeconfig.cache
CoordinatorOne/obj/Debug/net6.0/Protos/Schema.cs deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
CoordinatorOne/obj/Debug/net6.0/Protos/SchemaGrpc.cs deleted 100644 → 0
View file @ a55e48b0
// <auto-generated>
// Generated by the protocol buffer compiler. DO NOT EDIT!
// source: Protos/schema.proto
// </auto-generated>
#pragma warning disable 0414, 1591, 8981, 0612
#region Designer generated code
using grpc = global::Grpc.Core;
namespace CoordinatorOne {
public static partial class Queue
{
static readonly string __ServiceName = "Tranmitter.Queue";
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
static void __Helper_SerializeMessage(global::Google.Protobuf.IMessage message, grpc::SerializationContext context)
{
#if !GRPC_DISABLE_PROTOBUF_BUFFER_SERIALIZATION
if (message is global::Google.Protobuf.IBufferMessage)
{
context.SetPayloadLength(message.CalculateSize());
global::Google.Protobuf.MessageExtensions.WriteTo(message, context.GetBufferWriter());
context.Complete();
return;
}
#endif
context.Complete(global::Google.Protobuf.MessageExtensions.ToByteArray(message));
}
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
static class __Helper_MessageCache<T>
{
public static readonly bool IsBufferMessage = global::System.Reflection.IntrospectionExtensions.GetTypeInfo(typeof(global::Google.Protobuf.IBufferMessage)).IsAssignableFrom(typeof(T));
}
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
static T __Helper_DeserializeMessage<T>(grpc::DeserializationContext context, global::Google.Protobuf.MessageParser<T> parser) where T : global::Google.Protobuf.IMessage<T>
{
#if !GRPC_DISABLE_PROTOBUF_BUFFER_SERIALIZATION
if (__Helper_MessageCache<T>.IsBufferMessage)
{
return parser.ParseFrom(context.PayloadAsReadOnlySequence());
}
#endif
return parser.ParseFrom(context.PayloadAsNewBuffer());
}
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
static readonly grpc::Marshaller<global::CoordinatorOne.Message> __Marshaller_Tranmitter_Message = grpc::Marshallers.Create(__Helper_SerializeMessage, context => __Helper_DeserializeMessage(context, global::CoordinatorOne.Message.Parser));
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
static readonly grpc::Marshaller<global::CoordinatorOne.Acknowledgement> __Marshaller_Tranmitter_Acknowledgement = grpc::Marshallers.Create(__Helper_SerializeMessage, context => __Helper_DeserializeMessage(context, global::CoordinatorOne.Acknowledgement.Parser));
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
static readonly grpc::Method<global::CoordinatorOne.Message, global::CoordinatorOne.Acknowledgement> __Method_QueueMessage = new grpc::Method<global::CoordinatorOne.Message, global::CoordinatorOne.Acknowledgement>(
grpc::MethodType.Unary,
__ServiceName,
"QueueMessage",
__Marshaller_Tranmitter_Message,
__Marshaller_Tranmitter_Acknowledgement);
/// <summary>Service descriptor</summary>
public static global::Google.Protobuf.Reflection.ServiceDescriptor Descriptor
{
get { return global::CoordinatorOne.SchemaReflection.Descriptor.Services[0]; }
}
/// <summary>Base class for server-side implementations of Queue</summary>
[grpc::BindServiceMethod(typeof(Queue), "BindService")]
public abstract partial class QueueBase
{
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
public virtual global::System.Threading.Tasks.Task<global::CoordinatorOne.Acknowledgement> QueueMessage(global::CoordinatorOne.Message request, grpc::ServerCallContext context)
{
throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, ""));
}
}
/// <summary>Creates service definition that can be registered with a server</summary>
/// <param name="serviceImpl">An object implementing the server-side handling logic.</param>
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
public static grpc::ServerServiceDefinition BindService(QueueBase serviceImpl)
{
return grpc::ServerServiceDefinition.CreateBuilder()
.AddMethod(__Method_QueueMessage, serviceImpl.QueueMessage).Build();
}
/// <summary>Register service method with a service binder with or without implementation. Useful when customizing the service binding logic.
/// Note: this method is part of an experimental API that can change or be removed without any prior notice.</summary>
/// <param name="serviceBinder">Service methods will be bound by calling <c>AddMethod</c> on this object.</param>
/// <param name="serviceImpl">An object implementing the server-side handling logic.</param>
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
public static void BindService(grpc::ServiceBinderBase serviceBinder, QueueBase serviceImpl)
{
serviceBinder.AddMethod(__Method_QueueMessage, serviceImpl == null ? null : new grpc::UnaryServerMethod<global::CoordinatorOne.Message, global::CoordinatorOne.Acknowledgement>(serviceImpl.QueueMessage));
}
}
}
#endregion
CoordinatorOne/obj/project.assets.json deleted 100644 → 0
View file @ a55e48b0
This source diff could not be displayed because it is too large. You can view the blob instead.
CoordinatorOne/obj/project.nuget.cache deleted 100644 → 0
View file @ a55e48b0
{
"version": 2,
"dgSpecHash": "jqmws6IiNzxDbmjs0xZsdz+xiBh08TuB5QO5F4UDXwVj2gLVkVZ+MGq9t+Xdnev1Hgfmg/khpDzuLXj4KnyPgQ==",
"success": true,
"projectFilePath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\CoordinatorOne\\CoordinatorOne.csproj",
"expectedPackageFiles": [
"C:\\Users\\moham\\.nuget\\packages\\google.protobuf\\3.27.1\\google.protobuf.3.27.1.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\grpc.aspnetcore\\2.40.0\\grpc.aspnetcore.2.40.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\grpc.aspnetcore.server\\2.40.0\\grpc.aspnetcore.server.2.40.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\grpc.aspnetcore.server.clientfactory\\2.40.0\\grpc.aspnetcore.server.clientfactory.2.40.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\grpc.core.api\\2.63.0\\grpc.core.api.2.63.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\grpc.net.client\\2.63.0\\grpc.net.client.2.63.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\grpc.net.clientfactory\\2.40.0\\grpc.net.clientfactory.2.40.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\grpc.net.common\\2.63.0\\grpc.net.common.2.63.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\grpc.tools\\2.64.0\\grpc.tools.2.64.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.apidescription.server\\6.0.5\\microsoft.extensions.apidescription.server.6.0.5.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.caching.abstractions\\3.1.0\\microsoft.extensions.caching.abstractions.3.1.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.configuration\\6.0.0\\microsoft.extensions.configuration.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.configuration.abstractions\\6.0.0\\microsoft.extensions.configuration.abstractions.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.configuration.binder\\6.0.0\\microsoft.extensions.configuration.binder.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.configuration.commandline\\6.0.0\\microsoft.extensions.configuration.commandline.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.configuration.environmentvariables\\6.0.0\\microsoft.extensions.configuration.environmentvariables.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.configuration.fileextensions\\6.0.0\\microsoft.extensions.configuration.fileextensions.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.configuration.json\\6.0.0\\microsoft.extensions.configuration.json.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.configuration.usersecrets\\6.0.0\\microsoft.extensions.configuration.usersecrets.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.dependencyinjection\\6.0.0\\microsoft.extensions.dependencyinjection.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.dependencyinjection.abstractions\\6.0.0\\microsoft.extensions.dependencyinjection.abstractions.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.diagnostics.healthchecks\\2.2.5\\microsoft.extensions.diagnostics.healthchecks.2.2.5.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.diagnostics.healthchecks.abstractions\\2.2.0\\microsoft.extensions.diagnostics.healthchecks.abstractions.2.2.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.fileproviders.abstractions\\6.0.0\\microsoft.extensions.fileproviders.abstractions.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.fileproviders.physical\\6.0.0\\microsoft.extensions.fileproviders.physical.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.filesystemglobbing\\6.0.0\\microsoft.extensions.filesystemglobbing.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.hosting\\6.0.0\\microsoft.extensions.hosting.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.hosting.abstractions\\6.0.0\\microsoft.extensions.hosting.abstractions.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.http\\3.1.0\\microsoft.extensions.http.3.1.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.logging\\6.0.0\\microsoft.extensions.logging.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.logging.abstractions\\6.0.0\\microsoft.extensions.logging.abstractions.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.logging.configuration\\6.0.0\\microsoft.extensions.logging.configuration.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.logging.console\\6.0.0\\microsoft.extensions.logging.console.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.logging.debug\\6.0.0\\microsoft.extensions.logging.debug.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.logging.eventlog\\6.0.0\\microsoft.extensions.logging.eventlog.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.logging.eventsource\\6.0.0\\microsoft.extensions.logging.eventsource.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.options\\6.0.0\\microsoft.extensions.options.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.options.configurationextensions\\6.0.0\\microsoft.extensions.options.configurationextensions.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.extensions.primitives\\6.0.0\\microsoft.extensions.primitives.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\microsoft.openapi\\1.2.3\\microsoft.openapi.1.2.3.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\steeltoe.common\\3.2.6\\steeltoe.common.3.2.6.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\steeltoe.common.abstractions\\3.2.6\\steeltoe.common.abstractions.3.2.6.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\steeltoe.common.http\\3.2.6\\steeltoe.common.http.3.2.6.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\steeltoe.connector.abstractions\\3.2.6\\steeltoe.connector.abstractions.3.2.6.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\steeltoe.connector.connectorbase\\3.2.6\\steeltoe.connector.connectorbase.3.2.6.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\steeltoe.connector.connectorcore\\3.2.6\\steeltoe.connector.connectorcore.3.2.6.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\steeltoe.discovery.abstractions\\3.2.6\\steeltoe.discovery.abstractions.3.2.6.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\steeltoe.discovery.clientbase\\3.2.6\\steeltoe.discovery.clientbase.3.2.6.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\steeltoe.discovery.eureka\\3.2.6\\steeltoe.discovery.eureka.3.2.6.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\steeltoe.extensions.configuration.abstractions\\3.2.6\\steeltoe.extensions.configuration.abstractions.3.2.6.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\swashbuckle.aspnetcore\\6.4.0\\swashbuckle.aspnetcore.6.4.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\swashbuckle.aspnetcore.swagger\\6.4.0\\swashbuckle.aspnetcore.swagger.6.4.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\swashbuckle.aspnetcore.swaggergen\\6.4.0\\swashbuckle.aspnetcore.swaggergen.6.4.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\swashbuckle.aspnetcore.swaggerui\\6.4.0\\swashbuckle.aspnetcore.swaggerui.6.4.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\system.diagnostics.diagnosticsource\\6.0.0\\system.diagnostics.diagnosticsource.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\system.diagnostics.eventlog\\6.0.0\\system.diagnostics.eventlog.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\system.net.http.json\\3.2.1\\system.net.http.json.3.2.1.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\system.reflection.metadataloadcontext\\4.6.0\\system.reflection.metadataloadcontext.4.6.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\system.runtime.compilerservices.unsafe\\6.0.0\\system.runtime.compilerservices.unsafe.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\system.text.encodings.web\\6.0.0\\system.text.encodings.web.6.0.0.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\system.text.json\\6.0.0\\system.text.json.6.0.0.nupkg.sha512"
],
"logs": []
}
\ No newline at end of file
GrpcMessage/Services/SendMessageService.cs
View file @ 5a9c3975
......@@ -18,7 +18,6 @@ namespace GrpcMessageNode.Services
public override Task<Acknowledgement> SendMessage(Message message, ServerCallContext context)
{
Console.WriteLine("Got to Receiver Node");
bool res = PriorityHandling.SetPriority.setFinalPriority(message);
......@@ -29,8 +28,8 @@ namespace GrpcMessageNode.Services
ReplyCode = "ERRORROROR on Send " + message.MsgId
});
}
Console.WriteLine("WE ARE AFTER THE CHECKING OF RES");
//Console.WriteLine("Account Checker Passed ");
string reply = sendToCoordinator(message);
return Task.FromResult(new Acknowledgement
......@@ -46,13 +45,11 @@ namespace GrpcMessageNode.Services
using var channel = GrpcChannel.ForAddress(address);
Console.WriteLine("QueuerNode Address = " + address);
var queue_client = new Queue.QueueClient(channel);
var reply = queue_client.QueueMessage(message2);
Console.WriteLine(reply.ReplyCode);
// Console.WriteLine(reply.ReplyCode);
return reply.ReplyCode;
}
......@@ -62,7 +59,7 @@ namespace GrpcMessageNode.Services
{
string address = getCoordinatorAddress();
using var channel = GrpcChannel.ForAddress(address);
Console.WriteLine("QueuerNode Address = " + address);
//Console.WriteLine("QueuerNode Address = " + address);
var client = new Queue.QueueClient(channel);
return client;
}
......
GrpcMessage/obj/Debug/net6.0/GrpcMessageNode.GeneratedMSBuildEditorConfig.editorconfig
View file @ 5a9c3975
......@@ -8,9 +8,9 @@ build_property.PlatformNeutralAssembly =
build_property._SupportedPlatformList = Linux,macOS,Windows
build_property.RootNamespace = GrpcMessageNode
build_property.RootNamespace = GrpcMessageNode
build_property.ProjectDir = D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\GrpcMessage\
build_property.ProjectDir = D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\
build_property.RazorLangVersion = 6.0
build_property.SupportLocalizedComponentNames =
build_property.GenerateRazorMetadataSourceChecksumAttributes =
build_property.MSBuildProjectDirectory = D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\GrpcMessage
build_property.MSBuildProjectDirectory = D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage
build_property._RazorSourceGeneratorDebug =
GrpcMessage/obj/Debug/net6.0/GrpcMessageNode.csproj.FileListAbsolute.txt
View file @ 5a9c3975
......@@ -43,3 +43,48 @@ D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\GrpcMessage\obj\Debug\net6.0\GrpcM
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\GrpcMessage\obj\Debug\net6.0\ref\GrpcMessageNode.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\GrpcMessage\obj\Debug\net6.0\GrpcMessageNode.pdb
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\GrpcMessage\obj\Debug\net6.0\GrpcMessageNode.genruntimeconfig.cache
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\appsettings.Development.json
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\appsettings.json
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\GrpcMessageNode.exe
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\GrpcMessageNode.deps.json
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\GrpcMessageNode.runtimeconfig.json
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\GrpcMessageNode.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\ref\GrpcMessageNode.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\GrpcMessageNode.pdb
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Google.Protobuf.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Grpc.AspNetCore.Server.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Grpc.AspNetCore.Server.ClientFactory.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Grpc.Core.Api.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Grpc.Net.Client.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Grpc.Net.ClientFactory.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Grpc.Net.Common.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Microsoft.OpenApi.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Steeltoe.Common.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Steeltoe.Common.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Steeltoe.Common.Http.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Steeltoe.Connector.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Steeltoe.Connector.ConnectorBase.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Steeltoe.Connector.ConnectorCore.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Steeltoe.Discovery.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Steeltoe.Discovery.ClientBase.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Steeltoe.Discovery.Eureka.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Steeltoe.Extensions.Configuration.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Swashbuckle.AspNetCore.Swagger.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Swashbuckle.AspNetCore.SwaggerGen.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\Swashbuckle.AspNetCore.SwaggerUI.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\bin\Debug\net6.0\System.Reflection.MetadataLoadContext.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\GrpcMessageNode.csproj.AssemblyReference.cache
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\GrpcMessageNode.GeneratedMSBuildEditorConfig.editorconfig
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\GrpcMessageNode.AssemblyInfoInputs.cache
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\GrpcMessageNode.AssemblyInfo.cs
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\GrpcMessageNode.csproj.CoreCompileInputs.cache
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\GrpcMessageNode.MvcApplicationPartsAssemblyInfo.cs
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\GrpcMessageNode.MvcApplicationPartsAssemblyInfo.cache
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\staticwebassets.build.json
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\staticwebassets.development.json
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\scopedcss\bundle\GrpcMessageNode.styles.css
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\GrpcMessageNode.csproj.CopyComplete
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\GrpcMessageNode.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\ref\GrpcMessageNode.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\GrpcMessageNode.pdb
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\GrpcMessage\obj\Debug\net6.0\GrpcMessageNode.genruntimeconfig.cache
GrpcMessage/obj/Debug/net6.0/GrpcMessageNode.genruntimeconfig.cache
View file @ 5a9c3975
1cb9f2489a2fcc1cd478105107e976554815c050
4aa81b328c808608917c7c6f33675054a7677b31
GrpcMessage/obj/GrpcMessageNode.csproj.nuget.dgspec.json
View file @ 5a9c3975
{
"format": 1,
"restore": {
"D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\GrpcMessage\\GrpcMessageNode.csproj": {}
"D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\GrpcMessage\\GrpcMessageNode.csproj": {}
},
"projects": {
"D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\GrpcMessage\\GrpcMessageNode.csproj": {
"D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\GrpcMessage\\GrpcMessageNode.csproj": {
"version": "1.0.0",
"restore": {
"projectUniqueName": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\GrpcMessage\\GrpcMessageNode.csproj",
"projectUniqueName": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\GrpcMessage\\GrpcMessageNode.csproj",
"projectName": "GrpcMessageNode",
"projectPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\GrpcMessage\\GrpcMessageNode.csproj",
"projectPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\GrpcMessage\\GrpcMessageNode.csproj",
"packagesPath": "C:\\Users\\moham\\.nuget\\packages\\",
"outputPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\GrpcMessage\\obj\\",
"outputPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\GrpcMessage\\obj\\",
"projectStyle": "PackageReference",
"fallbackFolders": [
"C:\\Program Files (x86)\\Microsoft Visual Studio\\Shared\\NuGetPackages"
......
GrpcMessage/obj/project.assets.json
View file @ 5a9c3975
......@@ -2438,11 +2438,11 @@
"project": {
"version": "1.0.0",
"restore": {
"projectUniqueName": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\GrpcMessage\\GrpcMessageNode.csproj",
"projectUniqueName": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\GrpcMessage\\GrpcMessageNode.csproj",
"projectName": "GrpcMessageNode",
"projectPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\GrpcMessage\\GrpcMessageNode.csproj",
"projectPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\GrpcMessage\\GrpcMessageNode.csproj",
"packagesPath": "C:\\Users\\moham\\.nuget\\packages\\",
"outputPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\GrpcMessage\\obj\\",
"outputPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\GrpcMessage\\obj\\",
"projectStyle": "PackageReference",
"fallbackFolders": [
"C:\\Program Files (x86)\\Microsoft Visual Studio\\Shared\\NuGetPackages"
......
GrpcMessage/obj/project.nuget.cache
View file @ 5a9c3975
{
"version": 2,
"dgSpecHash": "23+cxchN2rlbUteg26ZfoIUSA28RNB623EumoA9yvn85PG9E/gAeyLlK9TbPEHocqZH0IvmN1IvlhPmt1D6q6w==",
"dgSpecHash": "88lU4KZ6FeduyrPfOecKs6eGkRoXCXIizwawpScf6Z523Srribwo9gAMLcAlUFvJMIr254EFQZW4o3zK+cDGHQ==",
"success": true,
"projectFilePath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\GrpcMessage\\GrpcMessageNode.csproj",
"projectFilePath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\GrpcMessage\\GrpcMessageNode.csproj",
"expectedPackageFiles": [
"C:\\Users\\moham\\.nuget\\packages\\google.protobuf\\3.27.1\\google.protobuf.3.27.1.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\grpc.aspnetcore\\2.40.0\\grpc.aspnetcore.2.40.0.nupkg.sha512",
......
GrpcMessageNode.sln
View file @ 5a9c3975
......@@ -5,11 +5,9 @@ VisualStudioVersion = 17.0.31903.59
MinimumVisualStudioVersion = 10.0.40219.1
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "GrpcMessageNode", "GrpcMessage\GrpcMessageNode.csproj", "{E55ED87C-0EE4-4A4C-BBBB-76CBF482188D}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "CoordinatorOne", "CoordinatorOne\CoordinatorOne.csproj", "{2B3382EE-564E-44BC-9B3A-2F67273B2802}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "MessageGeneratorGRPC", "MessageGeneratorGRPC\MessageGeneratorGRPC.csproj", "{494712AB-C5A0-4525-81AE-DD203F249CB9}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "QueuerNode", "QueuerNode\QueuerNode.csproj", "{676D9604-4597-4935-826A-7F054FD5936A}"
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "QueuerNode", "QueuerNode\QueuerNode.csproj", "{676D9604-4597-4935-826A-7F054FD5936A}"
EndProject
Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution
......@@ -21,10 +19,6 @@ Global
{E55ED87C-0EE4-4A4C-BBBB-76CBF482188D}.Debug|Any CPU.Build.0 = Debug|Any CPU
{E55ED87C-0EE4-4A4C-BBBB-76CBF482188D}.Release|Any CPU.ActiveCfg = Release|Any CPU
{E55ED87C-0EE4-4A4C-BBBB-76CBF482188D}.Release|Any CPU.Build.0 = Release|Any CPU
{2B3382EE-564E-44BC-9B3A-2F67273B2802}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{2B3382EE-564E-44BC-9B3A-2F67273B2802}.Debug|Any CPU.Build.0 = Debug|Any CPU
{2B3382EE-564E-44BC-9B3A-2F67273B2802}.Release|Any CPU.ActiveCfg = Release|Any CPU
{2B3382EE-564E-44BC-9B3A-2F67273B2802}.Release|Any CPU.Build.0 = Release|Any CPU
{494712AB-C5A0-4525-81AE-DD203F249CB9}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{494712AB-C5A0-4525-81AE-DD203F249CB9}.Debug|Any CPU.Build.0 = Debug|Any CPU
{494712AB-C5A0-4525-81AE-DD203F249CB9}.Release|Any CPU.ActiveCfg = Release|Any CPU
......
MessageGeneratorGRPC/obj/Debug/net6.0/MessageGeneratorGRPC.GeneratedMSBuildEditorConfig.editorconfig
View file @ 5a9c3975
......@@ -7,4 +7,4 @@ build_property.InvariantGlobalization =
build_property.PlatformNeutralAssembly =
build_property._SupportedPlatformList = Linux,macOS,Windows
build_property.RootNamespace = MessageGeneratorGRPC
build_property.ProjectDir = D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\MessageGeneratorGRPC\
build_property.ProjectDir = D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\
MessageGeneratorGRPC/obj/Debug/net6.0/MessageGeneratorGRPC.csproj.FileListAbsolute.txt
View file @ 5a9c3975
......@@ -35,3 +35,40 @@ D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\MessageGeneratorGRPC\obj\Debug\net
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\MessageGeneratorGRPC\obj\Debug\net6.0\ref\MessageGeneratorGRPC.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\MessageGeneratorGRPC\obj\Debug\net6.0\MessageGeneratorGRPC.pdb
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\MessageGeneratorGRPC\obj\Debug\net6.0\MessageGeneratorGRPC.genruntimeconfig.cache
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\appsettings.Development.json
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\appsettings.json
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\MessageGeneratorGRPC.exe
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\MessageGeneratorGRPC.deps.json
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\MessageGeneratorGRPC.runtimeconfig.json
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\MessageGeneratorGRPC.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\ref\MessageGeneratorGRPC.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\MessageGeneratorGRPC.pdb
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Google.Protobuf.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Grpc.Core.Api.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Grpc.Net.Client.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Grpc.Net.Common.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Microsoft.OpenApi.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Steeltoe.Common.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Steeltoe.Common.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Steeltoe.Common.Http.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Steeltoe.Connector.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Steeltoe.Connector.ConnectorBase.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Steeltoe.Connector.ConnectorCore.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Steeltoe.Discovery.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Steeltoe.Discovery.ClientBase.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Steeltoe.Discovery.Eureka.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Steeltoe.Extensions.Configuration.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Swashbuckle.AspNetCore.Swagger.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Swashbuckle.AspNetCore.SwaggerGen.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\Swashbuckle.AspNetCore.SwaggerUI.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\bin\Debug\net6.0\System.Reflection.MetadataLoadContext.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\obj\Debug\net6.0\MessageGeneratorGRPC.csproj.AssemblyReference.cache
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\obj\Debug\net6.0\MessageGeneratorGRPC.GeneratedMSBuildEditorConfig.editorconfig
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\obj\Debug\net6.0\MessageGeneratorGRPC.AssemblyInfoInputs.cache
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\obj\Debug\net6.0\MessageGeneratorGRPC.AssemblyInfo.cs
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\obj\Debug\net6.0\MessageGeneratorGRPC.csproj.CoreCompileInputs.cache
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\obj\Debug\net6.0\MessageGeneratorGRPC.csproj.CopyComplete
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\obj\Debug\net6.0\MessageGeneratorGRPC.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\obj\Debug\net6.0\ref\MessageGeneratorGRPC.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\obj\Debug\net6.0\MessageGeneratorGRPC.pdb
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\MessageGeneratorGRPC\obj\Debug\net6.0\MessageGeneratorGRPC.genruntimeconfig.cache
MessageGeneratorGRPC/obj/Debug/net6.0/MessageGeneratorGRPC.genruntimeconfig.cache
View file @ 5a9c3975
2917d4603a5e29d13425a4cb559d78bac8ae4c9c
c870b7dc19dfc8f3633c52541745159c24ef5ca8
MessageGeneratorGRPC/obj/MessageGeneratorGRPC.csproj.nuget.dgspec.json
View file @ 5a9c3975
{
"format": 1,
"restore": {
"D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\MessageGeneratorGRPC\\MessageGeneratorGRPC.csproj": {}
"D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\MessageGeneratorGRPC\\MessageGeneratorGRPC.csproj": {}
},
"projects": {
"D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\MessageGeneratorGRPC\\MessageGeneratorGRPC.csproj": {
"D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\MessageGeneratorGRPC\\MessageGeneratorGRPC.csproj": {
"version": "1.0.0",
"restore": {
"projectUniqueName": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\MessageGeneratorGRPC\\MessageGeneratorGRPC.csproj",
"projectUniqueName": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\MessageGeneratorGRPC\\MessageGeneratorGRPC.csproj",
"projectName": "MessageGeneratorGRPC",
"projectPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\MessageGeneratorGRPC\\MessageGeneratorGRPC.csproj",
"projectPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\MessageGeneratorGRPC\\MessageGeneratorGRPC.csproj",
"packagesPath": "C:\\Users\\moham\\.nuget\\packages\\",
"outputPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\MessageGeneratorGRPC\\obj\\",
"outputPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\MessageGeneratorGRPC\\obj\\",
"projectStyle": "PackageReference",
"fallbackFolders": [
"C:\\Program Files (x86)\\Microsoft Visual Studio\\Shared\\NuGetPackages"
......
MessageGeneratorGRPC/obj/project.assets.json
View file @ 5a9c3975
......@@ -2299,11 +2299,11 @@
"project": {
"version": "1.0.0",
"restore": {
"projectUniqueName": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\MessageGeneratorGRPC\\MessageGeneratorGRPC.csproj",
"projectUniqueName": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\MessageGeneratorGRPC\\MessageGeneratorGRPC.csproj",
"projectName": "MessageGeneratorGRPC",
"projectPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\MessageGeneratorGRPC\\MessageGeneratorGRPC.csproj",
"projectPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\MessageGeneratorGRPC\\MessageGeneratorGRPC.csproj",
"packagesPath": "C:\\Users\\moham\\.nuget\\packages\\",
"outputPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\MessageGeneratorGRPC\\obj\\",
"outputPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\MessageGeneratorGRPC\\obj\\",
"projectStyle": "PackageReference",
"fallbackFolders": [
"C:\\Program Files (x86)\\Microsoft Visual Studio\\Shared\\NuGetPackages"
......
MessageGeneratorGRPC/obj/project.nuget.cache
View file @ 5a9c3975
{
"version": 2,
"dgSpecHash": "KXi3skHdp2c+M5uEBHg5wZwoNQo0AWVHpibrQhnWDGkStcliZstVV2o4vl58S3PmZgOILlzYmiMUBUtJOYL7wQ==",
"dgSpecHash": "/RqSpcKHJ6tQrjMLOCYr1ka5c7HzNSoqnHcGFF3d0MYNnEgOhx4ZJyVq1FLi4AEM2IPvbLLFqbVwQo9lvBtLRQ==",
"success": true,
"projectFilePath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\MessageGeneratorGRPC\\MessageGeneratorGRPC.csproj",
"projectFilePath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\MessageGeneratorGRPC\\MessageGeneratorGRPC.csproj",
"expectedPackageFiles": [
"C:\\Users\\moham\\.nuget\\packages\\google.protobuf\\3.27.2\\google.protobuf.3.27.2.nupkg.sha512",
"C:\\Users\\moham\\.nuget\\packages\\grpc.core.api\\2.63.0\\grpc.core.api.2.63.0.nupkg.sha512",
......
ProxyGate/Program.cs deleted 100644 → 0
View file @ a55e48b0
using ProxyGateGRPC.Services;
using Steeltoe.Common.Discovery;
using Steeltoe.Discovery;
using Steeltoe.Discovery.Client;
public class Program
{
public static void Main(string[] args)
{
var builder = WebApplication.CreateBuilder(args);
// Additional configuration is required to successfully run gRPC on macOS.
// For instructions on how to configure Kestrel and gRPC clients on macOS, visit https://go.microsoft.com/fwlink/?linkid=2099682
// Add services to the container.
builder.Services.AddGrpc();
builder.Services.AddDiscoveryClient(builder.Configuration);
var app = builder.Build();
// Configure the HTTP request pipeline.
app.MapGrpcService<ForwardMessageService>();
app.MapGet("/", () => "Communication with gRPC endpoints must be made through a gRPC client. To learn how to create a client, visit: https://go.microsoft.com/fwlink/?linkid=2086909");
app.Run();
//Console.WriteLine("Hello");
}
}
ProxyGate/Properties/launchSettings.json deleted 100644 → 0
View file @ a55e48b0
{
"profiles": {
"ProxyGate": {
"commandName": "Project",
"dotnetRunMessages": true,
"launchBrowser": false,
"applicationUrl": "http://localhost:5255;https://localhost:9090",
"environmentVariables": {
"ASPNETCORE_ENVIRONMENT": "Development"
}
}
}
}
ProxyGate/Protos/greet.proto deleted 100644 → 0
View file @ a55e48b0
syntax = "proto3";
option csharp_namespace = "ProxyGate";
package greet;
// The greeting service definition.
service Greeter {
// Sends a greeting
rpc SayHello (HelloRequest) returns (HelloReply);
}
// The request message containing the user's name.
message HelloRequest {
string name = 1;
}
// The response message containing the greetings.
message HelloReply {
string message = 1;
}
ProxyGate/Protos/schema-forward.proto deleted 100644 → 0
View file @ a55e48b0
syntax = "proto3";
option csharp_namespace = "ProxyGateGRPC";
package Tranmitter;
message Message {
string clientID = 1;
string apiKey = 2;
string msgId = 3;
string phoneNumber = 4;
int32 localPriority = 5;
string text = 6;
}
message Acknowledgement
{
string replyCode = 1;
}
service Forward {
rpc ForwardMessage(Message) returns (Acknowledgement);
}
ProxyGate/Protos/schema.proto deleted 100644 → 0
View file @ a55e48b0
syntax = "proto3";
option csharp_namespace = "ProxyGateGRPC";
package Tranmitter;
message Message2 {
string clientID = 1;
string apiKey = 2;
string msgId = 3;
string phoneNumber = 4;
int32 localPriority = 5;
string text = 6;
}
message Acknowledgement2
{
string replyCode = 1;
}
service Send {
rpc SendMessage(Message2) returns (Acknowledgement2);
}
ProxyGate/ProxyGate.csproj deleted 100644 → 0
View file @ a55e48b0
<Project Sdk="Microsoft.NET.Sdk.Web">
<PropertyGroup>
<TargetFramework>net6.0</TargetFramework>
<Nullable>enable</Nullable>
<ImplicitUsings>enable</ImplicitUsings>
</PropertyGroup>
<ItemGroup>
<Protobuf Include="Protos\schema-forward.proto" GrpcServices="Server" />
<Protobuf Include="Protos\schema.proto" GrpcServices="Client" />
</ItemGroup>
<ItemGroup>
<PackageReference Include="Microsoft.Extensions.Hosting" Version="6.0.0" />
</ItemGroup>
<ItemGroup>
<PackageReference Include="Grpc.AspNetCore" Version="2.40.0" />
</ItemGroup>
<ItemGroup>
<PackageReference Include="Google.Protobuf" Version="3.27.1" />
<PackageReference Include="Grpc.Net.Client" Version="2.63.0" />
<PackageReference Include="Grpc.Tools" Version="2.64.0">
<PrivateAssets>all</PrivateAssets>
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
</PackageReference>
</ItemGroup>
<ItemGroup>
<PackageReference Include="Swashbuckle.AspNetCore" Version="6.4.*" />
</ItemGroup>
<ItemGroup>
<PackageReference Include="Steeltoe.Connector.ConnectorCore" Version="$(SteeltoeVersion)" />
<PackageReference Include="Steeltoe.Discovery.Eureka" Version="$(SteeltoeVersion)" />
</ItemGroup>
</Project>
ProxyGate/Services/ForwardMessageService.cs deleted 100644 → 0
View file @ a55e48b0
using Grpc.Core;
using Grpc.Net.Client;
using Steeltoe.Common.Discovery;
using Steeltoe.Discovery;
namespace ProxyGateGRPC.Services
{
public class ForwardMessageService : Forward.ForwardBase
{
private readonly ILogger<ForwardMessageService> _logger;
private readonly DiscoveryHttpClientHandler _handler;
public ForwardMessageService(ILogger<ForwardMessageService> logger, IDiscoveryClient client)
{
_logger = logger;
_handler = new DiscoveryHttpClientHandler(client);
}
public override Task<Acknowledgement> ForwardMessage (Message message, ServerCallContext context)
{
//my port = 9090
Console.WriteLine("Accepted" + message.ApiKey);
using var channel = GrpcChannel.ForAddress("https://localhost:9091");
var client = new Send.SendClient(channel);
Message2 message2 = new Message2();
message.ApiKey = message.ApiKey;
message2.MsgId = message.MsgId; ;
message2.LocalPriority = message.LocalPriority;
message2.PhoneNumber = message2.PhoneNumber;
message2.Text = message.Text;
message2.ClientID = message.ClientID;
Acknowledgement2 acknowledgement2 = client.SendMessage(message2);
Console.ForegroundColor = ConsoleColor.Red;
Console.WriteLine("IN Queue ??");
Console.ForegroundColor = ConsoleColor.Black;
return Task.FromResult(new Acknowledgement
{ ReplyCode = acknowledgement2.ReplyCode});
}
}
}
ProxyGate/Services/GreeterService.cs deleted 100644 → 0
View file @ a55e48b0
using Grpc.Core;
using ProxyGate;
namespace ProxyGate.Services
{
public class GreeterService : Greeter.GreeterBase
{
private readonly ILogger<GreeterService> _logger;
public GreeterService(ILogger<GreeterService> logger)
{
_logger = logger;
}
public override Task<HelloReply> SayHello(HelloRequest request, ServerCallContext context)
{
return Task.FromResult(new HelloReply
{
Message = "Hello " + request.Name
});
}
}
}
\ No newline at end of file
ProxyGate/appsettings.Development.json deleted 100644 → 0
View file @ a55e48b0
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.AspNetCore": "Warning"
}
}
}
ProxyGate/appsettings.json deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/bin/Debug/net6.0/Google.Protobuf.dll deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/bin/Debug/net6.0/Grpc.AspNetCore.Server.dll deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/bin/Debug/net6.0/Grpc.Core.Api.dll deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/bin/Debug/net6.0/Grpc.Net.Client.dll deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/bin/Debug/net6.0/Grpc.Net.ClientFactory.dll deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/bin/Debug/net6.0/Grpc.Net.Common.dll deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/bin/Debug/net6.0/Microsoft.OpenApi.dll deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/bin/Debug/net6.0/ProxyGate.deps.json deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/bin/Debug/net6.0/ProxyGate.dll deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/bin/Debug/net6.0/ProxyGate.exe deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/bin/Debug/net6.0/ProxyGate.pdb deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/bin/Debug/net6.0/Steeltoe.Common.Http.dll deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/bin/Debug/net6.0/Steeltoe.Common.dll deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/bin/Debug/net6.0/Steeltoe.Discovery.Eureka.dll deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/bin/Debug/net6.0/appsettings.json deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/bin/Debug/net6.0/ref/ProxyGate.dll deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/Debug/net6.0/Protos/Greet.cs deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/Debug/net6.0/Protos/GreetGrpc.cs deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/Debug/net6.0/Protos/Schema.cs deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/Debug/net6.0/Protos/SchemaForward.cs deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/Debug/net6.0/Protos/SchemaGrpc.cs deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/Debug/net6.0/ProxyGate.AssemblyInfo.cs deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/Debug/net6.0/ProxyGate.GlobalUsings.g.cs deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/Debug/net6.0/ProxyGate.assets.cache deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/Debug/net6.0/ProxyGate.dll deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/Debug/net6.0/ProxyGate.pdb deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/Debug/net6.0/apphost.exe deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/Debug/net6.0/ref/ProxyGate.dll deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/Debug/net6.0/staticwebassets.build.json deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/ProxyGate.csproj.nuget.dgspec.json deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/ProxyGate.csproj.nuget.g.props deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/ProxyGate.csproj.nuget.g.targets deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/project.assets.json deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/project.nuget.cache deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyGate/obj/staticwebassets.pack.sentinel deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyProtocols/Program.cs deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyProtocols/Properties/launchSettings.json deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyProtocols/Protos/schema-forward.proto deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyProtocols/Protos/schema.proto deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyProtocols/ProxyProtocols.csproj deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyProtocols/Services/ForwardMessageService.cs deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyProtocols/Worker.cs deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyProtocols/appsettings.Development.json deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyProtocols/appsettings.json deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyProtocols/obj/Debug/net6.0/Protos/Schema-2Grpc.cs deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyProtocols/obj/Debug/net6.0/Protos/Schema.cs deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyProtocols/obj/Debug/net6.0/Protos/Schema2.cs deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyProtocols/obj/Debug/net6.0/Protos/SchemaCopy.cs deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyProtocols/obj/Debug/net6.0/Protos/SchemaGrpc.cs deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyProtocols/obj/ProxyProtocols.csproj.nuget.g.props deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyProtocols/obj/project.assets.json deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
ProxyProtocols/obj/project.nuget.cache deleted 100644 → 0
View file @ a55e48b0
This diff is collapsed.
QueuerNode/Services/QueueMessageService.cs
View file @ 5a9c3975
This diff is collapsed.
QueuerNode/bin/Debug/net6.0/QueuerNode.dll
View file @ 5a9c3975
This diff is collapsed.
QueuerNode/bin/Debug/net6.0/QueuerNode.pdb
View file @ 5a9c3975
This diff is collapsed.
QueuerNode/obj/Debug/net6.0/QueuerNode.dll
View file @ 5a9c3975
This diff is collapsed.
QueuerNode/obj/Debug/net6.0/QueuerNode.pdb
View file @ 5a9c3975
This diff is collapsed.
QueuerNode/obj/project.assets.json
View file @ 5a9c3975
This diff is collapsed.
QueuerNode/obj/project.nuget.cache
View file @ 5a9c3975
This diff is collapsed.
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment

HIAST - GitLab