@InvokeOnHeader(CONTROL_ACTION_UNSUBSCRIBE)
    public void performUnsubscribe(final Message message, AsyncCallback callback) {
        Map<String, Object> headers = message.getHeaders();
        String subscriptionId = (String) headers.getOrDefault(CONTROL_SUBSCRIPTION_ID, configuration.getSubscriptionId());
        String subscribeChannel = (String) headers.getOrDefault(CONTROL_SUBSCRIBE_CHANNEL, configuration.getSubscribeChannel());
        boolean result = dynamicRouterControlService.removeSubscription(subscribeChannel, subscriptionId);
        message.setBody(result, boolean.class);
        callback.done(false);
    }
@Test
    void performUnsubscribeAction() {
        String subscriptionId = "testId";
        String subscribeChannel = "testChannel";
        Map<String, Object> headers = Map.of(
                CONTROL_ACTION_HEADER, CONTROL_ACTION_UNSUBSCRIBE,
                CONTROL_SUBSCRIBE_CHANNEL, subscribeChannel,
                CONTROL_SUBSCRIPTION_ID, subscriptionId);
        when(message.getHeaders()).thenReturn(headers);
        Mockito.doNothing().when(callback).done(false);
        producer.performUnsubscribe(message, callback);
        Mockito.verify(controlService, Mockito.times(1))
                .removeSubscription(subscribeChannel, subscriptionId);
    }