Class DuplexConnectionPool

    • Constructor Detail

      • DuplexConnectionPool

        public DuplexConnectionPool​(Destination destination,
                                    int maxConnections,
                                    Callback requester)
    • Method Detail

      • lock

        protected void lock()
      • unlock

        protected void unlock()
      • getIdleConnections

        public java.util.Queue<Connection> getIdleConnections()
      • getActiveConnections

        public java.util.Collection<Connection> getActiveConnections()
      • isActive

        public boolean isActive​(Connection connection)
        Specified by:
        isActive in interface ConnectionPool
        Parameters:
        connection - the connection to test
        Returns:
        whether the given connection is currently in use
      • release

        public boolean release​(Connection connection)
        Description copied from interface: ConnectionPool

        Returns the given connection, previously obtained via ConnectionPool.acquire(), back to this ConnectionPool.

        Specified by:
        release in interface ConnectionPool
        Parameters:
        connection - the connection to release
        Returns:
        true if the connection has been released, false if the connection should be closed
      • deactivate

        protected boolean deactivate​(Connection connection)
      • remove

        public boolean remove​(Connection connection)
        Description copied from interface: ConnectionPool

        Removes the given connection from this ConnectionPool.

        Specified by:
        remove in interface ConnectionPool
        Parameters:
        connection - the connection to remove
        Returns:
        true if the connection was removed from this ConnectionPool
      • remove

        protected boolean remove​(Connection connection,
                                 boolean force)
      • dump

        public void dump​(java.lang.Appendable out,
                         java.lang.String indent)
                  throws java.io.IOException
        Description copied from interface: Dumpable
        Dump this object (and children) into an Appendable using the provided indent after any new lines. The indent should not be applied to the first object dumped.
        Specified by:
        dump in interface Dumpable
        Parameters:
        out - The appendable to dump to
        indent - The indent to apply after any new lines.
        Throws:
        java.io.IOException - if unable to write to Appendable
      • dump

        protected void dump​(java.lang.Appendable out,
                            java.lang.String indent,
                            java.lang.Object... items)
                     throws java.io.IOException
        Throws:
        java.io.IOException
      • sweep

        public boolean sweep()
        Specified by:
        sweep in interface Sweeper.Sweepable
        Returns:
        whether this resource should be swept
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object