+3
-7
lines changedFilter options
+3
-7
lines changed Original file line number Diff line number Diff line change
@@ -25,9 +25,6 @@ class DefaultNewSessionQueueConfig extends MapConfig {
25
25
26
26
DefaultNewSessionQueueConfig() {
27
27
super(ImmutableMap.of(
28
-
"events", ImmutableMap.of(
29
-
"publish", "tcp://*:4442",
30
-
"subscribe", "tcp://*:4443"),
31
28
"server", ImmutableMap.of(
32
29
"port", 5559)));
33
30
}
Original file line number Diff line number Diff line change
@@ -38,7 +38,6 @@
38
38
import java.util.logging.Logger;
39
39
40
40
import static java.net.HttpURLConnection.HTTP_NO_CONTENT;
41
-
import static org.openqa.selenium.grid.config.StandardGridRoles.EVENT_BUS_ROLE;
42
41
import static org.openqa.selenium.grid.config.StandardGridRoles.HTTPD_ROLE;
43
42
import static org.openqa.selenium.grid.config.StandardGridRoles.SESSION_QUEUE_ROLE;
44
43
import static org.openqa.selenium.json.Json.JSON_UTF_8;
@@ -49,7 +48,7 @@
49
48
public class NewSessionQueueServer extends TemplateGridServerCommand {
50
49
51
50
private static final Logger LOG = Logger.getLogger(NewSessionQueueServer.class.getName());
52
-
private static final String LOCAL_NEWSESSION_QUEUE =
51
+
private static final String LOCAL_NEW_SESSION_QUEUE =
53
52
"org.openqa.selenium.grid.sessionqueue.local.LocalNewSessionQueue";
54
53
55
54
@Override
@@ -64,7 +63,7 @@ public String getDescription() {
64
63
65
64
@Override
66
65
public Set<Role> getConfigurableRoles() {
67
-
return ImmutableSet.of(EVENT_BUS_ROLE, HTTPD_ROLE, SESSION_QUEUE_ROLE, SESSION_QUEUE_ROLE);
66
+
return ImmutableSet.of(HTTPD_ROLE, SESSION_QUEUE_ROLE);
68
67
}
69
68
70
69
@Override
@@ -86,7 +85,7 @@ protected Config getDefaultConfig() {
86
85
protected Handlers createHandlers(Config config) {
87
86
NewSessionQueueOptions queueOptions = new NewSessionQueueOptions(config);
88
87
89
-
NewSessionQueue sessionQueue = queueOptions.getSessionQueue(LOCAL_NEWSESSION_QUEUE);
88
+
NewSessionQueue sessionQueue = queueOptions.getSessionQueue(LOCAL_NEW_SESSION_QUEUE);
90
89
91
90
return new Handlers(
92
91
Route.combine(
You can’t perform that action at this time.
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4