Functions — github.com/aws-samples/amazon-resilient-fix-engine-demo

CodeHub MCPcopy Create free account

hub / github.com/aws-samples/amazon-resilient-fix-engine-demo / functions

Functions100 in github.com/aws-samples/amazon-resilient-fix-engine-demo

⨍ Functions 100◇ Types & classes 11

↓ 20 callersMethodget

(int startSequence, int endSequence, Collection<String> messages)

src/main/java/com/amazonaws/fixengineonaws/RedisStore.java:169

↓ 17 callersMethodgetSessionSetting

Searches SessionSettings for a setting with the given name and returns the value of the first instance it finds (regardless of what section it's found

src/main/java/com/amazonaws/fixengineonaws/FixEngineConfig.java:249

↓ 17 callersMethodset

(int sequence, String message)

src/main/java/com/amazonaws/fixengineonaws/RedisStore.java:180

↓ 11 callersMethodgetNextSenderMsgSeqNum

src/main/java/com/amazonaws/fixengineonaws/RedisStore.java:133

↓ 11 callersMethodgetNextTargetMsgSeqNum

src/main/java/com/amazonaws/fixengineonaws/RedisStore.java:138

↓ 8 callersMethodcreate

Create a JDBC message store. @param sessionID the sessionID for the message store.

src/main/java/com/amazonaws/fixengineonaws/RedisStoreFactory.java:30

↓ 8 callersMethodgetSqlValue

(String javaValue, String defaultSqlValue)

src/main/java/com/amazonaws/fixengineonaws/RedisStore.java:88

↓ 6 callersMethodgetSessionSettings

Returns populated, detokenized and validated quickfix.SessionSettings object @return

src/main/java/com/amazonaws/fixengineonaws/FixEngineConfig.java:74

↓ 5 callersMethodgetSessionID

src/main/quickfix/AbstractMessageStoreTest.java:94

↓ 5 callersMethodreset

src/main/java/com/amazonaws/fixengineonaws/RedisStore.java:159

↓ 4 callersMethodfindSessionSetting

Searches SessionSettings for a setting with the given name and returns the sessionProperty tuple containing the first instance it finds (regardless of

src/main/java/com/amazonaws/fixengineonaws/FixEngineConfig.java:204

↓ 4 callersMethodgetMessageStoreFactory

src/main/java/com/amazonaws/fixengineonaws/RedisStoreTest.java:48

↓ 3 callersMethodcloneSessionSettings

Returns a new SessionSettings object with the exact same content as the original This is a wourkaround for a bug in sessionSettings where simply setti

src/main/java/com/amazonaws/fixengineonaws/FixEngineConfig.java:96

↓ 3 callersMethodlogStats

prints a @param count @param firstOrderTime @param lastOrderTime

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:275

↓ 3 callersMethodrefresh

src/main/java/com/amazonaws/fixengineonaws/RedisStore.java:192

↓ 3 callersMethodsetNextSenderMsgSeqNum

src/main/java/com/amazonaws/fixengineonaws/RedisStore.java:143

↓ 3 callersMethodsetNextTargetMsgSeqNum

src/main/java/com/amazonaws/fixengineonaws/RedisStore.java:147

↓ 2 callersMethodcloseMessageStore

(MessageStore store)

src/main/quickfix/AbstractMessageStoreTest.java:170

↓ 2 callersMethodgetCreationTime

src/main/java/com/amazonaws/fixengineonaws/RedisStore.java:127

↓ 2 callersMethodgetMessageStoreFactory

src/main/quickfix/AbstractMessageStoreTest.java:55

↓ 2 callersMethodinitRedis

src/main/java/com/amazonaws/fixengineonaws/RedisStore.java:106

↓ 2 callersMethodlogStats

(boolean appToFix, int count, Date firstOrderTime, Date lastOrderTime)

src/main/java/com/amazonaws/fixengineonaws/TestClient.java:113

↓ 2 callersMethodsetSessionSetting

Searches SessionSettings for a setting with the given name and sets the value of the first instance it finds (regardless of what section it's found in

src/main/java/com/amazonaws/fixengineonaws/FixEngineConfig.java:267

↓ 2 callersMethodstartFixServer

Creates QuickFix SocketAcceptor class, calls start() on it and assigns it to global variable FIX_SERVER Uses the FIX_SERVER to look up the FIX session

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:465

↓ 1 callersMethodcreateStore

src/main/quickfix/AbstractMessageStoreTest.java:63

↓ 1 callersMethodfixStringToOrder

(String orderStr)

src/test/java/com/amazonaws/fixengineonaws/FixEncoderDecoderDemo.java:77

↓ 1 callersMethodgenerateExecution

src/test/java/com/amazonaws/fixengineonaws/TestClient.java:124

↓ 1 callersMethodgenerateExecution

src/main/java/com/amazonaws/fixengineonaws/TestServer.java:41

↓ 1 callersMethodgenerateOrder

src/test/java/com/amazonaws/fixengineonaws/TestClient.java:93

↓ 1 callersMethodgenerateOrder

src/test/java/com/amazonaws/fixengineonaws/FixEncoderDecoderDemo.java:42

↓ 1 callersMethodgenerateOrder

src/main/java/com/amazonaws/fixengineonaws/TestClient.java:40

↓ 1 callersMethodgenerateOrders

src/test/java/com/amazonaws/fixengineonaws/TestClient.java:212

↓ 1 callersMethodgenerateOrders

(int numberOfMessages, int waitBetweenMessages, String queueName)

src/main/java/com/amazonaws/fixengineonaws/TestClient.java:142

↓ 1 callersMethodgetDataSource

src/main/java/com/amazonaws/fixengineonaws/RedisStoreTest.java:104

↓ 1 callersMethodgetKafkaConsumer

src/test/java/com/amazonaws/fixengineonaws/TestClient.java:271

↓ 1 callersMethodgetKafkaProducer

src/test/java/com/amazonaws/fixengineonaws/TestClient.java:200

↓ 1 callersMethodgetKafkaProperties

(String configfile)

src/test/java/com/amazonaws/fixengineonaws/TestClient.java:378

↓ 1 callersMethodgetLeaderStatus

Calls heartbeatSprocStmt to determine if the current engine is still tht leader, still not the leader, or just became the leader. @param heartbeatSpro

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:416

↓ 1 callersMethodgetMessageStoreClass

src/main/quickfix/AbstractMessageStoreTest.java:57

↓ 1 callersMethodgetMessageStoreFactoryForTest

src/main/quickfix/AbstractMessageStoreTest.java:48

↓ 1 callersMethodgetMyIp

Returns the IP address of the host running this code as a String @return

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:226

↓ 1 callersMethodgetSessionUniqueId

src/main/java/com/amazonaws/fixengineonaws/RedisStore.java:92

↓ 1 callersMethodgetSsmParameter

Retrieves SSM parameter by name (using prefix returned by getSsmParameterPath()). If run on Windows, returns dummy values hard coded at the start of t

src/main/java/com/amazonaws/fixengineonaws/FixEngineConfig.java:143

↓ 1 callersMethodgetSsmParameterPath

Retrieves APPLICATION_STACK_NAME from the Java runtime's OS ENV variables SSM paths are expected to look like: /fixengine/<APPLICATION_STACK_NAME>/<to

src/main/java/com/amazonaws/fixengineonaws/FixEngineConfig.java:116

↓ 1 callersMethodgetStore

src/main/quickfix/AbstractMessageStoreTest.java:59

↓ 1 callersMethodheartbeatMessageProcessingLoop

Decides whether it's a client or server based on ConnectionType setting in FixEngineConfig. Calls getHeartbeatSprocStmt to create a DB connection and

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:572

↓ 1 callersMethodincrNextSenderMsgSeqNum

src/main/java/com/amazonaws/fixengineonaws/RedisStore.java:151

↓ 1 callersMethodincrNextTargetMsgSeqNum

src/main/java/com/amazonaws/fixengineonaws/RedisStore.java:155

↓ 1 callersMethodinitializeParameters

Use the file at the specified location to create a SessionSettings object, then call overrideConfigFromSsmParameters() to replace any tokens with valu

src/main/java/com/amazonaws/fixengineonaws/FixEngineConfig.java:317

↓ 1 callersMethodlogStats

(boolean appToFix, int count, Date firstOrderTime, Date lastOrderTime)

src/main/java/com/amazonaws/fixengineonaws/TestServer.java:95

↓ 1 callersMethodorderToFixString

(NewOrderSingle order)

src/test/java/com/amazonaws/fixengineonaws/FixEncoderDecoderDemo.java:73

↓ 1 callersMethodoverrideConfigFromSsmParameters

Searches SessionSettings for values with tokens (formatted as <TOKEN_NAME>) and replaces them with parameters with the same name from SSM parameter st

src/main/java/com/amazonaws/fixengineonaws/FixEngineConfig.java:284

↓ 1 callersMethodparseOrder

Parses FIX string to a QuickFixJ Message object @param fixString @return

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:253

↓ 1 callersMethodpollForOrders

(int waitBetweenMessages, String inboundQueueName, String outboundQueueName, boolean replyWithExecution)

src/main/java/com/amazonaws/fixengineonaws/TestServer.java:123

↓ 1 callersMethodpollForReplies

(int waitBetweenMessages, String inboundQueueName)

src/main/java/com/amazonaws/fixengineonaws/TestClient.java:171

↓ 1 callersMethodprocessInboundAppToFixMessages

Parses FIX-formatted message String from MemoryDB ConsumerRecord parameter into a QuickFixJ Message object, then sends that object out via the FIX con

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:307

↓ 1 callersMethodprocessKafkaMsgs

src/test/java/com/amazonaws/fixengineonaws/TestClient.java:296

↓ 1 callersMethodrun

Calls heartbeatMessageProcessingLoop and catches/logs any errors

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:126

↓ 1 callersMethodsetDataSource

src/main/java/com/amazonaws/fixengineonaws/RedisStoreFactory.java:47

↓ 1 callersMethodsetupKafka

(String configfile)

src/test/java/com/amazonaws/fixengineonaws/TestClient.java:192

↓ 1 callersMethodstartFixClient

Creates QuickFix SocketInitiator class, calls start() on it and assigns it to global variable FIX_CLIENT Uses the FIX_CLIENT to look up the FIX sessio

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:498

↓ 1 callersMethodstopFixClient

Stops FIX_CLIENT and nulls out FIX_SESSION and FIX_CLIENT

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:549

↓ 1 callersMethodupdateGAEndpoints

Re-points Global Accelerator endpoint (specified by myGaEndpointGroupArn) to the endpoint that's running this code (specified by myGaEndpointArn) @par

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:360

↓ 1 callersMethodvalidateSessionSettings

Ensure that all the settings listed in the required<Client|Server>ConfigFields variable for the current ConnectionType (initiator/accpetor) are presen

src/main/java/com/amazonaws/fixengineonaws/FixEngineConfig.java:343

MethodFixEngine

Constructor creates a LOGGER and a FixEngineConfig using the specified configfile location, in preparation for calling run() @param configfile @throws

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:108

MethodFixEngineConfig

Constructor initializes a quickfix.SessionSettings object from YAML .cfg file denoted by <configfile> parameter, overrides it with SSM parameters and

src/main/java/com/amazonaws/fixengineonaws/FixEngineConfig.java:55

MethodRedisStore

(SessionSettings settings, SessionID sessionID, Jedis jedisParam)

src/main/java/com/amazonaws/fixengineonaws/RedisStore.java:41

MethodRedisStoreFactory

Create a factory using session settings.

src/main/java/com/amazonaws/fixengineonaws/RedisStoreFactory.java:21

MethodcloneSessionSettingsWithNewPort

Returns a clone of the current populated, detokenized and validated quickfix.SessionSettings object, but with a new FIX port value substituted into th

src/main/java/com/amazonaws/fixengineonaws/FixEngineConfig.java:82

MethodfromAdmin

QuickFixJ Application interface hook

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:180

QuickFixJ Application interface hook - called when a message is received by this process from the FIX connection decodes the message and forwards it t

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:196

MethodgetConfigurationFileName

src/main/quickfix/AbstractMessageStoreTest.java:174

MethodgetMessageStoreClass

src/main/java/com/amazonaws/fixengineonaws/RedisStoreTest.java:133

MethodgetSettings

Used to support the MySQL-specific class (JNI compatibility) @return the session settings

src/main/java/com/amazonaws/fixengineonaws/RedisStoreFactory.java:43

(String[] args)

src/test/java/com/amazonaws/fixengineonaws/TestClient.java:142

(String[] args)

src/test/java/com/amazonaws/fixengineonaws/FixEncoderDecoderDemo.java:103

(String[] args)

src/main/java/com/amazonaws/fixengineonaws/TestClient.java:71

src/main/java/com/amazonaws/fixengineonaws/RedisStore.java:196

Instantiates FixEngine class using configfile location from args[0], then calls run() on it @param args @throws ConfigError

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:646

(String[] args)

src/main/java/com/amazonaws/fixengineonaws/TestServer.java:57

QuickFixJ Application interface hook - called when FIX session object is first created

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:147

QuickFixJ Application interface hook - called when FIX session is established

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:155

QuickFixJ Application interface hook - called when FIX session is logged out

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:164

MethodsetLogLevel

Sets the LOGGER's log level to INFO (for regular operation) if the parameter is false or FINE (for debugging) if the parameter is true @param enableFi

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:241

MethodsetTestEnabled

src/main/quickfix/AbstractMessageStoreTest.java:178

src/main/quickfix/AbstractMessageStoreTest.java:35

src/main/java/com/amazonaws/fixengineonaws/RedisStoreTest.java:26

MethodstopFixServer

Stops FIX_SERVER and nulls out FIX_SESSION and FIX_SERVER

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:539

src/main/java/com/amazonaws/fixengineonaws/RedisStoreTest.java:35

MethodtestCreationTime

src/main/java/com/amazonaws/fixengineonaws/RedisStoreTest.java:122

MethodtestExplicitDataSource

src/main/java/com/amazonaws/fixengineonaws/RedisStoreTest.java:77

MethodtestMessageStorageMessages

src/main/quickfix/AbstractMessageStoreTest.java:98

MethodtestMessageStorageMessagesWithCustomMessagesTableName

src/main/java/com/amazonaws/fixengineonaws/RedisStoreTest.java:90

MethodtestMessageStorageOutOfSequence

src/main/quickfix/AbstractMessageStoreTest.java:116

MethodtestMessageStoreSequenceNumbers

src/main/quickfix/AbstractMessageStoreTest.java:67

MethodtestMessageUpdate

src/main/java/com/amazonaws/fixengineonaws/RedisStoreTest.java:137

MethodtestRefreshMessageStore

src/main/quickfix/AbstractMessageStoreTest.java:133

MethodtestSequenceNumbersWithCustomSessionsTableName

src/main/java/com/amazonaws/fixengineonaws/RedisStoreTest.java:83

QuickFixJ Application interface hook

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:173

QuickFixJ Application interface hook - called when a message is being sent by this process out via the FIX connection

src/main/java/com/amazonaws/fixengineonaws/FixEngine.java:187