}

    @Test
    public void test_offerAll_emptyListTx() {
        final String sessionId = "offer_session1";
        final List<OpenSearchUrlQueue> emptyList = new ArrayList<>();

        // Should not throw exception
        urlQueueService.offerAll(sessionId, emptyList);

        // Verify no items were added
        final OpenSearchUrlQueue polled = urlQueueService.poll(sessionId);
        assertNull(polled);
    }

        return "ms";
      case SECONDS:
        return "s";
      case MINUTES:
        return "min";
      case HOURS:
        return "h";
      case DAYS:
        return "d";
    }
    throw new AssertionError();
  }

    this.lowerBoundType = checkNotNull(lowerBoundType);
    this.upperEndpoint = upperEndpoint;
    this.upperBoundType = checkNotNull(upperBoundType);

    // Trigger any exception that the comparator would throw for the endpoints.
    /*
     * uncheckedCastNullableTToT is safe as long as the callers are careful to pass a "real" T
     * whenever they pass `true` for the matching `has*Bound` parameter.
     */

        // Don't stub mockSid2 since it won't be reached due to NPE on null element
        testSids = new jcifs.SID[] { mockSid1, null, mockSid2 };

        // Act & Assert - This should throw an exception when LsarSidArrayX tries to process null
        assertThrows(NullPointerException.class, () -> {
            new MsrpcLookupSids(mockPolicyHandle, testSids);
        });
    }

    @Test

                                + "  Project coordinates:  %s:%s:%s%n"
                                + "  Artifact coordinates: %s:%s:%s",
                        g1, a1, v1, g2, a2, v2);
            }
            throw new IllegalArgumentException(message);
        }
        getMavenProject(project)
                .addAttachedArtifact(
                        RepositoryUtils.toArtifact(getSession(project).toArtifact(artifact)));

                        unicode.setLength(0);
                        inUnicode = false;
                        hadSlash = false;
                    } catch (NumberFormatException nfe) {
                        throw new IllegalArgumentException("Unable to parse unicode value: " + unicode, nfe);
                    }
                }
                continue;
            }

            if (hadSlash) {

                        unicode.setLength(0);
                        inUnicode = false;
                        hadSlash = false;
                    } catch (NumberFormatException nfe) {
                        throw new IllegalArgumentException("Unable to parse unicode value: " + unicode, nfe);
                    }
                }
                continue;
            }

            if (hadSlash) {

            assertThat(state()).isEqualTo(Service.State.STOPPING);
            notifyStopped();
          }

          @Override
          protected void doStop() {
            throw new AssertionError(); // Should not be called.
          }
        };

    ServiceManager manager = new ServiceManager(asList(a));
    manager.startAsync();
    manager.stopAsync();

            len += rem;
        }

        haveResponse(buffer, start, len);

        if ((this.nextCommand != 0 && this.next != null) && (this.nextCommand % 8 != 0)) {
            throw new SMBProtocolDecodingException("Chained command is not aligned");
        }
        return len;
    }

    /**
     * Checks if this message has an error status.
     *

        // So we also need to support a1/a2/a3/b/c1/c2/c3

        String[] testParts = fullTestName.split("/");
        if(testParts.length < 3 ){
            throw new IllegalArgumentException("To skip tests, all 3 parts [folder/file/test name] must be defined. found [" + fullTestName + "]");
        }

        PatternSet skippedPatternSet = patternSetFactory.create();