Actor메시지는 일반적으로 전송시 순서가 보장이 되지만

MailBox의 경우 동시에 보낸 메시지중 우선으로 처리해야할 메시지에대해

정의가 가능합니다.

using Akka.Actor;
using Akka.Event;
using Akka.Dispatch;    

//namespace ServiceA.STUDY
	public class Issue
    {
        public bool IsSecurityFlaw;
        public bool IsBug;
        public string Message;

        public Issue(string message, bool isBug)
        {
            Message = message;
            IsBug = isBug;
            IsSecurityFlaw = !isBug;
        }

    }

    public class IssueTrackerMailbox : UnboundedPriorityMailbox
    {        
        public IssueTrackerMailbox(Settings setting , Akka.Configuration.Config config) : base(setting, config)
        {            
        }
        

        protected override int PriorityGenerator(object message)
        {
            var issue = message as Issue;

            if (issue != null)
            {
                if (issue.IsSecurityFlaw)
                    return 0;

                if (issue.IsBug)
                    return 1;
            }

            return 2;
        }
    }

    public class MailBoxActor : ReceiveActor
    {
        private ILoggingAdapter log = Context.GetLogger();

        public MailBoxActor()
        {
            Receive<Issue>(issue => {
                log.Info("IssueInfo : Message:{0} IsSecurityFlaw:{1} IsBug:{2} ", issue.Message, issue.IsSecurityFlaw, issue.IsBug);
            });
        }

    }

#특정한 액터에 MailBox 메시지 처리기를 사용하겠다고 설정을 합니다.


my-custom-mailbox {
              mailbox-type : "ServiceA.STUDY.IssueTrackerMailbox, ServiceA"
            }


actor.deployment {
                /mymailbox {
                mailbox = my-custom-mailbox
                }
              }

            var mailboxOpt = Props.Create<MailBoxActor>().WithMailbox("my-custom-mailbox");
            var actor = actorSystem.ActorOf(mailboxOpt, "mymailbox");
            Issue msg1 = new Issue("test1",true);
            Issue msg2 = new Issue("test2", false);
            Issue msg3 = new Issue("test3", true);
            Issue msg4 = new Issue("test4", true);
            Issue msg5 = new Issue("test5", false);
            actor.Tell(msg1);
            actor.Tell(msg2);
            actor.Tell(msg3);
            actor.Tell(msg4);
            actor.Tell(msg5);

Image Added