@@ -60,12 +60,12 @@ public class GridModel {
60
60
public GridModel (EventBus events ) {
61
61
this .events = Require .nonNull ("Event bus" , events );
62
62
63
- events .addListener (NodeDrainStarted .listener (nodeId -> setAvailability (nodeId , DRAINING )));
64
- events .addListener (NodeDrainComplete .listener (this ::remove ));
65
- events .addListener (NodeRemovedEvent .listener (this ::remove ));
66
- events .addListener (NodeStatusEvent .listener (status -> refresh ( status ) ));
63
+ this . events .addListener (NodeDrainStarted .listener (nodeId -> setAvailability (nodeId , DRAINING )));
64
+ this . events .addListener (NodeDrainComplete .listener (this ::remove ));
65
+ this . events .addListener (NodeRemovedEvent .listener (this ::remove ));
66
+ this . events .addListener (NodeStatusEvent .listener (this :: refresh ));
67
67
68
- events .addListener (SessionClosedEvent .listener (this ::release ));
68
+ this . events .addListener (SessionClosedEvent .listener (this ::release ));
69
69
}
70
70
71
71
public GridModel add (NodeStatus node ) {
@@ -188,7 +188,7 @@ public boolean reserve(SlotId slotId) {
188
188
189
189
if (!UP .equals (node .availability )) {
190
190
LOG .warning (String .format (
191
- "Asked to reserve a slot on node %s, but not is %s" ,
191
+ "Asked to reserve a slot on node %s, but node is %s" ,
192
192
slotId .getOwningNodeId (),
193
193
node .availability ));
194
194
return false ;
0 commit comments