Data Adapter sample for COMMAND mode

Otake

Is there any tutorial for impelementing a data adapter in .NET for COMMAND mode? It seems like PortfolioDemo has one in java but not in .Net?

Mone

Hi,

we already made a .NET port of our Portfolio adapter :Smile_Ab:
It will be publicly available in the next release, in the meanwhile we could send it to you if you want.
Just send me a PM asking for it and I'll send the code to you.

Otake

Hi Mone,

I just sent you a PM.

Thanks.

Otake

Mone, many thanks for the source code.

I was missing "listener.EndOfSnapshot(itemName);" on my data adapter implementation but adding that didin't solve my problem.

I am basically trying to implement a NonVisualTable with COMMAND mode; and I tried to benefit from below link:
http://79.125.12.202/vb/showthread.php?t=63

However, Although I can see that my subscription is successfull and data being passed to LS by calling listener.Update(...), I am not able to receive anything on the client. (onItemUpdate doesn't fire)

My javascript code:

function SubscribeToTradeData(clientAccountId) {
    var pushPage = getPushPage();
    
    var schema = new Array("key", "command", "marketId", "name", "qty", "tradePrice", "currently");
    var group = new Array(LSSubscriptionTables.ClientTrades.Prefix + clientAccountId);
    var clientTradesTable = new NonVisualTable(group, schema, "COMMAND");

    clientTradesTable.setDataAdapter("TradingAdapter");
    clientTradesTable.setSnapshotRequired(true);
    
    clientTradesTable.onItemUpdate = function(item, itemUpdate) {
        console.log("item: " + item);

        //Some debug code here for itemUpdate
    }

    pushPage.addTable(clientTradesTable, LSSubscriptionTables.ClientTrades.Name);
}

If I change "COMMAND" to "MERGE", onItemUpdate event fires (only once though) so I know that adapter settings etc.. are correct.

My publishing c# code:

public void Publish(string itemName, IList<TradeDTO> tradeDtos)
        {
            Publish(itemName, tradeDtos, false);
        }

        public void PublishSnapshot(string itemName, IList<TradeDTO> tradeDtos)
        {
            Publish(itemName, tradeDtos, true);
            
            //Notify Lightstreamer for end of snapshot
            listener.EndOfSnapshot(itemName);
            log.Info("End of snapshot for: " + itemName);
        }

        public void Publish(string itemName, IList<TradeDTO> tradeDtos, bool isSnapshot)
        {
            if (IsConnected)
            {
                foreach (var tradeDto in tradeDtos)
                {
                    log.WarnFormat("Broadcasting --> ItemName: {0} , Trade Id: {1} , Market Id: {2} , Market Name: {3}", itemName, tradeDto.TradeId, tradeDto.MarketId, tradeDto.MarketName);
                    listener.Update(itemName, CreateDataToSend(tradeDto, isSnapshot ? BroadcastingCommand.Add : BroadcastingCommand.Update), isSnapshot);
                }
            }
            else
            {
                log.WarnFormat("Not connected, unable to publish {0}.", tradeDtos);
            }
        }

I tried to set the command logic but I am not sure I need it. Any idea what I am missing?

Mone

Hi,

The post you linked was written before the inclusion of the setCommandLogic method.
It simplifies your job as without calling it updates received trhough the onItemUpdate are item-based while after correctly calling the setCommandLogic method you'll have key-based updates (basically the difference is in the meaning of the isValueChanged and getOldValue methods). Moreover the method can be used to enable the multimetapush logic (eg: see the Portfolio demo description that uses the multimetapush logic vs the simple portfolio demo that uses simple metapush).

About your client code, after a quick look it seems correct.
Maybe the problem lies in the metadata adapter. Which one are you using? Can you see any error on your server log?
Did you try to change your code to connect to the default portfolio adapter?

Otake

Hi Mone,

After half an hour of posting my message; I managed to receive data notifications (onItemUpdate fires now with correct data) and both data adapter and my client script are working as I want them to be.

It think only reason I am not having the updates to the client was "not restarting the whole system" properly after my changes; because I wasn't able to see any error log etc.. , just onItemUpdate wasn't firing but all was ok after restarting every system component.

Many thanks for the reply.