Queue
老邱 authored at 2016-12-20 11:46:24
836.00 B
X
namespace NewLife.Queue.Protocols.Brokers
{
    public enum BrokerRequestCode
    {
        SendMessage = 10,
        PullMessage = 11,
        BatchSendMessage = 12,
        ProducerHeartbeat = 100,
        ConsumerHeartbeat = 101,
        GetConsumerIdsForTopic = 102,
        UpdateQueueConsumeOffsetRequest = 103,
        GetBrokerStatisticInfo = 1000,
        GetTopicQueueInfo = 1001,
        GetTopicConsumeInfo = 1002,
        GetProducerList = 1003,
        GetConsumerList = 1004,
        CreateTopic = 1005,
        DeleteTopic = 1006,
        AddQueue = 1007,
        DeleteQueue = 1008,
        SetQueueProducerVisible = 1009,
        SetQueueConsumerVisible = 1010,
        SetQueueNextConsumeOffset = 1011,
        DeleteConsumerGroup = 1012,
        GetMessageDetail = 1013,
        GetLastestMessages = 1014
    }
}