Hi Team,

We are looking for a way to integrate UDP(User datagram protocol) with our current infra where we have IS/MSR, API Gateway and UM.

Any suggestion on how can we integrate UDP with webmethods components. This protocol can be on either consumer or provider side.

Any help on this topic is highly appreciated. Please let me know if any other details are needed.

Thanks

Hi Rupinder,

Thank you for your reply, looks like WmSockets option is not compatible now.

I wanted to add further here that our use case if for live data streaming. Can we use webSockets in API gateway for same.

Thanks

My 2 cents that I think might be a doable option:

• Create a java class for continuous UDP listening within your custom package:

  package com.yourcompany.udp;
  
  import java.net.DatagramPacket;
  import java.net.DatagramSocket;
  import java.util.concurrent.atomic.AtomicBoolean;
  
  import com.wm.app.b2b.server.Service;
  import com.wm.data.IData;
  import com.wm.data.IDataFactory;
  
  public class UDPListener implements Runnable {
  
      private int port;
      private Thread thread;
      private AtomicBoolean running = new AtomicBoolean(false);
      private DatagramSocket socket;
  
      public UDPListener(int port) {
          this.port = port;
      }
  
      public void start() {
          if (running.get()) return;
          running.set(true);
          thread = new Thread(this, "UDPListenerThread");
          thread.start();
      }
  
      public void stop() {
          running.set(false);
          if (socket != null && !socket.isClosed()) {
              socket.close();  // This will break .receive()
          }
      }
  
      @Override
      public void run() {
          try {
              socket = new DatagramSocket(port);
              byte[] buffer = new byte[2048];
              while (running.get()) {
                  DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
                  socket.receive(packet);
  
                  String message = new String(packet.getData(), 0, packet.getLength());
  
                  // Invoke IS service to handle the message
                  IData input = IDataFactory.create();
                  input.getCursor().insertAfter("message", message);
                  Service.doInvoke("YourPackage.YourFolder", "handleUDPMessage", input);
              }
          } catch (Exception e) {
              e.printStackTrace();
          } finally {
              if (socket != null && !socket.isClosed()) {
                  socket.close();
              }
          }
      }
  }
  

• Then create 2 Java Services that will start and shutdown the UDP listener following the IS/MSR lifecycle.

  
  import com.yourcompany.udp.UDPListener;
  
  String portStr = (String) IDataUtil.get(pipelineCursor, "port");
  int port = Integer.parseInt(portStr);
  
  UDPListener listener = new UDPListener(port);
  listener.start();
  
  

• // be aware you must implement a Singleton Listener in order to handle the Listener instances propertly.
  
  if (MyListenerHolder.listener != null) {
      MyListenerHolder.listener.stop();
  }
  

Finally, just set up the above Java services as your custom package's startup and shutdown services, respectively.

I know there are a few hard coded variables in the above implementation but I bet you can make it better starting from this point.

HIH,

Moacy  

------------------------------
Moacy Barbosa
------------------------------