Class ResourceManager


  • public final class ResourceManager
    extends java.lang.Object
    Manages resources such as multicast addresses and multicast ports, and TCP ports. This class is mainly used for running unit tests in parallel (TestNG) and preventing clusters intended to be separate from joining each other.
    Author:
    Bela Ban
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static java.lang.String getNextMulticastAddress()
      Returns the next available multicast address, e.g.
      static short getNextMulticastPort​(java.net.InetAddress bind_addr)  
      static int getNextTcpPort​(java.net.InetAddress bind_addr)  
      protected static int getNextTCPPort​(java.net.InetAddress bind_addr, int start_port)  
      static java.util.List<java.lang.Integer> getNextTcpPorts​(java.net.InetAddress bind_addr, int num_requested_ports)  
      static java.lang.String getUniqueClusterName()  
      static java.lang.String getUniqueClusterName​(java.lang.String base_name)  
      static void main​(java.lang.String[] args)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Method Detail

      • getNextMulticastAddress

        public static java.lang.String getNextMulticastAddress()
        Returns the next available multicast address, e.g. "228.1.2.3". This class is a JVM singleton
        Returns:
      • getNextMulticastPort

        public static short getNextMulticastPort​(java.net.InetAddress bind_addr)
                                          throws java.lang.Exception
        Throws:
        java.lang.Exception
      • getNextTcpPorts

        public static java.util.List<java.lang.Integer> getNextTcpPorts​(java.net.InetAddress bind_addr,
                                                                        int num_requested_ports)
                                                                 throws java.lang.Exception
        Throws:
        java.lang.Exception
      • getNextTcpPort

        public static int getNextTcpPort​(java.net.InetAddress bind_addr)
                                  throws java.lang.Exception
        Throws:
        java.lang.Exception
      • getNextTCPPort

        protected static int getNextTCPPort​(java.net.InetAddress bind_addr,
                                            int start_port)
                                     throws java.lang.Exception
        Throws:
        java.lang.Exception
      • getUniqueClusterName

        public static java.lang.String getUniqueClusterName​(java.lang.String base_name)
      • getUniqueClusterName

        public static java.lang.String getUniqueClusterName()
      • main

        public static void main​(java.lang.String[] args)
                         throws java.lang.Exception
        Throws:
        java.lang.Exception