| | |
| | | || noRebindArgument.isPresent()) |
| | | { |
| | | connection = connectionFactory.getAsynchronousConnection( |
| | | null, null).get(); |
| | | null).get(); |
| | | } |
| | | for (int j = 0; j < numThreads; j++) |
| | | { |
| | |
| | | |
| | | |
| | | class UpdateStatsResultHandler<S extends Result> implements |
| | | ResultHandler<S, Void> |
| | | ResultHandler<S> |
| | | { |
| | | private long eTime; |
| | | |
| | |
| | | |
| | | |
| | | |
| | | public void handleResult(Void p, S result) |
| | | public void handleResult(S result) |
| | | { |
| | | successRecentCount.getAndIncrement(); |
| | | eTime = System.nanoTime() - eTime; |
| | |
| | | |
| | | |
| | | |
| | | public void handleErrorResult(Void p, ErrorResultException error) |
| | | public void handleErrorResult(ErrorResultException error) |
| | | { |
| | | failedRecentCount.getAndIncrement(); |
| | | app.println(LocalizableMessage.raw(error.getResult().toString())); |
| | |
| | | |
| | | |
| | | |
| | | abstract class WorkerThread<R extends ResultHandler<?, ?>> extends |
| | | abstract class WorkerThread<R extends ResultHandler<?>> extends |
| | | Thread |
| | | { |
| | | private int count; |
| | |
| | | try |
| | | { |
| | | connection = connectionFactory.getAsynchronousConnection( |
| | | null, null).get(); |
| | | null).get(); |
| | | } |
| | | catch (InterruptedException e) |
| | | { |
| | |
| | | AuthenticatedAsynchronousConnection ac = (AuthenticatedAsynchronousConnection) connection; |
| | | try |
| | | { |
| | | ac.rebind(null, null).get(); |
| | | ac.rebind(null).get(); |
| | | } |
| | | catch (InterruptedException e) |
| | | { |