(long milliseconds, boolean backingoff)
| 5853 | } |
| 5854 | |
| 5855 | boolean acquire(long milliseconds, boolean backingoff) throws InterruptedException { |
| 5856 | try { |
| 5857 | this.backingoff = backingoff; |
| 5858 | return semaphore.tryAcquire(milliseconds, TimeUnit.MILLISECONDS); |
| 5859 | } finally { |
| 5860 | this.backingoff = false; |
| 5861 | } |
| 5862 | } |
| 5863 | |
| 5864 | void error(Throwable ex) { |
| 5865 | if (ex instanceof MessagingException && |
no outgoing calls
no test coverage detected