API Documentation

import net.nanex.NxCoreClass;
import java.util.Vector;

class UserDataSample2 extends NxCoreClass{
    class CompositeType{
        public MyData(String Symbol) {
            this.Symbol = Symbol;
        }
        String Symbol;   // Symbol string 
        double CurrentPrice = 0.0; // Current composite price
        long TotalVolume = 0;     // Current total volume
    }
    private Vector<CompositeType> CompositeRecs = new Vector<CompositeType>();
    
    @Override
    public int OnNxCoreCallback(NxCoreSystem nxCoreSys, NxCoreMessage nxCoreMsg) {
        switch (nxCoreMsg.MessageType)
        {
            // Process a status message
        case defines.NxMSG_STATUS:
    
        // If we just ticked a minute, dump out the composite data
        if (nxCoreSys.ClockUpdateInterval >= defines.NxCLOCK_MINUTE && nxCoreSys.nxTime.Hour >= 9)
        {
            // Print the date and time
            System.out.println(String.format("\nNxCore Time: %02d/%02d/%d  %02d:%02d:%02d",
                nxCoreSys.nxDate.Month,nxCoreSys.nxDate.Day,nxCoreSys.nxDate.Year,
                nxCoreSys.nxTime.Hour,nxCoreSys.nxTime.Minute,nxCoreSys.nxTime.Second));
    
            // Now dump out the current values stored in composite recs
            for (int i=0;i < CompositeRecs.size();i++)
            {
                System.out.println(String.format(
                    "Symbol=%s, UserData1=%d, Price=%.4f, Volume=%d",
                    CompositeRecs.get(i).Symbol,
                    i+1,
                    CompositeRecs.get(i).CurrentPrice,
                    CompositeRecs.get(i).TotalVolume));          
            }
        }
        break;
        // Process Symbol Spin and Symbol Change add messages
        case defines.NxMSG_SYMBOLCHANGE:
            if(nxCoreMsg.coreData.SymbolChange.Status != defines.NxSS_ADD)
                return defines.NxCALLBACKRETURN_CONTINUE;
        case defines.NxMSG_SYMBOLSPIN:
            // First check to see if this is an equity symbol type....
            if (nxCoreMsg.coreHeader.pnxStringSymbol.String.charAt(0)=='e')
            {
                // Check to see if this is one of the stocks we are interested in. 
                // If it is, set UserData1 to 1.
                if (nxCoreMsg.coreHeader.pnxStringSymbol.String.equals("eAAPL")||
                    nxCoreMsg.coreHeader.pnxStringSymbol.String.equals("eIBM")||
                    nxCoreMsg.coreHeader.pnxStringSymbol.String.equals("eGE"))
                {
                    System.out.println(String.format(
                        "Interest Set for %s\n",nxCoreMsg.coreHeader.pnxStringSymbol.String));
                    
                    // Set the composite rec symbol pointer to the nxcore symbol string pointer
                    CompositeRecs.addElement(new CompositeType(nxCoreMsg.coreHeader.pnxStringSymbol.String));
                
                    // Set userdata1 to one greater than the index which equals the current size.
                    // This means the actual array slot 0 will be a value of 1 (so that UserData1 can
                    // be used for both the interest test and an index value).
                    nxCoreMsg.coreHeader.pnxStringSymbol.UserData1 = CompositeRecs.size();
                }
            }
        break;
            case defines.NxMSG_TRADE:
                // If UserData1 is set then we are interested in this symbol....
                if (nxCoreMsg.coreHeader.pnxStringSymbol.UserData1 != 0)
                {
                    // Get the composite array index by subtracting 1 from UserData.
                    int i = nxCoreMsg.coreHeader.pnxStringSymbol.UserData1 - 1;
    
                    // Set the composite values.
                    NxCoreTrade nt = nxCoreMsg.coreData.Trade;
                    CompositeRecs.get(i).CurrentPrice = PriceToDouble(nt.Price, nt.PriceType);
                    CompositeRecs.get(i).TotalVolume += nt.Size;
                }
                break;
        }
        return defines.NxCALLBACKRETURN_CONTINUE;
    }
    
    public static void main(String args[]) {
        UserDataSample2 nxCore = new UserDataSample2();

        if (nxCore.LoadNxCore("NxCoreAPI64.dll") != 0){
            nxCore.ProcessTape(args[0], 0, defines.NxCF_EXCLUDE_CRC_CHECK | defines.NxCF_EXCLUDE_QUOTES | defines.NxCF_EXCLUDE_QUOTES2 | defines.NxCF_EXCLUDE_OPRA, 0);
        }
        else
            System.out.println("loading library failed");
    }
}