Class TBackoffConnect


  • public class TBackoffConnect
    extends Object
    • Constructor Detail

      • TBackoffConnect

        public TBackoffConnect​(int retryTimes,
                               int retryInterval,
                               int retryIntervalCeiling,
                               boolean retryForever)
      • TBackoffConnect

        public TBackoffConnect​(int retryTimes,
                               int retryInterval,
                               int retryIntervalCeiling)
    • Method Detail

      • doConnectWithRetry

        public org.apache.storm.thrift.transport.TTransport doConnectWithRetry​(ITransportPlugin transportPlugin,
                                                                               org.apache.storm.thrift.transport.TTransport underlyingTransport,
                                                                               String host,
                                                                               String asUser)
                                                                        throws IOException
        Throws:
        IOException