I'm not an expert on the camel you show, but try changing:
from(String.format("netty4:udp://localhost:%d?sync=false&textline=true",
to
from(String.format("netty4:udp://0.0.0.0:%d?sync=false&textline=true",
> -----Original Message-----
> From: Steve973 [mailto:steve...@gmail.com]
> Sent: Wednesday, August 31, 2016 10:29 AM
> To: users@camel.apache.org
> Subject: Camel send/receive UDP with Netty4
>
> Hello, All. I am trying to create an example where I can receive UDP packets
> with the Netty4 component, but it isn't working. I'm sending UDP packets
> with a DatagramSocket to localhost, and I have a camel route consuming
> from netty4:udp//localhost on the port the DatagramSocket sent to. Here's
> the code:
>
> public class UdpWithCamelService implements BundleActivator {
> private static final Logger LOGGER =
> LoggerFactory.getLogger(UdpWithCamelService.class);
> public static final int SERVER_PORT = 22222;
> public static final int RECEIVER_PORT = 22223;
> private OsgiDefaultCamelContext camelContext;
> private RouteBuilder routeBuilder;
> private ScheduledExecutorService scheduler;
> private UdpSender sender;
>
> public UdpWithCamelService() throws Exception {
> scheduler = Executors.newSingleThreadScheduledExecutor();
> sender = new UdpSender();
> }
>
> @Override
> public void start(BundleContext context) throws Exception {
> camelContext = new OsgiDefaultCamelContext(context);
> camelContext.start();
> routeBuilder = new CamelUdpReceiverRouteBuilder();
> camelContext.addRoutes(routeBuilder);
> final Runnable senderTask = () -> {
> try {
> sender.sendTimestamp();
> LOGGER.warn("Sent timestamp via UDP");
> } catch (Exception e) {
> LOGGER.error("Problem sending timestamp via UDP", e);
> }
> };
> scheduler.scheduleAtFixedRate(senderTask, 1, 1, TimeUnit.SECONDS);
> }
>
> @Override
> public void stop(BundleContext context) throws Exception {
> scheduler.shutdown();
> sender.stop();
>
> camelContext.removeRouteDefinitions(routeBuilder.getRouteCollection().g
> etRoutes());
> camelContext = null;
> }
> }
>
> public class UdpSender {
> private final DatagramSocket socket;
>
> public UdpSender() throws Exception {
> socket = new DatagramSocket(UdpWithCamelService.SERVER_PORT);
> }
>
> public void stop() {
> socket.disconnect();
> socket.close();
> }
>
> public void sendTimestamp() throws Exception {
> String timestamp = String.valueOf(System.currentTimeMillis());
> socket.send(
> new DatagramPacket(
> timestamp.getBytes(), timestamp.getBytes().length,
> InetAddress.getLocalHost(), UdpWithCamelService.RECEIVER_PORT
> )
> );
> }
> }
>
> public class CamelUdpReceiverRouteBuilder extends RouteBuilder {
> private static final Logger LOGGER =
> LoggerFactory.getLogger(CamelUdpReceiverRouteBuilder.class);
>
> @Override
> public void configure() throws Exception {
>
> from(String.format("netty4:udp://localhost:%d?sync=false&textline=true",
> UdpWithCamelService.RECEIVER_PORT))
> .process(exchange -> {
> String body = exchange.getIn().getBody(String.class);
> LOGGER.warn("UDP Packet Received: " + body);
> });
> }
> }
>
> Thanks in advance,
>
> Steve
