| | |
| | | |
| | | |
| | | |
| | | final int run(ConnectionFactory<?> connectionFactory) |
| | | final int run(ConnectionFactory connectionFactory) |
| | | { |
| | | List<Thread> threads = new ArrayList<Thread>(); |
| | | |
| | |
| | | |
| | | abstract WorkerThread<?> newWorkerThread( |
| | | AsynchronousConnection connection, |
| | | ConnectionFactory<?> connectionFactory); |
| | | ConnectionFactory connectionFactory); |
| | | |
| | | |
| | | |
| | |
| | | |
| | | private final AsynchronousConnection connection; |
| | | |
| | | private final ConnectionFactory<?> connectionFactory; |
| | | private final ConnectionFactory connectionFactory; |
| | | |
| | | |
| | | |
| | | WorkerThread(AsynchronousConnection connection, |
| | | ConnectionFactory<?> connectionFactory) |
| | | ConnectionFactory connectionFactory) |
| | | { |
| | | super("Worker Thread"); |
| | | this.connection = connection; |