Skip to content

Commit

Permalink
Do not pass Image header to initiating connection callback but rather…
Browse files Browse the repository at this point in the history
… values at time of initiating session
  • Loading branch information
marc-adaptive committed Jan 24, 2025
1 parent 44d03e3 commit 1f212eb
Showing 1 changed file with 8 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1368,6 +1368,8 @@ public Action onInitiateConnection(
{
DebugLogger.log(FIX_CONNECTION, connectingFormatter, host, port, libraryId);

final int outboundSessionId = header.sessionId();
final long outboundPositionId = header.position();
final InetSocketAddress address = new InetSocketAddress(host, port);
final ConnectingSession connectingSession = new ConnectingSession(address, sessionContext.sessionId());
library.connectionStartsConnecting(correlationId, connectingSession);
Expand All @@ -1394,7 +1396,8 @@ public Action onInitiateConnection(
fixDictionaryClass,
heartbeatIntervalInS,
correlationId,
header,
outboundSessionId,
outboundPositionId,
library,
address,
channel,
Expand Down Expand Up @@ -1548,7 +1551,8 @@ private void onFixConnectionOpen(
final Class<? extends FixDictionary> fixDictionaryClass,
final int heartbeatIntervalInS,
final long correlationId,
final Header outBoundheader,
final int outboundSessionId,
final long outboundPositionId,
final LiveLibraryInfo library,
final InetSocketAddress address,
final TcpChannel channel,
Expand Down Expand Up @@ -1607,8 +1611,8 @@ private void onFixConnectionOpen(
connectionId,
sessionId,
gatewaySession,
outBoundheader.sessionId(),
outBoundheader.position(),
outboundSessionId,
outboundPositionId,
address.toString(),
INITIATOR);
}
Expand Down

0 comments on commit 1f212eb

Please sign in to comment.