Browse Source

Shielding unsupport code.

master
yangxiaodong 7 years ago
parent
commit
14320e86e2
1 changed files with 21 additions and 21 deletions
  1. +21
    -21
      src/DotNetCore.CAP.Kafka/CAP.SubscribeAttribute.cs

+ 21
- 21
src/DotNetCore.CAP.Kafka/CAP.SubscribeAttribute.cs View File

@@ -6,35 +6,35 @@ namespace DotNetCore.CAP
public class CapSubscribeAttribute : TopicAttribute
{
public CapSubscribeAttribute(string name)
: this(name, 0)
: 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)
// : this(name, partition, 0)
//{
//}

/// <summary>
/// Not support
/// </summary>
public CapSubscribeAttribute(string name, int partition, long offset)
: base(name)
{
Offset = offset;
Partition = partition;
}
///// <summary>
///// Not support
///// </summary>
//public CapSubscribeAttribute(string name, int partition, long offset)
// : base(name)
//{
// Offset = offset;
// Partition = partition;
//}

public int Partition { get; }
//public int Partition { get; }

public long Offset { get; }
//public long Offset { get; }

public bool IsPartition => Partition == 0;
//public bool IsPartition => Partition == 0;

public bool IsOffset => Offset == 0;
//public bool IsOffset => Offset == 0;

public override string ToString()
{


Loading…
Cancel
Save