| | |
| | | ConnectionResultHandler<? super AuthenticatedAsynchronousConnection, P> handler, |
| | | P p) |
| | | { |
| | | // TODO: bug here? if allowRebind= false then bind will never happen |
| | | ConnectionFutureImpl<P> future = new ConnectionFutureImpl<P>( |
| | | allowRebinds ? request : null, handler, p); |
| | | future.connectFuture = parentFactory.getAsynchronousConnection( |
| | |
| | | |
| | | |
| | | |
| | | public void close(UnbindRequest request) |
| | | public void close(UnbindRequest request, String reason) |
| | | throws NullPointerException |
| | | { |
| | | connection.close(request); |
| | | connection.close(request, reason); |
| | | } |
| | | |
| | | |
| | |
| | | searchResulthandler, p); |
| | | } |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | public boolean isClosed() |
| | | { |
| | | return connection.isClosed(); |
| | | } |
| | | } |
| | | |
| | | |