Kamal: Created page with "The NeoeMarketDataFeedClient disseminates real-time market data for the Aequitas NEO Exchange. It connects to the Service Locator for authentication and provides order boo..."

2026-05-27T20:18:37Z

Created page with "The NeoeMarketDataFeedClient disseminates real-time market data for the Aequitas NEO Exchange. It connects to the Service Locator for authentication and provides order boo..."

New page

The NeoeMarketDataFeedClient disseminates real-time market data for the Aequitas NEO Exchange. It connects to the [[Service Locator]] for authentication and provides order book data, time and sales, and the consolidated best bid offer (CBBO) for the NEO Exchange.

The feed is split into multiple channels for disseminating the CBBO, book, and trade data. Each channel resides in its own subdirectory whose name starts with the <code>neoe</code> prefix: <code>neoe_cbbo</code>, <code>neoe_cls</code>, and <code>neoe_book</code> for the CBBO, time and sales, and book feeds respectively.

== Configuration ==

Each channel is configured via a YAML file (<code>config.yml</code>) with the following structure:

<pre>
service_locator:
# The address of the Service Locator (host:port).
address: "127.0.0.1:20000"
# The account username used to authenticate with the Service Locator.
username: market_data_feed
# The password for the Service Locator account.
password: [REQUIRED]

# Rate at which market data snapshots are sampled and forwarded to the
# Market Data Server.
sampling: 100ms

# Multicast group address and port for the feed.
host: "239.0.0.1:30501"

# Network interface to join the multicast group on.
interface: "0.0.0.0:0"

# UDP socket receive buffer size in bytes (default: 128 MB).
receive_buffer: 134217728

# Maximum datagram size (MTU) in bytes (optional; defaults to system MTU).
mtu: 1500

# Retransmission endpoints for recovering dropped packets.
retransmission_request_address: "142.201.149.44:61030"
retransmission_response_address: "142.201.149.44:61031"

# Whether retransmission requests are enabled (default: false).
enable_retransmission: false

# Maximum number of retransmission requests before giving up (default: 10).
max_retransmissions: 10

# Maximum number of messages requested in a single retransmission block (default: 20000).
retransmission_block_size: 20000

# Time zone used to compute the feed's time offset (default: "America/Toronto").
time_zone: "America/Toronto"

# Enable logging of every received message (off by default; verbose when enabled).
enable_logging: false

# Whether this channel carries time and sales data.
is_time_and_sale: false

# Optional MPID rewriting: maps source IDs to canonical MPID names.
mpid_mappings:
- source: 1
name: ANON

# Path to the security master list (symbols.yml).
symbol_list: "symbols.yml"
</pre>

The <code>sampling</code>, <code>host</code>, <code>interface</code>, <code>retransmission_request_address</code>, <code>retransmission_response_address</code>, and <code>symbol_list</code> fields are required. All other fields have defaults.

== Security Master ==

A security master list of traded securities is typically stored in the <code>symbols.yml</code> file with the following format:

<pre>
- symbol: AAPL # The ticker symbol.
name: APPLE CDR (CAD HEDGED) # The name of the security.
board_lot: 100 # The security's board lot.
</pre>

Changes can be made in this security master list and reloaded by restarting the NEOE CBBO feed.

== Setup ==

The <code>setup.py</code> Python script configures all of the channels at once and can be called as follows:

<pre>
--local 192.168.0.100 # Local interface (default: auto-detected IP)
--address 127.0.0.1:20000 # Service Locator address
--username market_data_feed # Service Locator username (default: market_data_feed)
--password [REQUIRED] # Service Locator password
</pre>

== Management ==

Each channel is managed through three core scripts:

* <code>start.sh</code> - Starts the channel. Does nothing if the channel is already running.
* <code>stop.sh</code> - Stops the channel and waits for the channel to terminate.
* <code>check.sh</code> - Verifies that the channel is running.

== Logging ==

Log files are generated as <code>srv_[YYYY][MM][DD]_[HH]_[MM]_[SS].log</code> in the runtime directory. Upon termination, non-empty log files are moved into the <code>log/</code> subfolder, while empty log files are deleted.

NeoeMarketDataFeedClient - Revision history

Kamal: Created page with "The NeoeMarketDataFeedClient disseminates real-time market data for the Aequitas NEO Exchange. It connects to the Service Locator for authentication and provides order boo..."