From 0a1d6f802ef8d74363bb5cbed0a4a63bcc55da9b Mon Sep 17 00:00:00 2001 From: Savorboard Date: Wed, 13 Mar 2019 11:29:21 +0800 Subject: [PATCH] Move the every CapSubscribeAttribute to the core project --- .../CAP.SubscribeAttribute.cs | 50 ------------------- .../CAP.SubscribeAttribute.cs | 18 ------- .../CAP.SubscribeAttribute.cs | 2 +- 3 files changed, 1 insertion(+), 69 deletions(-) delete mode 100644 src/DotNetCore.CAP.Kafka/CAP.SubscribeAttribute.cs delete mode 100644 src/DotNetCore.CAP.RabbitMQ/CAP.SubscribeAttribute.cs rename src/{DotNetCore.CAP.AzureServiceBus => DotNetCore.CAP}/CAP.SubscribeAttribute.cs (90%) diff --git a/src/DotNetCore.CAP.Kafka/CAP.SubscribeAttribute.cs b/src/DotNetCore.CAP.Kafka/CAP.SubscribeAttribute.cs deleted file mode 100644 index ad4021e..0000000 --- a/src/DotNetCore.CAP.Kafka/CAP.SubscribeAttribute.cs +++ /dev/null @@ -1,50 +0,0 @@ -// Copyright (c) .NET Core Community. All rights reserved. -// Licensed under the MIT License. See License.txt in the project root for license information. - -using DotNetCore.CAP.Abstractions; - -// ReSharper disable once CheckNamespace -namespace DotNetCore.CAP -{ - /// - /// An attribute for subscribe Kafka messages. - /// - public class CapSubscribeAttribute : TopicAttribute - { - public CapSubscribeAttribute(string name) - : base(name) - { - } - - ///// - ///// Not support - ///// - //public CapSubscribeAttribute(string name, int partition) - // : this(name, partition, 0) - //{ - //} - - ///// - ///// Not support - ///// - //public CapSubscribeAttribute(string name, int partition, long offset) - // : base(name) - //{ - // Offset = offset; - // Partition = partition; - //} - - //public int Partition { get; } - - //public long Offset { get; } - - //public bool IsPartition => Partition == 0; - - //public bool IsOffset => Offset == 0; - - public override string ToString() - { - return Name; - } - } -} \ No newline at end of file diff --git a/src/DotNetCore.CAP.RabbitMQ/CAP.SubscribeAttribute.cs b/src/DotNetCore.CAP.RabbitMQ/CAP.SubscribeAttribute.cs deleted file mode 100644 index a09a8d6..0000000 --- a/src/DotNetCore.CAP.RabbitMQ/CAP.SubscribeAttribute.cs +++ /dev/null @@ -1,18 +0,0 @@ -// Copyright (c) .NET Core Community. All rights reserved. -// Licensed under the MIT License. See License.txt in the project root for license information. - -using DotNetCore.CAP.Abstractions; - -// ReSharper disable once CheckNamespace -namespace DotNetCore.CAP -{ - /// - /// An attribute for subscribe RabbitMQ messages. - /// - public class CapSubscribeAttribute : TopicAttribute - { - public CapSubscribeAttribute(string name) : base(name) - { - } - } -} \ No newline at end of file diff --git a/src/DotNetCore.CAP.AzureServiceBus/CAP.SubscribeAttribute.cs b/src/DotNetCore.CAP/CAP.SubscribeAttribute.cs similarity index 90% rename from src/DotNetCore.CAP.AzureServiceBus/CAP.SubscribeAttribute.cs rename to src/DotNetCore.CAP/CAP.SubscribeAttribute.cs index e745555..bd3e1e5 100644 --- a/src/DotNetCore.CAP.AzureServiceBus/CAP.SubscribeAttribute.cs +++ b/src/DotNetCore.CAP/CAP.SubscribeAttribute.cs @@ -7,7 +7,7 @@ using DotNetCore.CAP.Abstractions; namespace DotNetCore.CAP { /// - /// An attribute for subscribe Kafka messages. + /// An attribute for subscribe event bus message. /// public class CapSubscribeAttribute : TopicAttribute {