migrated interfaces/added channel mapping

removed a bunch of the message interfaces in favor of using record objects instead to make implemenetation of connectors simpler as well as clean up the code
added in a channel mapper class that allows for the channels specificed to be mapped/changed during run time for the different messaging styles in case there is a need to do so.

Abstractions/Interfaces/IContractConnection.cs

@@ -5,15 +5,15 @@ namespace MQContract.Interfaces
 {
     public interface IContractConnection
     {
-        Task<IPingResult> PingAsync();
-        Task<ITransmissionResult> PublishAsync<T>(T message, TimeSpan? timeout = null, string? channel = null, IMessageHeader? messageHeader = null, IServiceChannelOptions? options = null, CancellationToken cancellationToken = new CancellationToken())
+        Task<PingResult> PingAsync();
+        Task<TransmissionResult> PublishAsync<T>(T message, TimeSpan? timeout = null, string? channel = null, IMessageHeader? messageHeader = null, IServiceChannelOptions? options = null, CancellationToken cancellationToken = new CancellationToken())
             where T : class;
         Task<ISubscription> SubscribeAsync<T>(Func<IMessage<T>,Task> messageRecieved, Action<Exception> errorRecieved, string? channel = null, string? group = null, bool ignoreMessageHeader = false,bool synchronous=false, IServiceChannelOptions? options = null, CancellationToken cancellationToken = new CancellationToken())
             where T : class;
-        Task<IQueryResult<R>> QueryAsync<Q, R>(Q message, TimeSpan? timeout = null, string? channel = null, IMessageHeader? messageHeader = null, IServiceChannelOptions? options = null, CancellationToken cancellationToken = new CancellationToken())
+        Task<QueryResult<R>> QueryAsync<Q, R>(Q message, TimeSpan? timeout = null, string? channel = null, IMessageHeader? messageHeader = null, IServiceChannelOptions? options = null, CancellationToken cancellationToken = new CancellationToken())
             where Q : class
             where R : class;
-        Task<IQueryResult<object>> QueryAsync<Q>(Q message, TimeSpan? timeout = null, string? channel = null, IMessageHeader? messageHeader = null, IServiceChannelOptions? options = null, CancellationToken cancellationToken = new CancellationToken())
+        Task<QueryResult<object>> QueryAsync<Q>(Q message, TimeSpan? timeout = null, string? channel = null, IMessageHeader? messageHeader = null, IServiceChannelOptions? options = null, CancellationToken cancellationToken = new CancellationToken())
             where Q : class;
         Task<ISubscription> SubscribeQueryResponseAsync<Q,R>(Func<IMessage<Q>,Task<QueryResponseMessage<R>>> messageRecieved, Action<Exception> errorRecieved, string? channel = null, string? group = null, bool ignoreMessageHeader = false, bool synchronous = false, IServiceChannelOptions? options = null, CancellationToken cancellationToken = new CancellationToken())
             where Q : class

Abstractions/Interfaces/Messages/IEncodedMessage.cs

@@ -0,0 +1,16 @@
+using MQContract.Messages;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace MQContract.Interfaces.Messages
+{
+    public interface IEncodedMessage
+    {
+        IMessageHeader Header { get; }
+        string MessageTypeID { get; }
+        ReadOnlyMemory<byte> Data { get; }
+    }
+}

Abstractions/Interfaces/Service/IMessageServiceConnection.cs

@@ -6,10 +6,10 @@ public interface IMessageServiceConnection
     {
         int? MaxMessageBodySize { get; }
         TimeSpan DefaultTimout { get; }
-        Task<IPingResult> PingAsync();
-        Task<ITransmissionResult> PublishAsync(IServiceMessage message, TimeSpan timeout, IServiceChannelOptions? options = null, CancellationToken cancellationToken = new CancellationToken());
-        Task<IServiceSubscription?> SubscribeAsync(Action<IRecievedServiceMessage> messageRecieved, Action<Exception> errorRecieved, string channel, string group, IServiceChannelOptions? options = null, CancellationToken cancellationToken = new CancellationToken());
-        Task<IServiceQueryResult> QueryAsync(IServiceMessage message, TimeSpan timeout, IServiceChannelOptions? options = null, CancellationToken cancellationToken = new CancellationToken());
-        Task<IServiceSubscription?> SubscribeQueryAsync(Func<IRecievedServiceMessage, Task<IServiceMessage>> messageRecieved, Action<Exception> errorRecieved, string channel, string group, IServiceChannelOptions? options = null, CancellationToken cancellationToken = new CancellationToken());
+        Task<PingResult> PingAsync();
+        Task<TransmissionResult> PublishAsync(ServiceMessage message, TimeSpan timeout, IServiceChannelOptions? options = null, CancellationToken cancellationToken = new CancellationToken());
+        Task<IServiceSubscription?> SubscribeAsync(Action<RecievedServiceMessage> messageRecieved, Action<Exception> errorRecieved, string channel, string group, IServiceChannelOptions? options = null, CancellationToken cancellationToken = new CancellationToken());
+        Task<ServiceQueryResult> QueryAsync(ServiceMessage message, TimeSpan timeout, IServiceChannelOptions? options = null, CancellationToken cancellationToken = new CancellationToken());
+        Task<IServiceSubscription?> SubscribeQueryAsync(Func<RecievedServiceMessage, Task<ServiceMessage>> messageRecieved, Action<Exception> errorRecieved, string channel, string group, IServiceChannelOptions? options = null, CancellationToken cancellationToken = new CancellationToken());
     }
 }

Abstractions/Messages/MessageHeader.cs

@@ -0,0 +1,31 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace MQContract.Messages
+{
+    public sealed class MessageHeader(IEnumerable<KeyValuePair<string,string>> data)
+        : IMessageHeader
+    {
+        public MessageHeader(Dictionary<string, string?>? headers)
+            : this(headers?.AsEnumerable().Select(pair=>new KeyValuePair<string,string>(pair.Key,pair.Value??string.Empty))?? []) { }
+
+        public MessageHeader(IMessageHeader? originalHeader, Dictionary<string, string?>? appendedHeader)
+            : this(
+                  (appendedHeader?.AsEnumerable().Select(pair => new KeyValuePair<string, string>(pair.Key, pair.Value??string.Empty))?? [])
+                  .Concat(originalHeader?.Keys.Select(k => new KeyValuePair<string, string>(k, originalHeader?[k]!))?? [])
+                  .DistinctBy(k => k.Key)
+            )
+        { }
+
+        public string? this[string tagKey] 
+            => data.Where(p=>Equals(p.Key,tagKey))
+            .Select(p=>p.Value)
+            .FirstOrDefault();
+
+        public IEnumerable<string> Keys 
+            => data.Select(p=>p.Key);
+    }
+}

Abstractions/Messages/PingResult.cs

@@ -0,0 +1,11 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace MQContract.Messages
+{
+    public record PingResult(string Host,string Version, TimeSpan ResponseTime)
+    {}
+}

Abstractions/Messages/QueryResult.cs

@@ -0,0 +1,13 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace MQContract.Messages
+{
+    public record QueryResult<T>(string ID,IMessageHeader Header,T? Result=null,string? Error=null)
+        : TransmissionResult(ID,Error)
+        where T : class
+    {}
+}

Abstractions/Messages/RecievedServiceMessage.cs

@@ -0,0 +1,14 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace MQContract.Messages
+{
+    public record RecievedServiceMessage(string ID, string MessageTypeID, string Channel, IMessageHeader Header, ReadOnlyMemory<byte> Data)
+        : ServiceMessage(ID,MessageTypeID,Channel,Header,Data)
+    { 
+        public DateTime RecievedTimestamp { get; private init; } = DateTime.Now;
+    }
+}

Abstractions/Messages/ServiceMessage.cs

@@ -0,0 +1,13 @@
+using MQContract.Interfaces.Messages;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace MQContract.Messages
+{
+    public record ServiceMessage(string ID,string MessageTypeID,string Channel,IMessageHeader Header,ReadOnlyMemory<byte> Data)
+        : IEncodedMessage
+    { }
+}

Abstractions/Messages/ServiceQueryResult.cs

@@ -0,0 +1,14 @@
+using MQContract.Interfaces.Messages;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace MQContract.Messages
+{
+    public record ServiceQueryResult(string ID, IMessageHeader Header,string MessageTypeID,ReadOnlyMemory<byte> Data)
+        : IEncodedMessage
+    {
+    }
+}

Abstractions/Messages/TransmissionResult.cs

@@ -0,0 +1,13 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace MQContract.Messages
+{
+    public record TransmissionResult(string ID,string? Error=null)
+    {
+        public bool IsError=>!string.IsNullOrWhiteSpace(Error);
+    }
+}