xiaoou
e9616125ce
6 major server modules (PdkFriendServer/GlobalSever/ServerCore/GameModule/GameNetModule) + game logic (GameFix/GameDAL/ServerData) + network layer (NetWorkMessage) + data layer (ObjectModel) + utilities (MrWu/Core/Config/CloudAPI/dll) + adapters (zyxAdapter/base) .NET 8.0 C# solution, 16 projects, 958 source files
69 lines
1.4 KiB
C#
69 lines
1.4 KiB
C#
/********************************
|
|
*
|
|
* 作者:吴隆健
|
|
* 创建时间: 2019/6/25 11:13:36
|
|
*
|
|
********************************/
|
|
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using RabbitMQ.Client;
|
|
|
|
namespace MrWu.RabbitMQ {
|
|
|
|
/// <summary>
|
|
/// 消费者
|
|
/// </summary>
|
|
public class Consumer {
|
|
|
|
/// <summary>
|
|
/// 消费者队列
|
|
/// </summary>
|
|
public string queue;
|
|
|
|
/// <summary>
|
|
/// 是否不需要确认
|
|
/// </summary>
|
|
public bool noAck = true;
|
|
|
|
/// <summary>
|
|
/// 消息者标记
|
|
/// </summary>
|
|
public string consumertag {
|
|
get;
|
|
internal set;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 消费者同时接收的消息数量
|
|
/// </summary>
|
|
public ushort prefetchCount = 0;
|
|
|
|
/// <summary>
|
|
/// 是否不接收本地
|
|
/// </summary>
|
|
public bool noLoacl;
|
|
|
|
/// <summary>
|
|
/// 是否独占
|
|
/// </summary>
|
|
public bool exclusive;
|
|
|
|
/// <summary>
|
|
/// 额外参数
|
|
/// </summary>
|
|
public IDictionary<string, object> arguments;
|
|
|
|
/// <summary>
|
|
/// 消费者信道
|
|
/// </summary>
|
|
internal IModel channel;
|
|
|
|
/// <summary>
|
|
/// 接收到消息
|
|
/// </summary>
|
|
public MessageHandle Receive;
|
|
|
|
}
|
|
}
|