CommonConfig commonConfig = new CommonConfig(settings.config());
this.capacity = commonConfig.getMailBoxCapacity();
CommonConfig commonConfig = new CommonConfig(settings.config());
this.capacity = commonConfig.getMailBoxCapacity();
final MeteredMessageQueue queue = new MeteredMessageQueue(this.capacity, this.pushTimeOut);
monitorQueueSize(owner, queue);
return queue;
}
final MeteredMessageQueue queue = new MeteredMessageQueue(this.capacity, this.pushTimeOut);
monitorQueueSize(owner, queue);
return queue;
}
- static <T extends Metric> void registerMetric(scala.Option<ActorRef> owner, String metricName, T metric) {
+ static <T extends Metric> void registerMetric(final scala.Option<ActorRef> owner, final String metricName,
+ final T metric) {
registry.register(fullName, metric);
} catch (IllegalArgumentException e) {
// already registered - shouldn't happen here since we check above...
registry.register(fullName, metric);
} catch (IllegalArgumentException e) {
// already registered - shouldn't happen here since we check above...
}
}
public static class MeteredMessageQueue extends BoundedDequeBasedMailbox.MessageQueue {
private static final long serialVersionUID = 1L;
}
}
public static class MeteredMessageQueue extends BoundedDequeBasedMailbox.MessageQueue {
private static final long serialVersionUID = 1L;