|
@@ -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 |
|
|
|
|
|
{ |
|
|
|
|
|
/// <summary> |
|
|
|
|
|
/// An attribute for subscribe Kafka messages. |
|
|
|
|
|
/// </summary> |
|
|
|
|
|
public class CapSubscribeAttribute : TopicAttribute |
|
|
|
|
|
{ |
|
|
|
|
|
public CapSubscribeAttribute(string name) |
|
|
|
|
|
: base(name) |
|
|
|
|
|
{ |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
///// <summary> |
|
|
|
|
|
///// Not support |
|
|
|
|
|
///// </summary> |
|
|
|
|
|
//public CapSubscribeAttribute(string name, int partition) |
|
|
|
|
|
// : this(name, partition, 0) |
|
|
|
|
|
//{ |
|
|
|
|
|
//} |
|
|
|
|
|
|
|
|
|
|
|
///// <summary> |
|
|
|
|
|
///// Not support |
|
|
|
|
|
///// </summary> |
|
|
|
|
|
//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; |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|