Skip to content

Commit e4bf2c5

Browse files
Compile from scratch
1 parent c4f037f commit e4bf2c5

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

src/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727
import java.util.Map;
2828
import java.util.Set;
2929
import java.util.concurrent.ConcurrentHashMap;
30+
import java.util.concurrent.TimeoutException;
3031

3132
/**
3233
* Connection implementation that performs automatic recovery when
@@ -79,7 +80,7 @@ public AutorecoveringConnection(ConnectionParams params, FrameHandlerFactory f,
7980
* @throws IOException
8081
* @see com.rabbitmq.client.ConnectionFactory#newConnection(java.util.concurrent.ExecutorService)
8182
*/
82-
public void init() throws IOException {
83+
public void init() throws IOException, TimeoutException {
8384
this.delegate = this.cf.newConnection();
8485
this.addAutomaticRecoveryListener();
8586
}

src/com/rabbitmq/client/impl/recovery/RecoveryAwareAMQConnectionFactory.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@
1010
import java.util.Arrays;
1111
import java.util.Collections;
1212
import java.util.List;
13+
import java.util.concurrent.TimeoutException;
1314

1415
public class RecoveryAwareAMQConnectionFactory {
1516
private final ConnectionParams params;
@@ -26,8 +27,7 @@ public RecoveryAwareAMQConnectionFactory(ConnectionParams params, FrameHandlerFa
2627
* @return an interface to the connection
2728
* @throws java.io.IOException if it encounters a problem
2829
*/
29-
RecoveryAwareAMQConnection newConnection() throws IOException
30-
{
30+
RecoveryAwareAMQConnection newConnection() throws IOException, TimeoutException {
3131
IOException lastException = null;
3232
for (Address addr : shuffle(addrs)) {
3333
try {

0 commit comments

Comments
 (0)