public class ConditionalProbe {
private final ActorRef actorRef;
- private final Predicate predicate;
+ private final Predicate<Object> predicate;
Logger log = LoggerFactory.getLogger(ConditionalProbe.class);
- public ConditionalProbe(ActorRef actorRef, Predicate predicate) {
+ public ConditionalProbe(ActorRef actorRef, Predicate<Object> predicate) {
this.actorRef = actorRef;
this.predicate = predicate;
}
- public void tell(Object message, ActorRef sender){
- if(predicate.apply(message)) {
+ public void tell(Object message, ActorRef sender) {
+ if (predicate.apply(message)) {
log.info("sending message to probe {}", message);
actorRef.tell(message, sender);
}