Merge pull request #96 from twino-framework/v3

3.7.0

src/Samples/Sample.Route.Server/Program.cs

@@ -5,6 +5,7 @@
 using Twino.MQ.Data;
 using Twino.MQ.Events;
 using Twino.MQ.Routing;
+using Twino.Protocols.TMQ;
 using Twino.Server;
 
 namespace Sample.Route.Server

src/Samples/Sample.Server/Program.cs

@@ -3,6 +3,7 @@
 using Twino.MQ.Data;
 using Twino.MQ.Queues;
 using Twino.MQ.Routing;
+using Twino.Protocols.TMQ;
 using Twino.Server;
 
 namespace Sample.Server

src/Twino.Client.TMQ/Annotations/QueueTagAttribute.cs

@@ -0,0 +1,24 @@
+using System;
+
+namespace Twino.Client.TMQ.Annotations
+{
+    /// <summary>
+    /// Used when queue is created with first push
+    /// </summary>
+    [AttributeUsage(AttributeTargets.Class)]
+    public class QueueTagAttribute : Attribute
+    {
+        /// <summary>
+        /// The Queue Tag for the type
+        /// </summary>
+        public string Tag { get; }
+
+        /// <summary>
+        /// Creates new Queue Tag attribute
+        /// </summary>
+        public QueueTagAttribute(string tag)
+        {
+            Tag = tag;
+        }
+    }
+}

src/Twino.Client.TMQ/Annotations/Resolvers/TypeDeliveryDescriptor.cs

@@ -36,6 +36,11 @@ public class TypeDeliveryDescriptor
         /// </summary>
         public MessagingQueueStatus? QueueStatus { get; set; }
 
+        /// <summary>
+        /// If queue is created with a message push and that value is not null, queue will be created with that Tag
+        /// </summary>
+        public string Tag { get; set; }
+
         /// <summary>
         /// Headers for delivery descriptor of type
         /// </summary>
@@ -157,6 +162,9 @@ public TmqMessage CreateMessage(MessageType type, string overrideTargetName, ush
             if (QueueStatus.HasValue)
                 message.AddHeader(TmqHeaders.QUEUE_STATUS, QueueStatus.Value.ToString().ToLower());
 
+            if (!string.IsNullOrEmpty(Tag))
+                message.AddHeader(TmqHeaders.QUEUE_TAG, Tag);
+
             foreach (KeyValuePair<string, string> pair in Headers)
                 message.AddHeader(pair.Key, pair.Value);
 

src/Twino.Client.TMQ/Annotations/Resolvers/TypeDeliveryResolver.cs

@@ -125,6 +125,10 @@ private void ResolveBase(Type type, TypeDeliveryDescriptor descriptor)
             if (qsa != null)
                 descriptor.QueueStatus = qsa.Status;
 
+            QueueTagAttribute qta = type.GetCustomAttribute<QueueTagAttribute>(true);
+            if (qta != null)
+                descriptor.Tag = qta.Tag;
+
             IEnumerable<MessageHeaderAttribute> headerAttributes = type.GetCustomAttributes<MessageHeaderAttribute>(true);
             foreach (MessageHeaderAttribute headerAttribute in headerAttributes)
                 descriptor.Headers.Add(new KeyValuePair<string, string>(headerAttribute.Key, headerAttribute.Value));