java - Camel Netty4 udp Multicast not working on windows -
i have been trying camel netty4 udp multicast work on windows , nettyudpmulticastasynctest seems failing java.nio.channels.closedchannelexception. same test seems working on osx. both machines running java 1.7 have updated interface name in test , able run nio udp multicast sample on same interface. using camel 2.14.1 not seem working on 2.15.x well.
the stack trace below.
tests run: 1, failures: 0, errors: 1, skipped: 0, time elapsed: 0.026 sec <<< failure! - in org.apache.camel.component.netty4.nettyudpmulticastasynctest testudpinonlymulticastwithnettyconsumer(org.apache.camel.component.netty4.nettyudpmulticastasynctest) time elapsed: 0.023 sec <<< error! java.nio.channels.closedchannelexception: null @ sun.nio.ch.datagramchannelimpl.innerjoin(datagramchannelimpl.java:832) @ sun.nio.ch.datagramchannelimpl.join(datagramchannelimpl.java:894) @ io.netty.channel.socket.nio.niodatagramchannel.joingroup(niodatagramchannel.java:409) @ io.netty.channel.socket.nio.niodatagramchannel.joingroup(niodatagramchannel.java:382) @ io.netty.channel.socket.nio.niodatagramchannel.joingroup(niodatagramchannel.java:375) @ org.apache.camel.component.netty4.singleudpnettyserverbootstrapfactory.startserverbootstrap(singleudpnettyserverbootstrapfactory.java:177) @ org.apache.camel.component.netty4.singleudpnettyserverbootstrapfactory.dostart(singleudpnettyserverbootstrapfactory.java:97) @ org.apache.camel.support.servicesupport.start(servicesupport.java:61) @ org.apache.camel.util.servicehelper.startservice(servicehelper.java:74) @ org.apache.camel.util.servicehelper.startservice(servicehelper.java:59) @ org.apache.camel.util.servicehelper.startservices(servicehelper.java:103) @ org.apache.camel.util.servicehelper.startservices(servicehelper.java:89) @ org.apache.camel.component.netty4.nettyconsumer.dostart(nettyconsumer.java:69)
found problem in binding multicast address before joining group, reason not work on windows. had update bootstrap.bind in singleudpnettyserverbootstrapfactory
channelfuture channelfuture = bootstrap.bind(new inetsocketaddress(configuration.getport()));
Comments
Post a Comment