using System;
using System.Collections.Generic;
namespace NewLife.Queue.Protocols.Brokers
{
[Serializable]
public class ConsumerHeartbeatData
{
public string ConsumerId { get; private set; }
public string GroupName { get; private set; }
public IEnumerable<string> SubscriptionTopics { get; private set; }
public IEnumerable<MessageQueueEx> ConsumingQueues { get; private set; }
public ConsumerHeartbeatData(string consumerId, string groupName, IEnumerable<string> subscriptionTopics, IEnumerable<MessageQueueEx> consumingQueues)
{
ConsumerId = consumerId;
GroupName = groupName;
SubscriptionTopics = subscriptionTopics;
ConsumingQueues = consumingQueues;
}
public override string ToString()
{
return string.Format("[ConsumerId:{0}, GroupName:{1}, SubscriptionTopics:{2}, ConsumingQueues:{3}]", ConsumerId, GroupName, string.Join("|", SubscriptionTopics), string.Join("|", ConsumingQueues));
}
}
}
|