How to use clearQueue method of org.openqa.selenium.grid.sessionqueue.NewSessionQueue class

Best Selenium code snippet using org.openqa.selenium.grid.sessionqueue.NewSessionQueue.clearQueue

Source:NewSessionQueuerTest.java

...173  @Test174  public void shouldBeClearQueue() {175    RequestId requestId = new RequestId(UUID.randomUUID());176    sessionQueue.offerLast(request, requestId);177    int count = local.clearQueue();178    assertEquals(count, 1);179    assertFalse(local.remove().isPresent());180  }181  @Test182  public void shouldBeClearQueueRemotely() {183    RequestId requestId = new RequestId(UUID.randomUUID());184    sessionQueue.offerLast(request, requestId);185    int count = remote.clearQueue();186    assertEquals(count, 1);187    assertFalse(remote.remove().isPresent());188  }189  @Test190  public void shouldBeClearQueueAndFireRejectedEvent() {191    AtomicBoolean result = new AtomicBoolean(false);192    RequestId requestId = new RequestId(UUID.randomUUID());193    bus.addListener(NewSessionRejectedEvent.listener(response ->194                                                         result.set(response.getRequestId()195                                                                        .equals(requestId))));196    sessionQueue.offerLast(request, requestId);197    int count = remote.clearQueue();198    assertThat(result.get()).isTrue();199    assertEquals(count, 1);200    assertFalse(remote.remove().isPresent());201  }202  @Test203  public void shouldBeAbleToRemoveFromQueueRemotely() {204    Optional<HttpRequest> httpRequest = remote.remove();205    assertFalse(httpRequest.isPresent());206  }207  @Test208  public void shouldBeAbleToAddAgainToQueue() {209    boolean added = local.retryAddToQueue(request, new RequestId(UUID.randomUUID()));210    assertTrue(added);211  }212  @Test213  public void shouldBeAbleToAddAgainToQueueRemotely() {214    HttpRequest request = createRequest(payload, POST, "/se/grid/newsessionqueuer/session");215    boolean added = remote.retryAddToQueue(request, new RequestId(UUID.randomUUID()));216    assertTrue(added);217  }218  @Test219  public void shouldBeAbleToRetryRequest() {220    AtomicBoolean isPresent = new AtomicBoolean(false);221    AtomicBoolean retrySuccess = new AtomicBoolean(false);222    bus.addListener(NewSessionRequestEvent.listener(reqId -> {223      // Keep a count of event fired224      count++;225      Optional<HttpRequest> sessionRequest = this.remote.remove();226      isPresent.set(sessionRequest.isPresent());227      if (count == 1) {228        retrySuccess.set(remote.retryAddToQueue(sessionRequest.get(), reqId));229      }230      // Only if it was retried after an interval, the count is 2231      if (count == 2) {232        ImmutableCapabilities capabilities = new ImmutableCapabilities("browserName", "chrome");233        try {234          SessionId sessionId = new SessionId("123");235          Session session =236              new Session(237                  sessionId,238                  new URI("http://example.com"),239                  caps,240                  capabilities,241                  Instant.now());242          CreateSessionResponse sessionResponse = new CreateSessionResponse(243              session,244              JSON.toJson(245                  ImmutableMap.of(246                      "value", ImmutableMap.of(247                          "sessionId", sessionId,248                          "capabilities", capabilities)))249                  .getBytes(UTF_8));250          NewSessionResponse newSessionResponse =251              new NewSessionResponse(reqId, sessionResponse.getSession(),252                                     sessionResponse.getDownstreamEncodedResponse());253          bus.fire(new NewSessionResponseEvent(newSessionResponse));254        } catch (URISyntaxException e) {255          bus.fire(256              new NewSessionRejectedEvent(257                  new NewSessionErrorResponse(new RequestId(UUID.randomUUID()), "Error")));258        }259      }260    }));261    HttpResponse httpResponse = remote.addToQueue(request);262    assertThat(isPresent.get()).isTrue();263    assertThat(retrySuccess.get()).isTrue();264    assertEquals(httpResponse.getStatus(), HTTP_OK);265  }266  @Test267  public void shouldBeAbleToHandleMultipleSessionRequestsAtTheSameTime() {268    bus.addListener(NewSessionRequestEvent.listener(reqId -> {269      Optional<HttpRequest> sessionRequest = this.local.remove();270      ImmutableCapabilities capabilities = new ImmutableCapabilities("browserName", "chrome");271      try {272        SessionId sessionId = new SessionId(UUID.randomUUID());273        Session session =274            new Session(275                sessionId,276                new URI("http://example.com"),277                caps,278                capabilities,279                Instant.now());280        CreateSessionResponse sessionResponse = new CreateSessionResponse(281            session,282            JSON.toJson(283                ImmutableMap.of(284                    "value", ImmutableMap.of(285                        "sessionId", sessionId,286                        "capabilities", capabilities)))287                .getBytes(UTF_8));288        NewSessionResponse newSessionResponse =289            new NewSessionResponse(reqId, sessionResponse.getSession(),290                                   sessionResponse.getDownstreamEncodedResponse());291        bus.fire(new NewSessionResponseEvent(newSessionResponse));292      } catch (URISyntaxException e) {293        bus.fire(294            new NewSessionRejectedEvent(295                new NewSessionErrorResponse(new RequestId(UUID.randomUUID()), "Error")));296      }297    }));298    ExecutorService executor = Executors.newFixedThreadPool(2);299    Callable<HttpResponse> callable = () -> remote.addToQueue(request);300    Future<HttpResponse> firstRequest = executor.submit(callable);301    Future<HttpResponse> secondRequest = executor.submit(callable);302    try {303      HttpResponse firstResponse = firstRequest.get(30, TimeUnit.SECONDS);304      HttpResponse secondResponse = secondRequest.get(30, TimeUnit.SECONDS);305      String firstResponseContents = Contents.string(firstResponse);306      String secondResponseContents = Contents.string(secondResponse);307      assertEquals(firstResponse.getStatus(), HTTP_OK);308      assertEquals(secondResponse.getStatus(), HTTP_OK);309      assertNotEquals(firstResponseContents, secondResponseContents);310    } catch (InterruptedException | ExecutionException | TimeoutException e) {311      fail("Could not create session");312    }313    executor.shutdown();314  }315  @Test316  public void shouldBeAbleToTimeoutARequestOnRetry() {317    Tracer tracer = DefaultTestTracer.createTracer();318    LocalNewSessionQueue sessionQueue = new LocalNewSessionQueue(319        tracer,320        bus,321        Duration.ofSeconds(4),322        Duration.ofSeconds(2));323    local = new LocalNewSessionQueuer(tracer, bus, sessionQueue);324    HttpClient client = new PassthroughHttpClient(local);325    remote = new RemoteNewSessionQueuer(tracer, client);326    HttpRequest request = createRequest(payload, POST, "/session");327    request.addHeader(SESSIONREQUEST_TIMESTAMP_HEADER,328                      Long.toString(1539091064));329    AtomicInteger count = new AtomicInteger();330    bus.addListener(NewSessionRequestEvent.listener(reqId -> {331      // Add to front of queue, when retry is triggered it will check if request timed out332      count.incrementAndGet();333      remote.retryAddToQueue(request, reqId);334    }));335    HttpResponse httpResponse = remote.addToQueue(request);336    assertEquals(count.get(),1);337    assertEquals(httpResponse.getStatus(), HTTP_INTERNAL_ERROR);338  }339  @Test340  public void shouldBeAbleToTimeoutARequestOnPoll() {341    Tracer tracer = DefaultTestTracer.createTracer();342    LocalNewSessionQueue sessionQueue = new LocalNewSessionQueue(343        tracer,344        bus,345        Duration.ofSeconds(4),346        Duration.ofSeconds(0));347    local = new LocalNewSessionQueuer(tracer, bus, sessionQueue);348    HttpClient client = new PassthroughHttpClient(local);349    remote = new RemoteNewSessionQueuer(tracer, client);350    AtomicBoolean isPresent = new AtomicBoolean();351    bus.addListener(NewSessionRequestEvent.listener(reqId -> {352      Optional<HttpRequest> request = remote.remove();353      isPresent.set(request.isPresent());354      bus.fire(355          new NewSessionRejectedEvent(356              new NewSessionErrorResponse(reqId, "Error")));357    }));358    HttpResponse httpResponse = remote.addToQueue(request);359    assertEquals(httpResponse.getStatus(), HTTP_INTERNAL_ERROR);360    assertThat(isPresent.get()).isFalse();361  }362  @Test363  public void shouldBeAbleToClearQueueAndRejectMultipleRequests() {364    ExecutorService executor = Executors.newFixedThreadPool(2);365    Callable<HttpResponse> callable = () -> remote.addToQueue(request);366    Future<HttpResponse> firstRequest = executor.submit(callable);367    Future<HttpResponse> secondRequest = executor.submit(callable);368    int count = 0;369    while (count < 2) {370      count += remote.clearQueue();371    }372    try {373      HttpResponse firstResponse = firstRequest.get(30, TimeUnit.SECONDS);374      HttpResponse secondResponse = secondRequest.get(30, TimeUnit.SECONDS);375      assertEquals(firstResponse.getStatus(), HTTP_INTERNAL_ERROR);376      assertEquals(secondResponse.getStatus(), HTTP_INTERNAL_ERROR);377    } catch (InterruptedException | ExecutionException | TimeoutException e) {378      fail("Could not create session");379    }380    executor.shutdown();381  }382  private HttpRequest createRequest(NewSessionPayload payload, HttpMethod httpMethod, String uri) {383    StringBuilder builder = new StringBuilder();384    try {...

Source:RemoteNewSessionQueue.java

...134    HttpTracing.inject(tracer, tracer.getCurrentContext(), upstream);135    client.with(addSecret).execute(upstream);136  }137  @Override138  public int clearQueue() {139    HttpRequest upstream = new HttpRequest(DELETE, "/se/grid/newsessionqueue/queue");140    HttpTracing.inject(tracer, tracer.getCurrentContext(), upstream);141    HttpResponse response = client.with(addSecret).execute(upstream);142    return Values.get(response, Integer.class);143  }144  @Override145  public List<SessionRequestCapability> getQueueContents() {146    HttpRequest upstream = new HttpRequest(GET, "/se/grid/newsessionqueue/queue");147    HttpTracing.inject(tracer, tracer.getCurrentContext(), upstream);148    HttpResponse response = client.execute(upstream);149    return Values.get(response, QUEUE_CONTENTS_TYPE);150  }151  @Override152  public boolean isReady() {...

Source:RemoteNewSessionQueuer.java

...102    }103    return Optional.empty();104  }105  @Override106  public int clearQueue() {107    HttpRequest upstream = new HttpRequest(DELETE, "/se/grid/newsessionqueuer/queue");108    HttpTracing.inject(tracer, tracer.getCurrentContext(), upstream);109    HttpResponse response = client.with(addSecret).execute(upstream);110    return Values.get(response, Integer.class);111  }112  @Override113  public List<Object> getQueueContents() {114    HttpRequest upstream = new HttpRequest(GET, "/se/grid/newsessionqueuer/queue");115    HttpTracing.inject(tracer, tracer.getCurrentContext(), upstream);116    HttpResponse response = client.execute(upstream);117    return Values.get(response, List.class);118  }119  @Override120  public boolean isReady() {...

Source:NewSessionQueue.java

...89  public abstract boolean retryAddToQueue(SessionRequest request);90  public abstract Optional<SessionRequest> remove(RequestId reqId);91  public abstract Optional<SessionRequest> getNextAvailable(Set<Capabilities> stereotypes);92  public abstract void complete(RequestId reqId, Either<SessionNotCreatedException, CreateSessionResponse> result);93  public abstract int clearQueue();94  public abstract List<SessionRequestCapability> getQueueContents();95  @Override96  public boolean matches(HttpRequest req) {97    return routes.matches(req);98  }99  @Override100  public HttpResponse execute(HttpRequest req) {101    return routes.execute(req);102  }103}...

Source:LocalNewSessionQueuer.java

...70  public Optional<HttpRequest> remove() {71    return sessionRequests.poll();72  }73  @Override74  public int clearQueue() {75    return sessionRequests.clear();76  }77  @Override78  public boolean isReady() {79    return bus.isReady();80  }81}...

Source:ClearSessionQueue.java

...38  public HttpResponse execute(HttpRequest req) {39    Span span = newSpanAsChildOf(tracer, req, "sessionqueue.clear");40    HTTP_REQUEST.accept(span, req);41    try {42      int value = newSessionQueue.clearQueue();43      span.setAttribute("cleared", value);44      HttpResponse response = new HttpResponse();45      if (value != 0) {46        response.setContent(47          asJson(ImmutableMap.of(48            "value", value,49            "message", "Cleared the new session request queue",50            "cleared_requests", value)));51      } else {52        response.setContent(53          asJson(ImmutableMap.of(54            "value", value,55            "message",56            "New session request queue empty. Nothing to clear.")));...

clearQueue

Using AI Code Generation

1import org.openqa.selenium.grid.sessionqueue.NewSessionQueue;2import org.openqa.selenium.grid.sessionqueue.config.SessionQueueOptions;3import org.openqa.selenium.remote.http.HttpClient;4import org.openqa.selenium.remote.tracing.Tracer;5import org.openqa.selenium.remote.tracing.config.TracerOptions;6import org.openqa.selenium.remote.tracing.opentelemetry.OpenTelemetryTracer;7import java.net.URI;8import java.net.URISyntaxException;9public class ClearQueue {10    public static void main(String[] args) throws URISyntaxException {11        Tracer tracer = new OpenTelemetryTracer(new TracerOptions());12        SessionQueueOptions options = new SessionQueueOptions();13        NewSessionQueue queue = new NewSessionQueue(tracer, client, options);14        queue.clearQueue();15    }16}

clearQueue

Using AI Code Generation

1import org.openqa.selenium.grid.sessionqueue.NewSessionQueue;2public class ClearQueue {3    public static void main(String[] args) {4        NewSessionQueue queue = new NewSessionQueue();5        queue.clearQueue();6    }7}8	at org.openqa.selenium.grid.sessionqueue.NewSessionQueue.clearQueue(NewSessionQueue.java:25)9	at ClearQueue.main(ClearQueue.java:9)

clearQueue

Using AI Code Generation

1package com.seleniumgrid;2import org.openqa.selenium.grid.config.MapConfig;3import org.openqa.selenium.grid.config.MemoizedConfig;4import org.openqa.selenium.grid.config.TomlConfig;5import org.openqa.selenium.grid.config.TomlConfigTest;6import org.openqa.selenium.grid.data.Session;7import org.openqa.selenium.grid.data.SessionId;8import org.openqa.selenium.grid.distributor.Distributor;9import org.openqa.selenium.grid.distributor.local.LocalDistributor;10import org.openqa.selenium.grid.node.local.LocalNode;11import org.openqa.selenium.grid.sessionqueue.NewSessionQueue;12import org.openqa.selenium.grid.sessionqueue.config.SessionQueueOptions;13import org.openqa.selenium.grid.sessionqueue.local.LocalNewSessionQueue;14import org.openqa.selenium.grid.sessionqueue.remote.RemoteNewSessionQueue;15import org.openqa.selenium.grid.web.Routable;16import org.openqa.selenium.grid.web.Routes;17import org.openqa.selenium.net.PortProber;18import org.openqa.selenium.remote.http.HttpClient;19import org.openqa.selenium.remote.http.HttpMethod;20import org.openqa.selenium.remote.http.HttpRequest;21import org.openqa.selenium.remote.http.HttpResponse;22import org.openqa.selenium.remote.tracing.Tracer;23import org.openqa.selenium.remote.tracing.noop.NoOpTracer;24import java.io.IOException;25import java.net.URI;26import java.net.URISyntaxException;27import java.time.Duration;28import java.util.UUID;29public class ClearQueue {30  public static void main(String[] args) throws URISyntaxException, IOException {31    Tracer tracer = NoOpTracer.getInstance();32    HttpClient.Factory clientFactory = HttpClient.Factory.createDefault();33    int nodePort = PortProber.findFreePort();34      .add(caps -> true, new FakeSession())35      .build();36    int distributorPort = PortProber.findFreePort();37      .add(node)38      .build();39    int queuePort = PortProber.findFreePort();40    MapConfig config = new MapConfig();41    config.set("session-queue", URI.create("

clearQueue

Using AI Code Generation

1import org.openqa.selenium.grid.sessionqueue.NewSessionQueue;2import org.openqa.selenium.grid.sessionqueue.config.SessionQueueOptions;3import org.openqa.selenium.remote.http.HttpClient;4import org.openqa.selenium.remote.http.HttpClient.Factory;5import org.openqa.selenium.remote.tracing.Tracer;6import org.openqa.selenium.remote.tracing.global.GlobalTracer;7import org.openqa.selenium.remote.tracing.opentelemetry.OpenTelemetryTracer;8import org.openqa.selenium.remote.tracing.opentelemetry.config.OpenTelemetryOptions;9import org.openqa.selenium.remote.tracing.opentelemetry.config.OpenTelemetryOptions.TracerImplementation;10import java.net.URI;11import java.net.URISyntaxException;12import java.util.logging.Level;13import java.util.logging.Logger;14public class ClearSessionQueue {15    public static void main(String[] args) {16        Tracer tracer = GlobalTracer.get();17        Factory clientFactory = HttpClient.Factory.createDefault();18        SessionQueueOptions sessionQueueOptions = new SessionQueueOptions();19        NewSessionQueue sessionQueue = new NewSessionQueue(tracer, clientFactory, sessionQueueOptions);20        sessionQueue.clearQueue();21    }22}23clearQueue()

Selenium 4 Tutorial:

LambdaTest’s Selenium 4 tutorial is covering every aspects of Selenium 4 testing with examples and best practices. Here you will learn basics, such as how to upgrade from Selenium 3 to Selenium 4, to some advanced concepts, such as Relative locators and Selenium Grid 4 for Distributed testing. Also will learn new features of Selenium 4, such as capturing screenshots of specific elements, opening a new tab or window on the browser, and new protocol adoptions.

Chapters:

Upgrading From Selenium 3 To Selenium 4?: In this chapter, learn in detail how to update Selenium 3 to Selenium 4 for Java binding. Also, learn how to upgrade while using different build tools such as Maven or Gradle and get comprehensive guidance for upgrading Selenium.
What’s New In Selenium 4 & What’s Being Deprecated? : Get all information about new implementations in Selenium 4, such as W3S protocol adaption, Optimized Selenium Grid, and Enhanced Selenium IDE. Also, learn what is deprecated for Selenium 4, such as DesiredCapabilites and FindsBy methods, etc.
Selenium 4 With Python: Selenium supports all major languages, such as Python, C#, Ruby, and JavaScript. In this chapter, learn how to install Selenium 4 for Python and the features of Python in Selenium 4, such as Relative locators, Browser manipulation, and Chrom DevTool protocol.
Selenium 4 Is Now W3C Compliant: JSON Wireframe protocol is retiring from Selenium 4, and they are adopting W3C protocol to learn in detail about the advantages and impact of these changes.
How To Use Selenium 4 Relative Locator? : Selenium 4 came with new features such as Relative Locators that allow constructing locators with reference and easily located constructors nearby. Get to know its different use cases with examples.
Selenium Grid 4 Tutorial For Distributed Testing: Selenium Grid 4 allows you to perform tests over different browsers, OS, and device combinations. It also enables parallel execution browser testing, reads up on various features of Selenium Grid 4 and how to download it, and runs a test on Selenium Grid 4 with best practices.
Selenium Video Tutorials: Binge on video tutorials on Selenium by industry experts to get step-by-step direction from automating basic to complex test scenarios with Selenium.