Page History
...
SmallestMailbox
메시지가 덜 쌓인(큐 가용성이 높은) 라우티에 우선적으로 메시지를 보냅니다.
BalancingRouting
MailBox와 유사하게 작동하지만, 바쁜 라우트에서 유휴 라우트로 작업을 재분배하려고 덜바쁜 유휴 라우티로 작업 분배하려고 시도하는 라우터.
액터 코드
| Code Block |
|---|
@Override
public Receive createReceive() {
return receiveBuilder()
.match(
WorkMessage.class,
message -> {
String pathName = self().path().name();
messageCount++;
log.info("[{}] ChildActor InMessage : {} - {}", pathName, message, messageCount);
// Routee가 a일때 임의 지연
if(pathName.equals("$a")){
log.info("SomeBlocking - 300ms");
Thread.sleep(300);
}
_probe.tell("completed", ActorRef.noSender());
})
.build();
} |
...