assertEquals((Integer) 2, converter.convert("two"));
    assertThrows(IllegalArgumentException.class, () -> converter.convert("three"));

    biMap.put("three", 3);

    assertEquals((Integer) 1, converter.convert("one"));
    assertEquals((Integer) 2, converter.convert("two"));
    assertEquals((Integer) 3, converter.convert("three"));
  }

    }

    /**
     * Creates an EditBody from a BoostDocumentRule entity for API responses.
     *
     * @param entity the BoostDocumentRule entity to convert
     * @return the converted EditBody object
     */
    protected EditBody createEditBody(final BoostDocumentRule entity) {
        final EditBody form = new EditBody();
        copyBeanToBean(entity, form, CopyOptions::excludeNull);

    }

    /**
     * Creates an edit body from a group entity for API responses.
     *
     * @param entity the group entity to convert
     * @return edit body containing the entity data
     */
    protected EditBody createEditBody(final Group entity) {
        final EditBody body = new EditBody();
        copyBeanToBean(entity, body, copyOp -> {

    }

    /**
     * Creates an EditBody from a DataConfig entity for API responses.
     * Handles permission and virtual host encoding.
     *
     * @param entity the DataConfig entity to convert
     * @return the converted EditBody object
     */
    protected EditBody createEditBody(final DataConfig entity) {
        final EditBody body = new EditBody();
        copyBeanToBean(entity, body, copyOp -> {

 * create {@code ListenableFuture} instances depends on how you currently create {@code Future}
 * instances:
 *
 * <ul>
 *   <li>If you receive them from an {@code java.util.concurrent.ExecutorService}, convert that
 *       service to a {@link ListeningExecutorService}, usually by calling {@link
 *       MoreExecutors#listeningDecorator(java.util.concurrent.ExecutorService)
 *       MoreExecutors.listeningDecorator}.

    }

    @Test
    @DisplayName("Should parse Type 1 message from byte array")
    void testType1MessageFromBytes() throws IOException {
        // Given - Create a Type 1 message and convert to bytes
        Type1Message original = new Type1Message(mockContext);
        byte[] messageBytes = original.toByteArray();

        // When
        Type1Message parsed = new Type1Message(messageBytes);

	mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames()))
	localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())

	// Convert local messages to JSON and send to mergeCh
	go func() {
		buf := bytes.NewBuffer(grid.GetByteBuffer()[:0])
		enc := json.NewEncoder(buf)
		tmpEvt := struct{ Records []event.Event }{[]event.Event{{}}}
		for {

                });
    }

    /**
     * Creates an EditBody from a StemmerOverrideItem entity for API responses.
     *
     * @param entity the StemmerOverrideItem entity to convert
     * @param dictId the dictionary ID
     * @return the converted EditBody object
     */
    protected EditBody createEditBody(final StemmerOverrideItem entity, final String dictId) {
        final EditBody body = new EditBody();

                    && field.getType() == String.class && field.getName().startsWith("LABELS_")) {

                field.setAccessible(true);
                String value = (String) field.get(null);

                // Convert field name to expected value
                String fieldNamePart = field.getName().substring("LABELS_".length());
                String expectedValuePart = fieldNamePart.toLowerCase()
                        .replace("_", ".")

 * create {@code ListenableFuture} instances depends on how you currently create {@code Future}
 * instances:
 *
 * <ul>
 *   <li>If you receive them from an {@code java.util.concurrent.ExecutorService}, convert that
 *       service to a {@link ListeningExecutorService}, usually by calling {@link
 *       MoreExecutors#listeningDecorator(java.util.concurrent.ExecutorService)
 *       MoreExecutors.listeningDecorator}.