Skip to content

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

GRPC + Http clients sends to GRPC,HTTP nodes which in turn send to queuer node... 

GRPC + Http clients sends to GRPC,HTTP nodes which in turn send to queuer node successfully , http client does not use discovery yet
parent 900ccd5e
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 9591 additions and 7 deletions
.vs/GrpcMessageNode/project-colors.json
View file @ 7b9e1709
...@@ -40,7 +40,12 @@ ...@@ -40,7 +40,12 @@
"ProjectGuid": "676d9604-4597-4935-826a-7f054fd5936a", "ProjectGuid": "676d9604-4597-4935-826a-7f054fd5936a",
"DisplayName": "QueuerNode", "DisplayName": "QueuerNode",
"ColorIndex": 6 "ColorIndex": 6
},
"79a276e9-da51-4434-9241-a0f8e6771232": {
"ProjectGuid": "79a276e9-da51-4434-9241-a0f8e6771232",
"DisplayName": "HTTPMessageNode",
"ColorIndex": 7
} }
}, },
"NextColorIndex": 7 "NextColorIndex": 8
} }
\ No newline at end of file
GrpcMessageNode.sln
View file @ 7b9e1709
...@@ -9,6 +9,10 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "MessageGeneratorGRPC", "Mes ...@@ -9,6 +9,10 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "MessageGeneratorGRPC", "Mes
EndProject EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "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 EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "HTTPMessageNode", "HTTPMessageNode\HTTPMessageNode.csproj", "{79828C38-A68B-4340-9F93-D55C5DCC203A}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "HTTPMessageGenerator", "HTTPMessageGenerator\HTTPMessageGenerator.csproj", "{C008AEEB-FD9F-4D59-B047-A77BD058C12F}"
EndProject
Global Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution GlobalSection(SolutionConfigurationPlatforms) = preSolution
Debug|Any CPU = Debug|Any CPU Debug|Any CPU = Debug|Any CPU
...@@ -27,6 +31,14 @@ Global ...@@ -27,6 +31,14 @@ Global
{676D9604-4597-4935-826A-7F054FD5936A}.Debug|Any CPU.Build.0 = Debug|Any CPU {676D9604-4597-4935-826A-7F054FD5936A}.Debug|Any CPU.Build.0 = Debug|Any CPU
{676D9604-4597-4935-826A-7F054FD5936A}.Release|Any CPU.ActiveCfg = Release|Any CPU {676D9604-4597-4935-826A-7F054FD5936A}.Release|Any CPU.ActiveCfg = Release|Any CPU
{676D9604-4597-4935-826A-7F054FD5936A}.Release|Any CPU.Build.0 = Release|Any CPU {676D9604-4597-4935-826A-7F054FD5936A}.Release|Any CPU.Build.0 = Release|Any CPU
{79828C38-A68B-4340-9F93-D55C5DCC203A}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{79828C38-A68B-4340-9F93-D55C5DCC203A}.Debug|Any CPU.Build.0 = Debug|Any CPU
{79828C38-A68B-4340-9F93-D55C5DCC203A}.Release|Any CPU.ActiveCfg = Release|Any CPU
{79828C38-A68B-4340-9F93-D55C5DCC203A}.Release|Any CPU.Build.0 = Release|Any CPU
{C008AEEB-FD9F-4D59-B047-A77BD058C12F}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{C008AEEB-FD9F-4D59-B047-A77BD058C12F}.Debug|Any CPU.Build.0 = Debug|Any CPU
{C008AEEB-FD9F-4D59-B047-A77BD058C12F}.Release|Any CPU.ActiveCfg = Release|Any CPU
{C008AEEB-FD9F-4D59-B047-A77BD058C12F}.Release|Any CPU.Build.0 = Release|Any CPU
EndGlobalSection EndGlobalSection
GlobalSection(SolutionProperties) = preSolution GlobalSection(SolutionProperties) = preSolution
HideSolutionNode = FALSE HideSolutionNode = FALSE
......
HTTPMessageGenerator/HTTPMessageGenerator.csproj 0 → 100644
View file @ 7b9e1709
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<OutputType>Exe</OutputType>
<TargetFramework>net6.0</TargetFramework>
<ImplicitUsings>enable</ImplicitUsings>
<Nullable>enable</Nullable>
</PropertyGroup>
<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="Client" />
</ItemGroup>
</Project>
HTTPMessageGenerator/MessageDTO.cs 0 → 100644
View file @ 7b9e1709
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace HTTPMessageGenerator
{
public class MessageDTO
{
public string? clientID { get; set; }
public string? apiKey { get; set; }
public string? msgId { get; set; }
public string? phoneNumber { get; set; }
public int localPriority { get; set; }
public string? text { get; set; }
}
}
HTTPMessageGenerator/Program.cs 0 → 100644
View file @ 7b9e1709
// See https://aka.ms/new-console-template for more information
using HTTPMessageGenerator;
using System.Net;
using System.Text;
using System.Text.Json;
Console.WriteLine("Hello, World!");
MessageDTO message = new MessageDTO();
message.text = "Hello World !";
message.apiKey = "Api-Key";
message.clientID = "m-salameh";
message.localPriority = 1;
message.msgId = "msg-id=1";
message.phoneNumber = "043 33 00 83";
var client = new HttpClient();
/*
using StringContent jsonContent = new(
JsonSerializer.Serialize(new
{message
}),
Encoding.UTF8,
"application/json");
*/
StringContent payload = new (JsonSerializer.Serialize(message) , Encoding.UTF8 , "application/json");
HttpResponseMessage reply = await client.PostAsync("https://localhost:7095/queue-msg", payload);
Console.WriteLine(reply.Content.ToString());
//Console.WriteLine(reply.Result);
HTTPMessageGenerator/Protos/schema.proto 0 → 100644
View file @ 7b9e1709
syntax = "proto3";
option csharp_namespace = "HTTPMessageGenerator";
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);
}
HTTPMessageGenerator/bin/Debug/net6.0/HTTPMessageGenerator.runtimeconfig.json 0 → 100644
View file @ 7b9e1709
{
"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
HTTPMessageGenerator/obj/Debug/net6.0/.NETCoreApp,Version=v6.0.AssemblyAttributes.cs 0 → 100644
View file @ 7b9e1709
// <autogenerated />
using System;
using System.Reflection;
[assembly: global::System.Runtime.Versioning.TargetFrameworkAttribute(".NETCoreApp,Version=v6.0", FrameworkDisplayName = "")]
HTTPMessageGenerator/obj/Debug/net6.0/12fbc7ffe642ca7e_schema.protodep 0 → 100644
View file @ 7b9e1709
obj\Debug\net6.0\Protos/Schema.cs \
obj\Debug\net6.0\Protos/SchemaGrpc.cs: Protos/schema.proto
\ No newline at end of file
HTTPMessageGenerator/obj/Debug/net6.0/HTTPMessageGenerator.AssemblyInfo.cs 0 → 100644
View file @ 7b9e1709
//------------------------------------------------------------------------------
// <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: System.Reflection.AssemblyCompanyAttribute("HTTPMessageGenerator")]
[assembly: System.Reflection.AssemblyConfigurationAttribute("Debug")]
[assembly: System.Reflection.AssemblyFileVersionAttribute("1.0.0.0")]
[assembly: System.Reflection.AssemblyInformationalVersionAttribute("1.0.0")]
[assembly: System.Reflection.AssemblyProductAttribute("HTTPMessageGenerator")]
[assembly: System.Reflection.AssemblyTitleAttribute("HTTPMessageGenerator")]
[assembly: System.Reflection.AssemblyVersionAttribute("1.0.0.0")]
// Generated by the MSBuild WriteCodeFragment class.
HTTPMessageGenerator/obj/Debug/net6.0/HTTPMessageGenerator.GeneratedMSBuildEditorConfig.editorconfig 0 → 100644
View file @ 7b9e1709
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 = HTTPMessageGenerator
build_property.ProjectDir = D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\
HTTPMessageGenerator/obj/Debug/net6.0/HTTPMessageGenerator.GlobalUsings.g.cs 0 → 100644
View file @ 7b9e1709
// <auto-generated/>
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;
HTTPMessageGenerator/obj/Debug/net6.0/HTTPMessageGenerator.csproj.FileListAbsolute.txt 0 → 100644
View file @ 7b9e1709
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\HTTPMessageGenerator.exe
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\HTTPMessageGenerator.deps.json
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\HTTPMessageGenerator.runtimeconfig.json
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\HTTPMessageGenerator.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\ref\HTTPMessageGenerator.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\HTTPMessageGenerator.pdb
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Google.Protobuf.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Grpc.AspNetCore.Server.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Grpc.AspNetCore.Server.ClientFactory.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Grpc.Core.Api.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Grpc.Net.Client.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Grpc.Net.ClientFactory.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Grpc.Net.Common.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Microsoft.OpenApi.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Steeltoe.Common.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Steeltoe.Common.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Steeltoe.Common.Http.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Steeltoe.Connector.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Steeltoe.Connector.ConnectorBase.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Steeltoe.Connector.ConnectorCore.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Steeltoe.Discovery.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Steeltoe.Discovery.ClientBase.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Steeltoe.Discovery.Eureka.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Steeltoe.Extensions.Configuration.Abstractions.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Swashbuckle.AspNetCore.Swagger.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Swashbuckle.AspNetCore.SwaggerGen.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\Swashbuckle.AspNetCore.SwaggerUI.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\bin\Debug\net6.0\System.Reflection.MetadataLoadContext.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\obj\Debug\net6.0\HTTPMessageGenerator.csproj.AssemblyReference.cache
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\obj\Debug\net6.0\HTTPMessageGenerator.GeneratedMSBuildEditorConfig.editorconfig
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\obj\Debug\net6.0\HTTPMessageGenerator.AssemblyInfoInputs.cache
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\obj\Debug\net6.0\HTTPMessageGenerator.AssemblyInfo.cs
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\obj\Debug\net6.0\HTTPMessageGenerator.csproj.CoreCompileInputs.cache
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\obj\Debug\net6.0\HTTPMessageGenerator.csproj.CopyComplete
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\obj\Debug\net6.0\HTTPMessageGenerator.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\obj\Debug\net6.0\ref\HTTPMessageGenerator.dll
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\obj\Debug\net6.0\HTTPMessageGenerator.pdb
D:\HIAST\FIY\Project-MSGPriorityQ\GrpcMessage\message-priority-queue\HTTPMessageGenerator\obj\Debug\net6.0\HTTPMessageGenerator.genruntimeconfig.cache
HTTPMessageGenerator/obj/Debug/net6.0/Protos/Schema.cs 0 → 100644
View file @ 7b9e1709
This diff is collapsed.
HTTPMessageGenerator/obj/Debug/net6.0/Protos/SchemaGrpc.cs 0 → 100644
View file @ 7b9e1709
// <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 HTTPMessageGenerator {
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::HTTPMessageGenerator.Message> __Marshaller_Tranmitter_Message = grpc::Marshallers.Create(__Helper_SerializeMessage, context => __Helper_DeserializeMessage(context, global::HTTPMessageGenerator.Message.Parser));
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
static readonly grpc::Marshaller<global::HTTPMessageGenerator.Acknowledgement> __Marshaller_Tranmitter_Acknowledgement = grpc::Marshallers.Create(__Helper_SerializeMessage, context => __Helper_DeserializeMessage(context, global::HTTPMessageGenerator.Acknowledgement.Parser));
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
static readonly grpc::Method<global::HTTPMessageGenerator.Message, global::HTTPMessageGenerator.Acknowledgement> __Method_QueueMessage = new grpc::Method<global::HTTPMessageGenerator.Message, global::HTTPMessageGenerator.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::HTTPMessageGenerator.SchemaReflection.Descriptor.Services[0]; }
}
/// <summary>Client for Queue</summary>
public partial class QueueClient : grpc::ClientBase<QueueClient>
{
/// <summary>Creates a new client for Queue</summary>
/// <param name="channel">The channel to use to make remote calls.</param>
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
public QueueClient(grpc::ChannelBase channel) : base(channel)
{
}
/// <summary>Creates a new client for Queue that uses a custom <c>CallInvoker</c>.</summary>
/// <param name="callInvoker">The callInvoker to use to make remote calls.</param>
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
public QueueClient(grpc::CallInvoker callInvoker) : base(callInvoker)
{
}
/// <summary>Protected parameterless constructor to allow creation of test doubles.</summary>
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
protected QueueClient() : base()
{
}
/// <summary>Protected constructor to allow creation of configured clients.</summary>
/// <param name="configuration">The client configuration.</param>
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
protected QueueClient(ClientBaseConfiguration configuration) : base(configuration)
{
}
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
public virtual global::HTTPMessageGenerator.Acknowledgement QueueMessage(global::HTTPMessageGenerator.Message request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))
{
return QueueMessage(request, new grpc::CallOptions(headers, deadline, cancellationToken));
}
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
public virtual global::HTTPMessageGenerator.Acknowledgement QueueMessage(global::HTTPMessageGenerator.Message request, grpc::CallOptions options)
{
return CallInvoker.BlockingUnaryCall(__Method_QueueMessage, null, options, request);
}
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
public virtual grpc::AsyncUnaryCall<global::HTTPMessageGenerator.Acknowledgement> QueueMessageAsync(global::HTTPMessageGenerator.Message request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))
{
return QueueMessageAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken));
}
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
public virtual grpc::AsyncUnaryCall<global::HTTPMessageGenerator.Acknowledgement> QueueMessageAsync(global::HTTPMessageGenerator.Message request, grpc::CallOptions options)
{
return CallInvoker.AsyncUnaryCall(__Method_QueueMessage, null, options, request);
}
/// <summary>Creates a new instance of client from given <c>ClientBaseConfiguration</c>.</summary>
[global::System.CodeDom.Compiler.GeneratedCode("grpc_csharp_plugin", null)]
protected override QueueClient NewInstance(ClientBaseConfiguration configuration)
{
return new QueueClient(configuration);
}
}
}
}
#endregion
HTTPMessageGenerator/obj/HTTPMessageGenerator.csproj.nuget.dgspec.json 0 → 100644
View file @ 7b9e1709
{
"format": 1,
"restore": {
"D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\HTTPMessageGenerator\\HTTPMessageGenerator.csproj": {}
},
"projects": {
"D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\HTTPMessageGenerator\\HTTPMessageGenerator.csproj": {
"version": "1.0.0",
"restore": {
"projectUniqueName": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\HTTPMessageGenerator\\HTTPMessageGenerator.csproj",
"projectName": "HTTPMessageGenerator",
"projectPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\HTTPMessageGenerator\\HTTPMessageGenerator.csproj",
"packagesPath": "C:\\Users\\moham\\.nuget\\packages\\",
"outputPath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\HTTPMessageGenerator\\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, )"
},
"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
HTTPMessageGenerator/obj/HTTPMessageGenerator.csproj.nuget.g.props 0 → 100644
View file @ 7b9e1709
<?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
HTTPMessageGenerator/obj/HTTPMessageGenerator.csproj.nuget.g.targets 0 → 100644
View file @ 7b9e1709
<?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
HTTPMessageGenerator/obj/project.assets.json 0 → 100644
View file @ 7b9e1709
This source diff could not be displayed because it is too large. You can view the blob instead.
HTTPMessageGenerator/obj/project.nuget.cache 0 → 100644
View file @ 7b9e1709
{
"version": 2,
"dgSpecHash": "2fzG40GLh4JB4Og+1xyJRvcu4067pikGe318shFQhNzjxNN5e64lfhNEsocxSiSxBtM8W9Rr7/LX3e7bhpanng==",
"success": true,
"projectFilePath": "D:\\HIAST\\FIY\\Project-MSGPriorityQ\\GrpcMessage\\message-priority-queue\\HTTPMessageGenerator\\HTTPMessageGenerator.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
HTTPMessageNode/Controllers/QueueMessageController.cs 0 → 100644
View file @ 7b9e1709
using Grpc.Net.Client;
using Microsoft.AspNetCore.Mvc;
using Steeltoe.Discovery;
namespace HTTPMessageNode.Controllers
{
[ApiController]
[Route("[controller]")]
public class QueueMessageController : ControllerBase
{
private readonly ILogger<QueueMessageController> _logger;
private readonly IDiscoveryClient discoveryClient;
public QueueMessageController(ILogger<QueueMessageController> logger , IDiscoveryClient discovery)
{
_logger = logger;
discoveryClient = discovery;
}
//[HttpGet(Name = "GetWeatherForecast")]
[Route("/queue-msg")]
[HttpPost]
public string SendMessage([FromBody] MessageDTO messageDTO)
{
Console.WriteLine("Msg from : " + messageDTO.clientID);
string address = getAddress();
using var channel = GrpcChannel.ForAddress(address);
var client = new Queue.QueueClient(channel);
Console.WriteLine("Sending to " + address);
Message message = copyMessage(messageDTO);
/*Message message = new Message();
message.MsgId = messageDTO.msgId;
message.Text = messageDTO.text;
message.LocalPriority = messageDTO.localPriority;
message.PhoneNumber = messageDTO.phoneNumber;
message.ApiKey = messageDTO.apiKey;
message.ClientID = messageDTO.clientID;*/
var reply = client.QueueMessage(message);
Console.WriteLine(reply.ReplyCode);
return reply.ReplyCode;
}
private Message copyMessage(MessageDTO messageDTO)
{
Message message = new Message();
message.MsgId = messageDTO.msgId;
message.Text = messageDTO.text;
message.LocalPriority = messageDTO.localPriority;
message.PhoneNumber = messageDTO.phoneNumber;
message.ApiKey = messageDTO.apiKey;
message.ClientID = messageDTO.clientID;
return message;
}
private string getAddress()
{
string address = "";
var y = discoveryClient.GetInstances("QueuerNode"); /// write names to config file
address = y[0].Uri.ToString();
return address;
}
}
}
\ No newline at end of file
HTTPMessageNode/HTTPMessageNode.csproj 0 → 100644
View file @ 7b9e1709
<Project Sdk="Microsoft.NET.Sdk.Web">
<PropertyGroup>
<TargetFramework>net6.0</TargetFramework>
<Nullable>enable</Nullable>
<ImplicitUsings>enable</ImplicitUsings>
</PropertyGroup>
<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="Client" />
</ItemGroup>
</Project>
HTTPMessageNode/MessageDTO.cs 0 → 100644
View file @ 7b9e1709
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace HTTPMessageNode
{
public class MessageDTO
{
public string? clientID { get; set; }
public string? apiKey { get; set; }
public string? msgId { get; set; }
public string? phoneNumber { get; set; }
public int localPriority { get; set; }
public string? text { get; set; }
}
}
HTTPMessageNode/Program.cs 0 → 100644
View file @ 7b9e1709
using Steeltoe.Discovery.Client;
var builder = WebApplication.CreateBuilder(args);
// Add services to the container.
builder.Services.AddControllers();
// Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
builder.Services.AddEndpointsApiExplorer();
builder.Services.AddSwaggerGen();
builder.Services.AddDiscoveryClient();
var app = builder.Build();
// Configure the HTTP request pipeline.
if (app.Environment.IsDevelopment())
{
app.UseSwagger();
app.UseSwaggerUI();
}
app.UseHttpsRedirection();
app.UseAuthorization();
app.MapControllers();
app.Run();
HTTPMessageNode/Properties/launchSettings.json 0 → 100644
View file @ 7b9e1709
{
"$schema": "https://json.schemastore.org/launchsettings.json",
"iisSettings": {
"windowsAuthentication": false,
"anonymousAuthentication": true,
"iisExpress": {
"applicationUrl": "http://localhost:21530",
"sslPort": 44331
}
},
"profiles": {
"HTTPMessageNode": {
"commandName": "Project",
"dotnetRunMessages": true,
"launchBrowser": true,
"launchUrl": "swagger",
"applicationUrl": "https://localhost:7095;http://localhost:5095",
"environmentVariables": {
"ASPNETCORE_ENVIRONMENT": "Development"
}
},
"IIS Express": {
"commandName": "IISExpress",
"launchBrowser": true,
"launchUrl": "swagger",
"environmentVariables": {
"ASPNETCORE_ENVIRONMENT": "Development"
}
}
}
}
HTTPMessageNode/Protos/schema.proto 0 → 100644
View file @ 7b9e1709
syntax = "proto3";
option csharp_namespace = "HTTPMessageNode";
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);
}
HTTPMessageNode/appsettings.Development.json 0 → 100644
View file @ 7b9e1709
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.AspNetCore": "Warning"
}
}
}
HTTPMessageNode/appsettings.json 0 → 100644
View file @ 7b9e1709
{
"spring": {
"application": {
"name": "http-message-node"
}
},
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.AspNetCore": "Warning"
}
},
"eureka": {
"client": {
"serviceUrl": "http://localhost:8761/eureka/",
"shouldFetchRegistry": "true",
"shouldRegisterWithEureka": true,
"validateCertificates": false
},
"AllowedHosts": "*"
}
}
HTTPMessageNode/bin/Debug/net6.0/HTTPMessageNode.deps.json 0 → 100644
View file @ 7b9e1709
This diff is collapsed.
HTTPMessageNode/bin/Debug/net6.0/HTTPMessageNode.runtimeconfig.json 0 → 100644
View file @ 7b9e1709
{
"runtimeOptions": {
"tfm": "net6.0",
"frameworks": [
{
"name": "Microsoft.NETCore.App",
"version": "6.0.0"
},
{
"name": "Microsoft.AspNetCore.App",
"version": "6.0.0"
}
],
"configProperties": {
"System.GC.Server": true,
"System.Runtime.Serialization.EnableUnsafeBinaryFormatterSerialization": false
}
}
}
\ No newline at end of file
HTTPMessageNode/bin/Debug/net6.0/appsettings.Development.json 0 → 100644
View file @ 7b9e1709
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.AspNetCore": "Warning"
}
}
}
HTTPMessageNode/bin/Debug/net6.0/appsettings.json 0 → 100644
View file @ 7b9e1709
{
"spring": {
"application": {
"name": "http-message-node"
}
},
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.AspNetCore": "Warning"
}
},
"eureka": {
"client": {
"serviceUrl": "http://localhost:8761/eureka/",
"shouldFetchRegistry": "true",
"shouldRegisterWithEureka": true,
"validateCertificates": false
},
"AllowedHosts": "*"
}
}
HTTPMessageNode/obj/Debug/net6.0/.NETCoreApp,Version=v6.0.AssemblyAttributes.cs 0 → 100644
View file @ 7b9e1709
// <autogenerated />
using System;
using System.Reflection;
[assembly: global::System.Runtime.Versioning.TargetFrameworkAttribute(".NETCoreApp,Version=v6.0", FrameworkDisplayName = "")]
HTTPMessageNode/obj/Debug/net6.0/12fbc7ffe642ca7e_schema.protodep 0 → 100644
View file @ 7b9e1709
obj\Debug\net6.0\Protos/Schema.cs \
obj\Debug\net6.0\Protos/SchemaGrpc.cs: Protos/schema.proto
\ No newline at end of file
HTTPMessageNode/obj/Debug/net6.0/HTTPMessageNode.assets.cache 0 → 100644
View file @ 7b9e1709
This diff is collapsed.
HTTPMessageNode/obj/Debug/net6.0/HTTPMessageNode.dll 0 → 100644
View file @ 7b9e1709
This diff is collapsed.
HTTPMessageNode/obj/Debug/net6.0/HTTPMessageNode.pdb 0 → 100644
View file @ 7b9e1709
This diff is collapsed.
HTTPMessageNode/obj/Debug/net6.0/Protos/Schema.cs 0 → 100644
View file @ 7b9e1709
This diff is collapsed.
HTTPMessageNode/obj/Debug/net6.0/Protos/SchemaGrpc.cs 0 → 100644
View file @ 7b9e1709
This diff is collapsed.
HTTPMessageNode/obj/Debug/net6.0/apphost.exe 0 → 100644
View file @ 7b9e1709
This diff is collapsed.
HTTPMessageNode/obj/Debug/net6.0/ref/HTTPMessageNode.dll 0 → 100644
View file @ 7b9e1709
This diff is collapsed.
HTTPMessageNode/obj/Debug/net6.0/staticwebassets.build.json 0 → 100644
View file @ 7b9e1709
This diff is collapsed.
HTTPMessageNode/obj/HTTPMessageNode.csproj.nuget.dgspec.json 0 → 100644
View file @ 7b9e1709
This diff is collapsed.
HTTPMessageNode/obj/HTTPMessageNode.csproj.nuget.g.props 0 → 100644
View file @ 7b9e1709
This diff is collapsed.
HTTPMessageNode/obj/HTTPMessageNode.csproj.nuget.g.targets 0 → 100644
View file @ 7b9e1709
This diff is collapsed.
HTTPMessageNode/obj/project.assets.json 0 → 100644
View file @ 7b9e1709
This diff is collapsed.
HTTPMessageNode/obj/project.nuget.cache 0 → 100644
View file @ 7b9e1709
This diff is collapsed.
HTTPMessageNode/obj/staticwebassets.pack.sentinel 0 → 100644
View file @ 7b9e1709
This diff is collapsed.
QueuerNode/Helper/MessageQueues.cs
View file @ 7b9e1709
This diff is collapsed.
QueuerNode/Services/QueueMessageService.cs
View file @ 7b9e1709
This diff is collapsed.
QueuerNode/bin/Debug/net6.0/QueuerNode.dll
View file @ 7b9e1709
This diff is collapsed.
QueuerNode/bin/Debug/net6.0/QueuerNode.pdb
View file @ 7b9e1709
This diff is collapsed.
QueuerNode/obj/Debug/net6.0/QueuerNode.dll
View file @ 7b9e1709
This diff is collapsed.
QueuerNode/obj/Debug/net6.0/QueuerNode.pdb
View file @ 7b9e1709
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