| 1234567891011121314151617181920212223242526272829 |
- using System;
- using ETModel;
- namespace ETHotfix
- {
- /// <summary>
- /// gate session类型的Mailbox,收到的actor消息直接转发给客户端
- /// </summary>
- [MailboxHandler(MailboxType.GateSession)]
- public class MailboxGateSessionHandler : IMailboxHandler
- {
- public async ETTask Handle(Session session, Entity entity, object actorMessage)
- {
- try
- {
- IActorMessage iActorMessage = actorMessage as IActorMessage;
- // 发送给客户端
- Session clientSession = entity as Session;
- iActorMessage.ActorId = 0;
- clientSession.Send(iActorMessage);
- await ETTask.CompletedTask;
- }
- catch (Exception e)
- {
- Log.Error(e);
- }
- }
- }
- }
|