131132133134135136137138139140141
synchronized (received) { Waiter w = new Waiter(received, 30000); while (received.size() < count && w.hasTime()) { w.await(); } } } void check() throws JMSException
654655656657658659660661662663664
{ Waiter w = new Waiter(commandsLock, timeout); while (w.hasTime() && (state != OPEN && state != CLOSED)) { checkFailoverRequired("Command was interrupted because of failover, before being sent"); w.await(); } } } switch (state)
723724725726727728729730731732733
e.rethrow(); } } } checkFailoverRequired("Command was interrupted because of failover, before being sent"); w.await(); } } if (state == CLOSED) {
855856857858859860861862863864865
checkFailoverRequired("Session sync was interrupted by failover."); if(log.isDebugEnabled()) { log.debug("%s waiting for[%d]: %d, %s", this, point, maxComplete, commands); } w.await(); } if (lt(maxComplete, point)) { if (state != CLOSED)
10621063106410651066106710681069107010711072
{ Waiter w = new Waiter(commandsLock, timeout); while (w.hasTime() && state != CLOSED) { checkFailoverRequired("close() was interrupted by failover."); w.await(); } if (state != CLOSED) { throw new SessionException("close() timed out");
11571158115911601161116211631164116511661167
{ Waiter w = new Waiter(stateLock, timeout); while (w.hasTime() && state == NEW) { checkFailoverRequired("Session opening was interrupted by failover."); w.await(); } } if (state != OPEN) {
966967968969970971972973974975976
Waiter w = new Waiter(this, timeout); while (w.hasTime() && state != CLOSED && !isDone()) { checkFailoverRequired("Operation was interrupted by failover."); log.debug("%s waiting for result: %s", Session.this, this); w.await(); } } if (isDone()) {
258259260261262263264265266267268
send(new ProtocolHeader(1, 0, 10)); Waiter w = new Waiter(lock, timeout); while (w.hasTime() && state == OPENING && error == null) { w.await(); } if (error != null) { ConnectionException t = error;
348349350351352353354355356357358
synchronized (lock) { Waiter w = new Waiter(lock, timeout); while (w.hasTime() && state != OPEN && error == null) { w.await(); } if (state != OPEN) { throw new ConnectionException("Timed out waiting for connection to be ready. Current state is :" + state);
625626627628629630631632633634635
state = CLOSING; connectionClose(replyCode, replyText, _options); Waiter w = new Waiter(lock, timeout); while (w.hasTime() && state == CLOSING && error == null) { w.await(); } if (error != null) { close(replyCode, replyText, _options);