How to add customer serverpipeline factory to switchyard camel netty component

[bhaskarsk]

I have a requirement where, i need to check whenever a client connects/disconnects to my listening socket.

As i am using switchyard netty binding, i see there is no paramter options for this. Even if i plan to use netty as camel URI, whenever i give the uri parameter as mentioned in

https://access.redhat.com/documentation/en-US/Fuse_ESB_Enterprise/7.1/html/EIP_Component_Reference/files/_IDU_Netty.html

netty:tcp://localhost:5150?serverPipelineFactory=#spf

it does not accept this parameter.

I dont see this uri parameter in the netty component model, is there any workaround or any plans to add it in the upcoming releases?

Thanks in advance

Bhaskar

[igarashitm]

That's weird. At least the Camel URI binding should accept the parameter. Also all of the SwitchYard camel-* binding accepts any URI parameters via additionalUriParameters. Here is an example in camel-ftp quickstart:

switchyard/switchyard.xml at master · jboss-switchyard/switchyard · GitHub

What happen when you specify that parameter?

[bhaskarsk]

I am able to pass the serverPipelineFactory, but to inject the named bean it is not working.

URI is

netty:tcp://localhost:8878?serverPipelineFactory=#spf&&textline=true

And the bean class is annotated with

@Named("spf")

public class SampleServerChannelPipelineFactory extends ServerPipelineFactory {

    private int maxLineSize = 1024;

..................

I am getting the error

Caused by: org.switchyard.SwitchYardException: org.apache.camel.FailedToCreateRouteException: Failed to create route V1CamelUriBindingModel/Hello@camel1#-1685994905: Route[[From[netty:tcp://localhost:8878?serverPipelineF... because of Failed to resolve endpoint: netty://tcp://localhost:8878?&serverPipelineFactory=%23spf&textline=true due to: No bean could be found in the registry for: spf of type: org.apache.camel.component.netty.ServerPipelineFactory

I am attaching the project as well.