We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b09ab9f commit a4c3e3bCopy full SHA for a4c3e3b
java/src/org/openqa/selenium/grid/distributor/local/LocalDistributor.java
@@ -252,8 +252,14 @@ private void register(NodeStatus status) {
252
public LocalDistributor add(Node node) {
253
Require.nonNull("Node", node);
254
255
- nodes.put(node.getId(), node);
256
- model.add(node.getStatus());
+ // An exception occurs if Node heartbeat has started but the server is not ready.
+ // Unhandled exception blocks the event-bus thread from processing any event henceforth.
257
+ try {
258
+ model.add(node.getStatus());
259
+ nodes.put(node.getId(), node);
260
+ } catch (Exception e){
261
+ return this;
262
+ }
263
264
// Extract the health check
265
Runnable runnableHealthCheck = asRunnableHealthCheck(node);
0 commit comments