Class PooledSender

    • Constructor Detail

      • PooledSender

        public PooledSender()
    • Method Detail

      • getNewDataSender

        public abstract DataSender getNewDataSender()
      • returnSender

        public void returnSender​(DataSender sender)
      • connect

        public void connect()
                     throws java.io.IOException
        Description copied from interface: DataSender
        Connect.
        Specified by:
        connect in interface DataSender
        Throws:
        java.io.IOException - when an error occurs
      • getInPoolSize

        public int getInPoolSize()
      • getInUsePoolSize

        public int getInUsePoolSize()
      • setPoolSize

        public void setPoolSize​(int poolSize)
      • getPoolSize

        public int getPoolSize()
      • getMaxWait

        public long getMaxWait()
      • setMaxWait

        public void setMaxWait​(long maxWait)
      • add

        public void add​(Member member)
        Description copied from interface: MultiPointSender
        Send to the specified member.
        Specified by:
        add in interface MultiPointSender
        Parameters:
        member - the member
      • remove

        public void remove​(Member member)
        Description copied from interface: MultiPointSender
        Stop sending to the specified member.
        Specified by:
        remove in interface MultiPointSender
        Parameters:
        member - the member