Class SimpleDiscoveryAgent

    • Constructor Detail

      • SimpleDiscoveryAgent

        public SimpleDiscoveryAgent()
    • Method Detail

      • getServices

        public String[] getServices()
      • setServices

        public void setServices​(String services)
      • setServices

        public void setServices​(String[] services)
      • setServices

        public void setServices​(URI[] services)
      • serviceFailed

        public void serviceFailed​(DiscoveryEvent devent)
                           throws IOException
        Description copied from interface: DiscoveryAgent
        A process actively using a service may see it go down before the DiscoveryAgent notices the service's failure. That process can use this method to notify the DiscoveryAgent of the failure so that other listeners of this DiscoveryAgent can also be made aware of the failure.
        Specified by:
        serviceFailed in interface DiscoveryAgent
        Throws:
        IOException
      • doReconnectDelay

        protected void doReconnectDelay​(org.apache.activemq.transport.discovery.simple.SimpleDiscoveryAgent.SimpleDiscoveryEvent event)
      • getBackOffMultiplier

        public long getBackOffMultiplier()
      • setBackOffMultiplier

        public void setBackOffMultiplier​(long backOffMultiplier)
      • getInitialReconnectDelay

        public long getInitialReconnectDelay()
      • setInitialReconnectDelay

        public void setInitialReconnectDelay​(long initialReconnectDelay)
      • getMaxReconnectAttempts

        public int getMaxReconnectAttempts()
      • setMaxReconnectAttempts

        public void setMaxReconnectAttempts​(int maxReconnectAttempts)
      • getMaxReconnectDelay

        public long getMaxReconnectDelay()
      • setMaxReconnectDelay

        public void setMaxReconnectDelay​(long maxReconnectDelay)
      • getMinConnectTime

        public long getMinConnectTime()
      • setMinConnectTime

        public void setMinConnectTime​(long minConnectTime)
      • isUseExponentialBackOff

        public boolean isUseExponentialBackOff()
      • setUseExponentialBackOff

        public void setUseExponentialBackOff​(boolean useExponentialBackOff)