|
@@ -5,16 +5,16 @@ namespace Hotfix
|
|
|
{
|
|
{
|
|
|
public abstract class AMHandler<Message> : IMHandler where Message: AMessage
|
|
public abstract class AMHandler<Message> : IMHandler where Message: AMessage
|
|
|
{
|
|
{
|
|
|
- protected abstract void Run(Message message);
|
|
|
|
|
|
|
+ protected abstract void Run(Session session, Message message);
|
|
|
|
|
|
|
|
- public void Handle(AMessage msg)
|
|
|
|
|
|
|
+ public void Handle(Session session, AMessage msg)
|
|
|
{
|
|
{
|
|
|
Message message = msg as Message;
|
|
Message message = msg as Message;
|
|
|
if (message == null)
|
|
if (message == null)
|
|
|
{
|
|
{
|
|
|
Log.Error($"消息类型转换错误: {msg.GetType().Name} to {typeof(Message).Name}");
|
|
Log.Error($"消息类型转换错误: {msg.GetType().Name} to {typeof(Message).Name}");
|
|
|
}
|
|
}
|
|
|
- this.Run(message);
|
|
|
|
|
|
|
+ this.Run(session, message);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
public Type GetMessageType()
|
|
public Type GetMessageType()
|