@ManagedOperation(description = "Subscribe for dynamic routing with the name of a predicate bean in the registry")
    public String subscribeWithPredicateBean(
            String subscribeChannel,
            String subscriptionId,
            String destinationUri,
            int priority,
            String predicateBean,
            boolean update) {
        return filterService.addFilterForChannel(subscriptionId, priority,
                obtainPredicateFromBeanName(predicateBean, camelContext),
                destinationUri, subscribeChannel, update);
    }
@Test
    void subscribeWithPredicateBean() {
        context.getRegistry().bind(predicateBeanName, Predicate.class, predicateInstance);
        service.subscribeWithPredicateBean(subscribeChannel, subscriptionId, destinationUri, priority,
                predicateBeanName, false);
        Mockito.verify(filterService, Mockito.times(1))
                .addFilterForChannel(
                        eq(subscriptionId), eq(priority), any(Predicate.class),
                        eq(destinationUri), eq(subscribeChannel), eq(false));
    }