Receiving Multicast (Listen on multicastgroup / port)

[nando <si...@gmail.com>]

Hi,
i am very new to activemq and camel.
can somebody tell me if there is a possibility to receive multicast data?
what i need is to join a multicast group and listen for incoming multicast
data...

i only found "sending" messages via multicast but not how to receive them...

Greetings
Nando



--
View this message in context: http://camel.465427.n5.nabble.com/Receiving-Multicast-Listen-on-multicastgroup-port-tp5741583.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Receiving Multicast (Listen on multicastgroup / port)

[nando <si...@gmail.com>]

Now i try receiving multicast using netty.
When i connect via netty with normal UDP it works, but if i try
to join a multicast group like this:

from("netty:udp://224.255.16.1:2200?broadcast=true&networkInterface=bond0")....

i get the following exception:


439  [de.dfs.showtime.camel.ATVoiceCamel.main()] INFO 
org.apache.camel.component.netty.SingleUDPNettyServerBootstrapFactory  -
ConnectionlessBootstrap joining 224.255.16.1:2200 using network interface:
bond0
439  [de.dfs.showtime.camel.ATVoiceCamel.main()] INFO 
org.apache.camel.component.netty.SingleUDPNettyServerBootstrapFactory  -
ConnectionlessBootstrap disconnecting from 224.255.16.1:2200
443  [de.dfs.showtime.camel.ATVoiceCamel.main()] INFO 
org.apache.camel.component.netty.NettyConsumer  - Netty consumer unbound
from: 224.255.16.1:2200
444  [de.dfs.showtime.camel.ATVoiceCamel.main()] INFO 
org.apache.camel.impl.DefaultCamelContext  - Apache Camel 2.12.1
(CamelContext: camel-1) is shutting down
448  [de.dfs.showtime.camel.ATVoiceCamel.main()] INFO 
org.apache.camel.impl.DefaultCamelContext  - Apache Camel 2.12.1
(CamelContext: camel-1) uptime 0.389 seconds
448  [de.dfs.showtime.camel.ATVoiceCamel.main()] INFO 
org.apache.camel.impl.DefaultCamelContext  - Apache Camel 2.12.1
(CamelContext: camel-1) is shutdown in 0.003 seconds
java.lang.UnsupportedOperationException
        at
org.jboss.netty.channel.socket.nio.NioDatagramChannel.joinGroup(NioDatagramChannel.java:144)
        at
org.jboss.netty.channel.socket.nio.NioDatagramChannel.joinGroup(NioDatagramChannel.java:135)
        at
org.apache.camel.component.netty.SingleUDPNettyServerBootstrapFactory.startServerBootstrap(SingleUDPNettyServerBootstrapFactory.java:165)
        at
org.apache.camel.component.netty.SingleUDPNettyServerBootstrapFactory.doStart(SingleUDPNettyServerBootstrapFactory.java:102)
        at
org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
        at
org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:65)
        at
org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:54)
        at
org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:77)
        at
org.apache.camel.component.netty.NettyConsumer.doStart(NettyConsumer.java:69)
        at
org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
        at
org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:1888)
        at
org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRouteConsumers(DefaultCamelContext.java:2182)
        at
org.apache.camel.impl.DefaultCamelContext.doStartRouteConsumers(DefaultCamelContext.java:2118)
        at
org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:2048)
        at
org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:1827)
        at
org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:1699)
        at
org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:1544)
        at
org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
        at
org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:1512)
        at
de.dfs.showtime.camel.ATVoiceCamel.startContext(ATVoiceCamel.java:148)
        at de.dfs.showtime.camel.ATVoiceCamel.main(ATVoiceCamel.java:176)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
        at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:616)
        at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:297)
        at java.lang.Thread.run(Thread.java:679)


Any ideas?






--
View this message in context: http://camel.465427.n5.nabble.com/Receiving-Multicast-Listen-on-multicastgroup-port-tp5741583p5741603.html
Sent from the Camel - Users mailing list archive at Nabble.com.