Page 2 of 2 FirstFirst 12
Results 11 to 17 of 17
  1. #11
    Senior Member
    Join Date
    Oct 2007
    Location
    HoChiMinh
    Posts
    69
    Dear Dario,

    Here my ReadBinaryFile() method and GetCurrentValues :

    --- "ExternalFeed.cs", ExternalFeedSimulator class---

    public class ExternalFeedSimulator
    {
    private double [] m_refprices = null;
    private double [] m_openprices = null;

    private double [] m_minprices;
    private double [] m_maxprices;
    ...


    public ExternalFeedSimulator()
    {

    _stockGenerators= new Hashtable();
    ...
    }

    //Get data stock from outside, read "security.dat" file
    public void ReadBinaryFile()
    {
    ISecurityStructReader reader;
    reader = new ReadSecurityStruct("C:\\TEMP\\BACKUP14\\SECURITY.D AT");

    nStock = 0;

    if (reader.Open())
    {
    arr = reader.Read();

    nStock = arr.Count;
    m_stockSymbol = new string[nStock];
    m_openprices = new double[nStock];

    for (int i=0; i< nStock ;i++)
    {
    Struct_Security item = (Struct_Security)arr[i];

    m_openprices[i]= item.OpenPrice;
    m_stockSymbol[i]= item.StockSymbol;
    ...
    }
    }
    reader.Close();
    }

    ---- "ExternalFeed.cs" file, ExternalFeedProducer class ---

    public void Start() {
    lock (this) {
    if (_thread != null) return;

    _thread = new Thread(new ThreadStart(Run));
    _thread.Start();
    }
    }

    private void Run() {
    do {
    int waitMillis= ComputeNextWaitTime();
    Thread.Sleep(waitMillis);

    if (_listener != null)
    {
    _listener.OnEvent(_itemName, GetCurrentValues(false), false);
    }

    } while (true);
    }

    //How about this method? Is it correct?
    public IDictionary GetCurrentValues(bool fullData) {
    lock (this) {
    IDictionary eventData = new Hashtable();

    eventData["ceiling"] = _ceiling.ToString("#,##0.##");
    eventData["floor"] = _floor.ToString("#,##0.##");
    ...
    }
    }

    How about Start(), Run() method in "ExternalFeedProducer" class? i need remove ? Because it has error in StockListAdapter :

    ---
    Unhandled exception : System.IndexOutOfRangeException : index was outside the bounds of the array at Lightstreamer.Adapters.Data.StockList.ExternalFeed Simulator.Run()

    ----

    Quotes :
    "Any unwanted behaviour (for instance, the Data Adapter not receiving all read data) should be inspected with a debugger" --> i don't understand this, u mean if i config in "lightstreamer_log_conf.xml" file and set priority value = "DEBUG" :

    <category name="LightstreamerLogger.pump" class="org.apache.log4j.Logger">
    <priority value="DEBUG" />
    </category>

    the Data Adapter not receiving all read data after every 5 seconds?

    and How to check or to recognize my Remote Adapter would still forward all updates to Lightstreamer Server?

    Can u help me?

  2. #12
    Administrator
    Join Date
    Jul 2006
    Location
    Milan
    Posts
    1,090
    To my human eye, the "ReadBinaryFile" and "GetCurrentValues" methods seem correct.
    I also confirm that "Start" and "Run" of the "ExternalFeedProducer" class should be removed, as now only the main thread in "ExternalFeedSimulator" is needed.

    Hence, if you observe that the Data Adapter does not call onEvent as expected, you should try to setup a code debugger and trace it step by step.
    Alternatively, if you want to log the data flow sent by your "ExternalFeedSimulator" class, you have to add custom log lines, for instance in the "onEvent" implementation in "StockList.cs".

    Note that, in this method, only the events pertaining to stocks that are currently subscribed to are forwarded to Lightstreamer.
    You can have the Remote Server log the update events really sent to Lightstreamer by setting as DEBUG the "Lightstreamer.DotNet.Server.RequestReply" logging category. The configuration of the Remote Server log, in the included deployment example, is in the "DotNetServer.exe.config" file beside the "DotNetServer.exe" executable; the configured log file is "DotNetServer.log".

    The Server logging configuration file, "lightstreamer_log_conf.xml", can remain unchanged, for the moment.

    Dario

  3. #13
    Senior Member
    Join Date
    Oct 2007
    Location
    HoChiMinh
    Posts
    69
    Thanks Dario very much, now it seem ok. but in html file, javascript code, when data stock changed, function updateItem(item, updateInfo) doesn't work.

    Last time, i have a question for this issue, and u have to answer the question, but i followed by your instruction, i didn't have successful. I don't know, what are there steps i wrong? Please help me again.

    Here my changed

    -----"default.html" file --------

    <script>
    for (var i = 1; i <= 30; i++)
    {
    var suff = (i % 2 == 1) ? "A" : "B";

    document.write('<tr class="lscold'+suff+'">');
    document.write('<td>&nbsp;</td>');
    document.write('<td class="stockname'+suff+'"><div source="lightstreamer" table="list" item="'+i+'" field="stock_symbol"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="ref_price"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="ceiling"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="floor"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="open_price"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="max"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="min"> - </div></td>');
    document.write('<td>&nbsp;</td>');
    document.write('<td>&nbsp;</td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="close_price"> - </div></td>');
    document.write(' <td><div source="lightstreamer" table="list" item="'+i+'" field="close_vol"> - </div></td>');
    document.write('<td>&nbsp;</td>');
    document.write('<td>&nbsp;</td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="bid3"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="bid3vol"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="bid2"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="bid2vol"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="bid1"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="bid1vol"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="last_price"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="lastVol"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="pct_change"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="ask1"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="ask1vol"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="ask2"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="ask2vol"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="ask3"> - </div></td>');
    document.write('<td><div source="lightstreamer" table="list" item="'+i+'" field="ask3vol"> - </div></td>');
    document.write('</tr>');
    }
    </script>


    //////////////////////////Event handlers

    var redColor = "#f8b87a";
    var greenColor = "lightgreen";

    function updateItem(item, updateInfo) {
    if (updateInfo == null)
    {
    return;
    }
    if (updateInfo.isValueChanged("pct_change")) {
    var val = updateInfo.getNewValue("pct_change"); if (val.indexOf("-") > -1) {
    updateInfo.addField(216,imgDown);
    } else {
    updateInfo.addField(216,imgUp);
    }
    }

    var oldLast = updateInfo.getOldValue("last_price");
    var newColor;
    if (oldLast == null) { //first update for this item
    updateInfo.addField(214,greenColor,true); //no fade for snapshot
    if (doFade) {
    updateInfo.addField(215,"OFF",true);
    }
    } else if (updateInfo.isValueChanged("last_price")) {
    //at least second update
    if (oldLast > updateInfo.getNewValue("last_price")) {
    updateInfo.addField(214,redColor,true);
    } else {
    updateInfo.addField(214,greenColor,true);
    }
    if (doFade) {
    updateInfo.addField(215,"ON",true);
    }
    }
    }


    function formatValues(item, itemUpdate) {
    if (itemUpdate == null) {
    return;
    }

    if (doFade) {
    if (itemUpdate.getServerValue(215) == "ON") {
    itemUpdate.setHotToColdTime(300);
    }
    }
    itemUpdate.setHotTime(600);

    if (itemUpdate.getServerValue(13) == "inactive") {
    carryBackUnchanged(itemUpdate);
    itemUpdate.setRowAttribute("#808080","#808080","co lor");
    } else {
    if (itemUpdate.getFormattedValue(13) != null) {
    carryBackUnchanged(itemUpdate);
    itemUpdate.setRowAttribute("#000000","#000000","co lor");
    itemUpdate.setAttribute(12,"#000080","#000080","co lor");
    }

    //choose the backgroundColor
    var backC = (item % 2 == 1) ? "#eeeeee" : "#ddddee";
    var backH = itemUpdate.getServerValue(214); itemUpdate.setRowAttribute(backH,backC,"background Color");

    //choose the "change" field stylesheet
    var newChng;
    if ((newChng = itemUpdate.getFormattedValue(3)) != null) {
    var hotTxtCol = (newChng.charAt(0) == '-') ? "#dd0000" : "#009900";
    itemUpdate.setAttribute(3,"black",hotTxtCol,"color ");
    itemUpdate.setAttribute(3,"bold","bold","fontWeigh t");
    }

    itemUpdate.setAttribute(12,backC,backC,"background Color");
    }

    //format the timestamp
    var time = itemUpdate.getFormattedValue(2);
    if (time != null) {
    time = formatTime(time);
    itemUpdate.setFormattedValue(2,time);
    }

    //format the "number" fields
    for (var i = 1; i <= 11; i++) {
    if (i == 2 || i == 4 || i == 7) {
    continue; //"string" fields
    }

    var newValue = itemUpdate.getFormattedValue(i);
    if (newValue == null) continue;

    var formattedVal = formatDecimal(newValue, 2, true);

    if (i == 3) {
    if (formattedVal > 0) {
    formattedVal = "+" + formattedVal;
    }
    formattedVal += "%";
    }
    itemUpdate.setFormattedValue(i,formattedVal);

    }
    }


    ////////////////Global var declaration
    var group = ["item1", "item2", "item3", "item4","item5", "item6", "item7", "item8","item9", "item10", "item11", "item12","item13", "item14", "item15", "item16", "item17", "item18", "item19", "item20", "item21", "item22", "item23", "item24", "item25", "item26", "item27", "item28", "item29", "item30"];
    var schema = ["last_price", "time", "pct_change","bid1", "bid2", "bid3", "bid1vol", "bid2vol", "bid3vol", "ask1","ask2", "ask3", "ask1vol", "ask2vol", "ask3vol", "min", "max","ref_price", "open_price", "stock_name", "stock_symbol", "ceiling", "floor", "lastVal", "lastVol", "close_price", "close_vol"];
    var newTable = new OverwriteTable(group, schema,"MERGE");

    ----------
    Now i want to changed, if all of items :
    lastVal, lastVol, last_price, bid1, bid2, bid3, ask1, ask2, ask3, bid1vol, bid2vol, bid3vol, ask1vol, ask2vol, ask3vol, pct_change

    has values modified, it will be fill by color (if current value < old_value, fill by red color, else fill by green color)


    Please help me again.

  4. #14
    Administrator
    Join Date
    Jul 2006
    Location
    Milan
    Posts
    1,090
    The sample page you are using as a base point sets the cell highlighting (i.e. "hot") color for all changed fields based on the change of the "last_price" field value. This necessarily involves a two-phase process:
    in "updateItem" the change is analyzed and the proper color is stored in an extra field (namely 214);
    then, in "formatValues", the color is assigned as the "hot" background color to all the cells in the row (note that only changed cells will be highlighted).
    Does this still work for the "last_price" field?

    Other code is not relevant for you; the only relevant code is:
    Code:
    function updateItem(item, updateInfo) {
       if (updateInfo == null) {
          return;
       }
    
       var oldLast = updateInfo.getOldValue("last_price");
       var newColor;
       if (oldLast == null) { //first update for this item
          updateInfo.addField(214,greenColor,true);
       } else if (updateInfo.isValueChanged("last_price")) {
          //at least second update
          if (oldLast > updateInfo.getNewValue("last_price")) {
             updateInfo.addField(214,redColor,true);
          } else {
             updateInfo.addField(214,greenColor,true);
          }
       } 
    } 
    
    
    function formatValues(item, itemUpdate) {
       if (itemUpdate == null) {
          return;
       }
    
       itemUpdate.setHotTime(600);
    
       //choose the backgroundColor
       var backC = (item % 2 == 1) ? "#eeeeee" : "#ddddee";
       var backH = itemUpdate.getServerValue(214);
       itemUpdate.setRowAttribute(backH,backC,"backgroundColor");
    }
    You seem to require two changes:
    1. The change of "last_price" should only affect the "last_price" cell; you can accomplish this by using the "setAttribute" API in place of the "setRowAttribute"; please find the details on these APIs here (the online web client APIs documentation root is http://www.lightstreamer.com/docs/cl...doc/index.html).
    2. The same code should be replicated for all the desired fields; this implies that you have to use more extra fields; you may prefer to name them by names (e.g. "last_price_color" in place of 214).

  5. #15
    Senior Member
    Join Date
    Oct 2007
    Location
    HoChiMinh
    Posts
    69
    Dear Dario,
    thanks for your help. i found my error. i forgot call updateItem(), formatValues() method.

    newTable.setClearOnDisconnected(true); //default is false
    newTable.setClearOnRemove(true); //default is false
    newTable.onItemUpdate = updateItem;
    newTable.onChangingValues = formatValues;
    newTable.setPushedHtmlEnabled(true);

    in my html.

  6. #16
    Senior Member
    Join Date
    Jan 2008
    Location
    Mumbai
    Posts
    39

    Question

    Hi Dario & Tuongkha,

    I changed the ExternalFeed.cs file according to my requirements and I can built it successfully, Now I want to implement this file on to lightstremer to get the changes according to my requirements in the browser So, for that what should I do ?
    where should I place the ExternalFeed.dll and what are the steps to be followed to get the changes?


    Thanks,

  7. #17
    Administrator
    Join Date
    Jul 2006
    Location
    Milan
    Posts
    1,090
    The full story is documented in
    DOCS-SDKs\sdk_adapter_dotnet\doc\DotNet Adapters.pdf
    where a step by step deployment of the Remote StockListDemo is shown. You should just replace the Data Adapter dll.
    In a few words, you have to mount special Proxy Adapters, supplied with Lightstreamer on the Server and ensure that the client pages ask for data from those adapters; then launch Lightstreamer Server and the Remote Server.
    For any problems in this phase, I revert to this thread.

 

 

Similar Threads

  1. Replies: 8
    Last Post: May 7th, 2008, 10:53 AM

Bookmarks

Posting Permissions

  • You may not post new threads
  • You may not post replies
  • You may not post attachments
  • You may not edit your posts
  •  
All times are GMT +1. The time now is 10:43 PM.