* @param handle The policy handle to receive the connection handle
         */
        public SamrConnect4(final String system_name, final int unknown, final int access_mask, final rpc.policy_handle handle) {
            this.system_name = system_name;
            this.unknown = unknown;
            this.access_mask = access_mask;
            this.handle = handle;
        }

        @Override

         * @param handle The policy handle to receive the connection handle
         */
        public SamrConnect4(final String system_name, final int unknown, final int access_mask, final rpc.policy_handle handle) {
            this.system_name = system_name;
            this.unknown = unknown;
            this.access_mask = access_mask;
            this.handle = handle;
        }

        @Override

        }
        throw new InvalidQueryException(messages -> messages.addErrorsInvalidQueryUnknown(UserMessages.GLOBAL_PROPERTY_KEY),
                "Unknown q: " + query.getClass() + " => " + query);
    }

        booleanParams.put("boolean", true);
        assertNotNull(queryRescorer.evaluate(booleanParams));

        // Test with unknown parameter
        Map<String, Object> unknownParams = new HashMap<>();
        unknownParams.put("unknown", new Object());
        assertNull(queryRescorer.evaluate(unknownParams));
    }

    public void test_evaluate_withNestedParams() {

        WEBAPP("fess-webapp"), //
        /** Thumbnail generator plugins */
        THUMBNAIL("fess-thumbnail"), //
        /** Crawler plugins */
        CRAWLER("fess-crawler"), //
        /** Unknown/generic JAR files */
        UNKNOWN("jar");

        /** The ID prefix for this artifact type */
        private final String id;

        /**
         * Creates a new artifact type with the specified ID.
         *

        assertThrows(IOException.class, () -> sis.read());
    }

    @Test
    @DisplayName("Unknown packet type is handled by continuing to next packet")
    void unknownPacketTypeHandled() throws IOException {
        // According to the SocketInputStream implementation, unknown packet types
        // are handled in the switch statement's default case which continues the loop

        // this should never happen since we checked all possible error sources before but better be sure
        if (result.hasExceptions()) {
            throw new ArtifactResolutionException(
                    "Unknown error during artifact resolution, " + request + ", " + result.getExceptions(),
                    request.getArtifact(),
                    request.getRemoteRepositories());
        }
    }

      )
      request.isChunked -> newChunkedSink() // Stream a request body of unknown length.
      contentLength != -1L -> newKnownLengthSink() // Stream a request body of a known length.
      else -> // Stream a request body of a known length.
        throw IllegalStateException(
          "Cannot stream a request body without chunked encoding or a known content length!",
        )
    }

  override fun cancel() {

        closed = true
      }
      else -> {
        throw ProtocolException("Unknown control opcode: " + opcode.toHexString())
      }
    }
  }

  @Throws(IOException::class)
  private fun readMessageFrame() {
    val opcode = this.opcode
    if (opcode != OPCODE_TEXT && opcode != OPCODE_BINARY) {
      throw ProtocolException("Unknown opcode: ${opcode.toHexString()}")
    }

    readMessage()

        for (WitnessEventType type : values()) {
            if (type.value == value) {
                return type;
            }
        }
        throw new IllegalArgumentException("Unknown witness event type: " + value);
    }