@@ -101,7 +101,7 @@ public void testDisposalOfFileResources() throws Exception {
101
101
new DefaultMessageFactory (), 30 , false , 30 , UtcTimestampPrecision .MILLIS , true , false ,
102
102
false , false , false , false , true , false , 1.5 , null , true ,
103
103
new int [] { 5 }, false , false , false , false , true , false , true , false ,
104
- null , true , 0 , false , false , true , new ArrayList <>(), 1.4 )) {
104
+ null , true , 0 , false , false , true , new ArrayList <>(), Session . DEFAULT_HEARTBEAT_TIMEOUT_MULTIPLIER )) {
105
105
// Simulate socket disconnect
106
106
session .setResponder (null );
107
107
}
@@ -142,7 +142,7 @@ public void testNondisposableFileResources() throws Exception {
142
142
new DefaultMessageFactory (), 30 , false , 30 , UtcTimestampPrecision .MILLIS , true , false ,
143
143
false , false , false , false , true , false , 1.5 , null , true ,
144
144
new int [] { 5 }, false , false , false , false , true , false , true , false ,
145
- null , true , 0 , false , false , true , new ArrayList <>(), 1.4 )) {
145
+ null , true , 0 , false , false , true , new ArrayList <>(), Session . DEFAULT_HEARTBEAT_TIMEOUT_MULTIPLIER )) {
146
146
// Simulate socket disconnect
147
147
session .setResponder (null );
148
148
@@ -2074,7 +2074,7 @@ private void testSequenceResetGapFillWithChunkSize(int chunkSize)
2074
2074
UtcTimestampPrecision .MILLIS , resetOnLogon , false , false , false , false , false , true ,
2075
2075
false , 1.5 , null , validateSequenceNumbers , new int [] { 5 },
2076
2076
false , false , false , false , true , false , true , false , null , true ,
2077
- chunkSize , false , false , true , new ArrayList <>(), 1.4 )) {
2077
+ chunkSize , false , false , true , new ArrayList <>(), Session . DEFAULT_HEARTBEAT_TIMEOUT_MULTIPLIER )) {
2078
2078
2079
2079
UnitTestResponder responder = new UnitTestResponder ();
2080
2080
session .setResponder (responder );
@@ -2136,7 +2136,7 @@ public void correct_sequence_number_for_last_gap_fill_if_next_sender_sequence_nu
2136
2136
new DefaultMessageFactory (), 30 , false , 30 , UtcTimestampPrecision .MILLIS , resetOnLogon ,
2137
2137
false , false , false , false , false , true , false , 1.5 , null , validateSequenceNumbers ,
2138
2138
new int []{5 }, false , false , false , false , true , false , true , false , null , true , 0 ,
2139
- false , false , true , new ArrayList <>(), 1.4 );
2139
+ false , false , true , new ArrayList <>(), Session . DEFAULT_HEARTBEAT_TIMEOUT_MULTIPLIER );
2140
2140
2141
2141
Responder mockResponder = mock (Responder .class );
2142
2142
when (mockResponder .send (anyString ())).thenReturn (true );
@@ -2184,7 +2184,7 @@ public void correct_sequence_number_for_last_gap_fill_if_next_sender_sequence_nu
2184
2184
new DefaultMessageFactory (), 30 , false , 30 , UtcTimestampPrecision .MILLIS , resetOnLogon ,
2185
2185
false , false , false , false , false , true , false , 1.5 , null , validateSequenceNumbers ,
2186
2186
new int []{5 }, false , false , false , false , true , false , true , false , null , true , 0 ,
2187
- enableNextExpectedMsgSeqNum , false , true , new ArrayList <>(), 1.4 );
2187
+ enableNextExpectedMsgSeqNum , false , true , new ArrayList <>(), Session . DEFAULT_HEARTBEAT_TIMEOUT_MULTIPLIER );
2188
2188
2189
2189
Responder mockResponder = mock (Responder .class );
2190
2190
when (mockResponder .send (anyString ())).thenReturn (true );
@@ -2233,7 +2233,7 @@ public void testMsgSeqNumTooHighWithDisconnectOnError() throws Exception {
2233
2233
UtcTimestampPrecision .MILLIS , resetOnLogon , false , false , false , false , false , true ,
2234
2234
false , 1.5 , null , validateSequenceNumbers , new int [] { 5 },
2235
2235
false , disconnectOnError , false , false , true , false , true , false ,
2236
- null , true , 0 , false , false , true , new ArrayList <>(), 1.4 )) {
2236
+ null , true , 0 , false , false , true , new ArrayList <>(), Session . DEFAULT_HEARTBEAT_TIMEOUT_MULTIPLIER )) {
2237
2237
2238
2238
UnitTestResponder responder = new UnitTestResponder ();
2239
2239
session .setResponder (responder );
@@ -2269,7 +2269,7 @@ public void testTimestampPrecision() throws Exception {
2269
2269
UtcTimestampPrecision .NANOS , resetOnLogon , false , false , false , false , false , true ,
2270
2270
false , 1.5 , null , validateSequenceNumbers , new int [] { 5 },
2271
2271
false , disconnectOnError , false , false , true , false , true , false ,
2272
- null , true , 0 , false , false , true , new ArrayList <>(), 1.4 )) {
2272
+ null , true , 0 , false , false , true , new ArrayList <>(), Session . DEFAULT_HEARTBEAT_TIMEOUT_MULTIPLIER )) {
2273
2273
2274
2274
UnitTestResponder responder = new UnitTestResponder ();
2275
2275
session .setResponder (responder );
@@ -2321,7 +2321,7 @@ private void testLargeQueue(int N) throws Exception {
2321
2321
new DefaultMessageFactory (), isInitiator ? 30 : 0 , false , 30 , UtcTimestampPrecision .MILLIS , resetOnLogon ,
2322
2322
false , false , false , false , false , true , false , 1.5 , null , validateSequenceNumbers ,
2323
2323
new int []{5 }, false , false , false , false , true , false , true , false , null , true , 0 ,
2324
- false , false , true , new ArrayList <>(), 1.4 );
2324
+ false , false , true , new ArrayList <>(), Session . DEFAULT_HEARTBEAT_TIMEOUT_MULTIPLIER );
2325
2325
2326
2326
UnitTestResponder responder = new UnitTestResponder ();
2327
2327
session .setResponder (responder );
@@ -2437,7 +2437,7 @@ public void fromAdmin(Message message, SessionID sessionId) throws FieldNotFound
2437
2437
new DefaultMessageFactory (), isInitiator ? 30 : 0 , false , 30 , UtcTimestampPrecision .MILLIS , resetOnLogon ,
2438
2438
false , false , false , false , false , true , false , 1.5 , null , validateSequenceNumbers ,
2439
2439
new int []{5 }, false , false , false , false , true , false , true , false , null , true , 0 ,
2440
- enableNextExpectedMsgSeqNum , false , true , new ArrayList <>(), 1.4 );
2440
+ enableNextExpectedMsgSeqNum , false , true , new ArrayList <>(), Session . DEFAULT_HEARTBEAT_TIMEOUT_MULTIPLIER );
2441
2441
UnitTestResponder responder = new UnitTestResponder ();
2442
2442
session .setResponder (responder );
2443
2443
0 commit comments