Artem Bilan

The logic there is like this: ``` public ConnectionManagerSupport(String uriTemplate, Object... uriVariables) { this.uri = UriComponentsBuilder.fromUriString(uriTemplate).buildAndExpand( uriVariables).encode().toUri(); } ``` So, uri is indeed encoded. Maybe you need to look into...

I think that makes sense. So, consider to raise an issue in https://github.com/spring-projects/spring-framework and ask that `org.springframework.web.socket.client.ConnectionManagerSupport` must also provide a ctor for the `URI` which will be created and...

I'm sorry, @ppojejje , it is not clear what is an intention of such a comment. Should we treat it as a spam and report your user for abusing: https://docs.github.com/en/communities/maintaining-your-safety-on-github/reporting-abuse-or-spam...

Right. Then it is better to be more specific and maybe share some thoughts how this could be implemented. I'm not so good with Debezium to give you an immediate...

Just to clarify: such an operator indeed going to be based on the `ReactiveMessageHandler` only, which could be represent as Lambda for simple use-cases. But most important it is going...

The `publishOn()` is a part of the `reactive()` endpoint configuration. It has nothing to do with particular handler. I'm not sure what kind of choice you'd like to see for...

There is already something like `handleFlux()` in Spring Integration Java DSL. It is called `fluxTransform()`: ``` /** * Populate a {@link FluxMessageChannel} to start a reactive processing for upstream data,...

@deepak5127 , sure! You can take a crack on this and we together can see what to do else in your Pull Request!

Why just don't use a plain polling behavior of the `Files.inboundAdapter()` and don't try to abuse a WatchService which puprose is really to let us to scan the whole file...

Well, one of them of course about walking through the whole file tree. Another one is to react for event in the file system: like updates to files or their...