java/com.sap.sse.replication/src/com/sap/sse/replication/RabbitMQConnectionFactoryHelper.java
... ...
@@ -5,7 +5,7 @@ import com.rabbitmq.client.ConnectionFactory;
5 5
public class RabbitMQConnectionFactoryHelper {
6 6
/**
7 7
* Creates a RabbitMQ {@link ConnectionFactory} that has a connection timeout of 30s, a network recovery interval of
8
- * 10s, a heartbeat interval of 6 minutes, and that uses automatic recovery and topology recovery.
8
+ * 10s, a heartbeat interval of 30 minutes, and that uses automatic recovery and topology recovery.
9 9
*/
10 10
public static ConnectionFactory getConnectionFactory() {
11 11
final ConnectionFactory connectionFactory = new ConnectionFactory();
... ...
@@ -13,7 +13,7 @@ public class RabbitMQConnectionFactoryHelper {
13 13
connectionFactory.setAutomaticRecoveryEnabled(true);
14 14
connectionFactory.setTopologyRecoveryEnabled(true);
15 15
connectionFactory.setNetworkRecoveryInterval(10000);
16
- connectionFactory.setRequestedHeartbeat(360);
16
+ connectionFactory.setRequestedHeartbeat(1800);
17 17
return connectionFactory;
18 18
}
19 19
}