| Package | Description |
|---|---|
| biz.onixs.fix.engine | |
| biz.onixs.fix.scheduler |
| Modifier and Type | Method and Description |
|---|---|
Session |
Session.addStateChangeListener(Session.StateChangeListener listener)
Adds state change listener.
|
Session |
Session.breakConnection()
The socket is closed.
|
Session |
Engine.DynamicAcceptorArgs.getCreatedSession() |
Session |
Session.logonAsAcceptor()
Establishes FIX Connection as Acceptor.
|
Session |
Session.logonAsInitiator(String host,
int port)
Establishes FIX Connection as Initiator using the default heartbeat value.
|
Session |
Session.logonAsInitiator(String host,
int port,
boolean setResetSeqNumFlag)
Establishes FIX connection as Initiator.
|
Session |
Session.logonAsInitiator(String host,
int port,
boolean setResetSeqNumFlag,
Message customLogonMsg)
Establishes FIX connection as Initiator using the custom Logon message.
|
Session |
Session.logonAsInitiator(String host,
int port,
int heartBtInt)
Establishes FIX connection as Initiator.
|
Session |
Session.logonAsInitiator(String host,
int port,
int heartBtInt,
boolean setResetSeqNumFlag)
Establishes FIX connection as Initiator.
|
Session |
Session.logonAsInitiator(String host,
int port,
int heartBtInt,
boolean setResetSeqNumFlag,
Message customLogonMsg)
Establishes FIX connection as Initiator using the custom Logon message.
|
Session |
Session.logonAsInitiator(String host,
int port,
int heartBtInt,
Message customLogonMsg)
Establishes FIX connection as Initiator using the custom Logon message.
|
Session |
Session.logonAsInitiator(String host,
int port,
Message customLogonMsg)
Establishes FIX connection as Initiator using the custom Logon message.
|
Session |
Session.logout()
Terminates the FIX connection.
|
Session |
Session.logout(Message logoutMessage)
Terminates the FIX connection.
|
Session |
Session.logout(String text)
Terminates the FIX connection.
|
Session |
Session.preFill(FlatMessage flatMessage)
Pre-fills session-level fields that are constant during the session's lifetime - SenderCompId, TargetCompId,
SenderLocationId, TargetLocationID, SenderSubID, TargetSubID and removing PossDupFlag.
|
Session |
Session.preFill(List<Message> messages)
Pre-fills session-level fields that are constant during the session's lifetime - SenderCompId, TargetCompId,
SenderLocationId, TargetLocationID, SenderSubID, TargetSubID and removing PossDupFlag.
|
Session |
Session.preFill(Message message)
Pre-fills session-level fields that are constant during the session's lifetime - SenderCompId, TargetCompId,
SenderLocationId, TargetLocationID, SenderSubID, TargetSubID and removing PossDupFlag.
|
Session |
Session.removeStateChangeListener(Session.StateChangeListener listener)
Removes state change listener.
|
Session |
Session.resetLocalSequenceNumbers()
Resets the local sequence numbers to 1 and backups the current log files.
|
Session |
Session.resetSeqNumViaLogonExchange()
Sends a Logon message with the ResetSeqNumFlag set.
|
Session |
Session.send(ByteBuffer rawMsg)
Sends the raw message to the counterparty without any updating (seq.
|
Session |
Session.send(FlatMessage message)
Sends the flat message to the counterparty.
|
Session |
Session.send(List<Message> messages)
Sends the structured messages to the counterparty.
|
Session |
Session.send(Message message)
Sends the structured message to the counterparty.
|
Session |
Session.sendAsIs(FlatMessage message)
Sends the flat message to the counterparty without any fields updating (except MsgSeqNum(34)).
|
Session |
Session.sendAsIs(Message message)
Sends the structured message to the counterparty without any fields updating (except MsgSeqNum(34)).
|
Session |
Session.sendResendRequest(long beginSeqNumber)
Sends the Resend Request (MsgType 2) message.
|
Session |
Session.sendTestRequest(String testReqId,
long timeoutInMilliseconds)
Sends the Test Request (1) message.
|
Session |
Session.setConnectionMode(ConnectionMode connectionMode)
Sets session connection mode.
|
Session |
Session.setConsiderRejectOnResendRequestAsGapFill(boolean considerRejectOnResendRequestAsGapFill)
Sets whether to consider Reject(3) on Resend Request(2) as Gap Fill.
|
Session |
Session.setErrorListener(Session.ErrorListener listener)
Sets error listener.
|
Session |
Session.setEventArgReuse(boolean eventArgReuse)
Sets whether to re-use event argument objects.
|
Session |
Session.setInboundApplicationFlatMessageFactory(FlatMessageFactory messageFactory)
Sets flat message factory to use for creating inbound application flat message instance.
|
Session |
Session.setInboundApplicationFlatMessageListener(Session.InboundApplicationFlatMessageListener listener)
Sets inbound application flat message listener.
|
Session |
Session.setInboundApplicationMessageFactory(MessageFactory messageFactory)
Sets message factory to use for creating inbound application message instance.
|
Session |
Session.setInboundApplicationMessageListener(Session.InboundApplicationMessageListener listener)
Sets inbound application message listener.
|
Session |
Session.setInboundMessageLogFilter(MessageFilter inboundMessageLogFilter)
Sets
MessageFilter object used to filter out inbound messages from the logs. |
Session |
Session.setInboundMessageReuse(boolean inboundMessageReuse)
Sets whether to use the same
FixMessage object for the incoming messages. |
Session |
Session.setInboundSessionFlatMessageFactory(FlatMessageFactory messageFactory)
Sets flat message factory to use for creating inbound session flat message instance.
|
Session |
Session.setInboundSessionFlatMessageListener(Session.InboundSessionFlatMessageListener listener)
Sets inbound session flat message listener.
|
Session |
Session.setInboundSessionMessageFactory(MessageFactory messageFactory)
Sets message factory to use for creating inbound session message instance.
|
Session |
Session.setInboundSessionMessageListener(Session.InboundSessionMessageListener listener)
Sets inbound session message listener.
|
Session |
Session.setIncomingMessageGapQueueMaximumSize(int maxSize)
If RequestOnlyMissedMessages feature is enabled and the sequence number of an incoming FIX message
greater than expected then the resend functionality is run and this incoming message is stored
in the incoming message gap queue for further processing.
|
Session |
Session.setInSeqNum(long seqNum)
Sets the expected sequence number of the next incoming message.
|
Session |
Session.setListenPort(int listenPort)
Sets the port to listen on for incoming FIX Connections in Acceptor mode.
|
Session |
Session.setLocalPortRange(PortRange localPortRange)
Sets the local port range, the first available port from this range
will be used to send and receive data.
|
Session |
Session.setLogBeforeSending(boolean logBeforeSending)
Sets whether outbound messages are logged before sending.
|
Session |
Session.setLogInboundMessages(boolean logIncomingMessages)
Sets whether to store inbound messages in the session storage.
|
Session |
Session.setLogonConfirmationTimeout(int logonConfirmationTimeout)
Sets number of seconds to wait for a logon response before disconnecting.
|
Session |
Session.setLogOutboundMessages(boolean logOutboundMessages)
Sets whether to store outbound messages in the session storage.
|
Session |
Session.setLogoutConfirmationTimeout(int logoutConfirmationTimeout)
Sets number of seconds to wait for a logout response before disconnecting.
|
Session |
Session.setLogoutMessage(Message logoutMessage)
Sets logout message.
|
Session |
Session.setMaxStorageSize(int maximumSize)
Sets the maximum size of the storage in messages.
|
Session |
Session.setMessageMode(MessageMode messageMode)
Sets message mode used for processing/parsing raw messages internally.
|
Session |
Session.setMessageResendingListener(Session.MessageResendingListener listener)
Sets message resending listener.
|
Session |
Session.setMessageSendingListener(Session.MessageSendingListener listener)
Sets message sending listener.
|
Session |
Session.setNetworkInterface(SocketAddress bindAddress)
Sets the network interface bind address for establishing initiator session.
|
Session |
Session.setOutboundApplicationFlatMessageListener(Session.OutboundApplicationFlatMessageListener listener)
Sets outbound application flat message listener.
|
Session |
Session.setOutboundApplicationMessageListener(Session.OutboundApplicationMessageListener listener)
Sets outbound application message listener.
|
Session |
Session.setOutboundSessionMessageListener(Session.OutboundSessionMessageListener listener)
Sets outbound session message listener.
|
Session |
Session.setOutSeqNum(long seqNum)
Sets the sequence number of the next outgoing message.
|
Session |
Session.setProcessLogonNextExpectedMsgSeqNum(boolean processLogonNextExpectedMsgSeqNum)
Sets whether to process NextExpectedMsgSeqNum(789) field in Logon(A).
|
Session |
Session.setProxySettings(ProxySettings proxySettings)
Sets proxy settings for the session see
ProxySettings. |
Session |
Session.setReasonableTransmissionTime(int reasonableTransmissionTime)
Sets reasonable transmission time as % from heartbeat interval value.
|
Session |
Session.setReceiveBufferSize(int size)
Sets the size of the TCP socket buffer allocated for receiving data, in bytes.
|
Session |
Session.setReceivedBytesListener(Session.ReceivedBytesListener listener)
Sets received bytes listener.
|
Session |
Session.setReceiveSpinningTimeout(long timeout)
Sets the non-blocking receive spinning timeout (in nanoseconds) before the receiving thread enters into the
blocking wait mode.
|
Session |
Session.setReceivingThreadAffinity(int[] cpuIndexes)
Sets the receiving thread affinity.
|
Session |
Session.setReportNewMessagesWhileWaitingForMissedMessages(boolean report)
When the message gap is detected the "Resend Request" FIX Message is sent and
Session state is changed to WAIT_FOR_RETRANSMISSION.
|
Session |
Session.setRequestOnlyMissedMessages(boolean request)
By default, the "Resend Request" message requests all messages begin from the first missed one.
|
Session |
Session.setResendingQueueSize(int resendingQueueSize)
Sets the number of sent messages that are available for resending on counterparty's Resend Request(2) message.
|
Session |
Session.setResendRequestLogic(ResendRequestLogic resendRequestLogic)
Sets resend request logic.
|
Session |
Session.setResendRequestMaximumRange(int resendRequestMaximumRange)
Sets the maximum number of messages to be requested in one Resend Request (MsgType=2) message.
|
Session |
Session.setScrambleLogonFields(Collection<Integer> fields)
Sets scrambled fields in the Logon(A) message, in the session storage, for security reasons.
|
Session |
Session.setSendBufferSize(int sendBufferSize)
Sets the size of the TCP socket buffer allocated for sending data, in bytes.
|
Session |
Session.setSenderLocationID(String senderLocationID)
Sets the value of SenderLocationID (142) field that will be set in all outgoing messages.
|
Session |
Session.setSenderSubID(String senderSubID)
Sets the value of SenderSubID (50) field that will be set in all outgoing messages.
|
Session |
Session.setSendingThreadAffinity(int[] cpuIndexes)
Sets the sending thread affinity.
|
Session |
Session.setSendingTimeFormat(TimestampFormat format)
Sets the time format of SendingTime of every sent message as
Timestamp. |
Session |
Session.setSendSpinningTimeout(long timeout)
Sets the send spinning timeout (in nanoseconds) of the
send(Message) method to wait for the
socket sending buffer availability in the spin loop mode before placing the message to the outgoing queue
(to be sent later by the sending thread). |
Session |
Session.setSpecifyApplIdField(boolean specifyApplIdField)
Sets whether to specify ApplVerID(1128) tag in all FIX messages when a FIX protocol version FIX 5.0 and
above is used.
|
Session |
Session.setSpecifyLastMsgSeqNumProcessed(boolean specifyLastMsgSeqNumProcessed)
Sets the option to specify the LastMsgSeqNumProcessed (tag # 369) field on every message sent.
|
Session |
Session.setSSLContext(SSLContext sslContext)
Sets the SSL context for establishing secure initiator session.
|
Session |
Session.setTargetLocationID(String targetLocationID)
Sets the value of TargetLocationID (143) field that will be set in all outgoing messages.
|
Session |
Session.setTargetSubID(String targetSubID)
Sets the value of TargetSubID (57) field that will be set in all outgoing messages.
|
Session |
Session.setTcpNoDelay(boolean on)
Enable/disable TCP_NODELAY socket option (disable/enable Nagle's algorithm).
|
Session |
Session.setTestRequestIdPattern(String pattern)
Sets the pattern describing the date and time format which will be used as a TestReqID(112) field value.
|
Session |
Session.setThrottlingLimit(int messagesCount,
long intervalDurationInMillis)
Sets the throttling limit parameters.
|
Session |
Session.setThrottlingLimit(int messagesCount,
long intervalDuration,
TimeUnit intervalUnit)
Sets throttling limit parameters.
|
Session |
Session.setTimestampProvider(TimestampProvider timestampProvider)
Sets the timestamp provider which is used to provide timestamp for writing messages to log and for setting
SendingTime tag.
|
Session |
Session.setUpdateSendingTime(boolean updateSendingTime)
Sets whether to update
SendingTime(52)
field in the outgoing message if it is already set.
|
Session |
Session.setUserSessionLevelMessageWarning(boolean userSessionLevelMessageWarning)
Sets whether to warn if user sends session level message.
|
Session |
Session.setValidateSequenceNumbers(boolean validateSequenceNumbers)
Sets whether to validate incoming message sequence numbers.
|
Session |
Session.setWarningListener(Session.WarningListener listener)
Sets warning listener.
|
Session |
Session.throttle()
Performs throttling of a session.
|
Session |
Session.warmUp(Message message)
Warms up the sending path.
|
| Modifier and Type | Method and Description |
|---|---|
void |
Engine.DynamicAcceptorArgs.setCreatedSession(Session createdSession) |
| Modifier and Type | Method and Description |
|---|---|
Session |
ErrorListener.ErrorArgs.getSession()
Returns the session.
|
Session |
InitiatorConnectingArgs.getSession()
Returns session which will be connected.
|
Session |
LogoutNotification.getSession()
Returns session.
|
| Modifier and Type | Method and Description |
|---|---|
void |
InitiatorConnection.logon(Session session)
Logons the session.
|
void |
SessionConnection.logon(Session session) |
SessionScheduler |
SessionScheduler.register(Session session,
SchedulerSettings settings,
String scheduleId)
Registers acceptor session.
|
SessionScheduler |
SessionScheduler.register(Session session,
SchedulerSettings settings,
String scheduleId,
SessionConnection connection)
Registers session.
|
SessionScheduler |
SessionScheduler.register(Session session,
SchedulerSettings settings,
String scheduleId,
String connectionId)
Registers session.
|
SessionScheduler |
SessionScheduler.register(Session session,
SessionSchedule schedule,
SchedulerSettings settings,
String connectionId)
Registers session.
|
SessionScheduler |
SessionScheduler.register(Session session,
SessionSchedule schedule,
SessionConnection connection)
Registers session.
|
SessionScheduler |
SessionScheduler.registerAcceptor(Session session,
SessionSchedule schedule)
Registers acceptor session.
|
SessionScheduler |
SessionScheduler.unregister(Session session)
Un-registers session.
|
| Constructor and Description |
|---|
LogonErrorArgs(Session session,
Exception exception,
String description,
int currentAttempt,
int maxAttempt) |
Copyright © 2005–2024 Onix Solutions. All rights reserved.