Queue
老邱 authored at 2016-12-20 11:46:24
745.00 B
X
using System;

namespace NewLife.Queue.Protocols.Brokers.Requests
{
    [Serializable]
    public class UpdateQueueOffsetRequest
    {
        public string ConsumerGroup { get; set; }
        public MessageQueue MessageQueue { get; set; }
        public long QueueOffset { get; set; }

        public UpdateQueueOffsetRequest(string consumerGroup, MessageQueue messageQueue, long queueOffset)
        {
            ConsumerGroup = consumerGroup;
            MessageQueue = messageQueue;
            QueueOffset = queueOffset;
        }

        public override string ToString()
        {
            return string.Format("[ConsumerGroup:{0}, MessageQueue:{1}, QueueOffset:{2}]", ConsumerGroup, MessageQueue, QueueOffset);
        }
    }
}