Example: FIX Input Adapter Data Stream

This is a Quote type FIX message:

8=FIX.4.4 | 9=204 | 35=S | 49=COUNTERPARTYA | 55=AASymbol | 117=AAQuoteID | 133=31.1 | 453=2 | 448=AAPartyID1 | 447=B | 452=1 | 802=2 | 523=AAPartySubID11 | 803=1 | 523=AAPartySubID12 | 803=2 | 448=AAPartyID2 | 447=C | 452=2 | 802=1 | 523=AAPartySubID21 | 803=3 | 10=107 |

That contains these fields:

• SenderCompID=COUNTERPARTYA (tag 49)
• QuoteID=AAQuoteID (tag 117)
• Symbol=AASymbol (tag 55)
• OfferPx=31.1 (tag 133)
• NoPartyIDs=2 (tag 453)

The message for Event Stream Processor is in this main stream:

<SourceStream id="MyQuotes" store="FixStore">
	<Column datatype="string" name="SenderCompID"/>
	<Column datatype="string" name="QuoteID"/>
	<Column datatype="integer" name="NoPartyIDs"/>
	<Column datatype="string" name="Symbol"/>
	<Column datatype="float" name="OfferPx"/>
	<Column datatype="long" name="FixMsgId" key="true"/>
</SourceStream>

This is the message for the Server:

CREATE  MEMORY  STORE FixStore PROPERTIES  INDEXTYPE ='tree',  INDEXSIZEHINT =8;


CREATE  INPUT  WINDOW MyQuotes
SCHEMA (SenderCompID STRING, QuoteID STRING, NoPartyIDs INTEGER, Symbol STRING, OfferPx FLOAT, FixMsgId LONG)
PRIMARY KEY (FixMsgId)
 STORE FixStore;

The message contains two groups of type NoPartyIDs:

Group 1:

• PartyID=AAPartyID1 (tag 448)
• PartyIDSource=B (tag 447)
• PartyRole=1 (Executing Firm, tag 452)
• NoPartySubIDs=2 (tag 802)

Group 2:

• PartyID=AAPartyID1 (tag 448)
• PartyIDSource=C (tag 447)
• PartyRole=2 (Broker of Credit, tag 452)
• NoPartySubIDs=1 (tag 802)

Groups 1 and 2 for Event Stream Processor are stored in this stream:

<SourceStream id="MyQuotes_NoPartyIDs" store="FixStore">
	<Column datatype="string" name="PartyID"/>
	<Column datatype="string" name="PartyIDSource"/>
	<Column datatype="integer" name="PartyRole"/>
	<Column datatype="integer" name="NoPartySubIDs"/>
	<Column datatype="long" name="FixMsgId" key="true"/>
	<Column datatype="long" name="NoPartyIDs_Num" key="true"/>
</SourceStream>

Groups 1 and 2 for the Server are stored in this stream:

CREATE  INPUT  WINDOW MyQuotes_NoPartyIDs
SCHEMA (PartyID STRING, PartyIDSource STRING, PartyRole INTEGER, NoPartySubIDs INTEGER, FixMsgId LONG, NoPartyIDs_Num LONG)
PRIMARY KEY (FixMsgId, NoPartyIDs_Num)
 STORE FixStore;

Group 1 and Group 2 contain their own groups of type NoPartySubIDs. Groups 11 and 12 below are part of Group 1:

Group 11:

• PartySubID=AAPartySubID11 (tag 523)
• PartySubIDType=1 (Firm, tag 803)

Group 12:

• PartySubID=AAPartySubID12 (tag 523)
• PartySubIDType=2 (Person, tag 803)

Group 21 is part of Group 2:

• PartySubID=AAPartySubID21 (tag 523)
• PartySubIDType=3 (System, tag 803)

Groups 11, 12, and 21 in Event Stream Processor are stored in this stream:

<SourceStream id="MyQuotes_NoPartyIDs_NoPartySubIDs" store="FixStore">
	<Column datatype="string" name="PartySubID"/>
	<Column datatype="integer" name="PartySubIDType"/>
	<Column datatype="long" name="FixMsgId" key="true"/>
	<Column datatype="long" name="NoPartyIDs_Num" key="true"/>
	<Column datatype="long" name="NoPartySubIDs_Num" key="true"/>
<SourceStream>

Groups 11, 12, and 21 for the Server are stored in this stream:

CREATE  INPUT  WINDOW MyQuotes_NoPartyIDs_NoPartySubIDs
SCHEMA (PartySubID STRING, PartySubIDType INTEGER, FixMsgId LONG, NoPartyIDs_Num LONG, NoPartySubIDs_Num LONG)
PRIMARY KEY (FixMsgId, NoPartyIDs_Num, NoPartySubIDs_Num)
 STORE FixStore;