public synchronized void processReqMsg(ClientSessionMgr clientSessionMgr, Token token,
            OMMMsg msg)
    {

        Map<Token, StreamItem> clientSessionStreams = clientSessionMgr.getClientSessionStreams();
        StreamItem streamItem = (StreamItem)clientSessionStreams.get(token);

        if (streamItem == null)
        {
            streamItem = createStreamItem(token, msg);
            if (msg.getMsgType() == OMMMsg.MsgType.REQUEST
                    && !msg.isSet(OMMMsg.Indication.NONSTREAMING))
            {
                clientSessionStreams.put(token, streamItem);
            }
        }

        if  (msg.isSet(OMMMsg.Indication.REFRESH))
            ((DataStreamItem)streamItem).sendRefresh(msg.isSet(OMMMsg.Indication.REFRESH));

        if (_updateInterval > 0 && !_updating && (!msg.isSet(OMMMsg.Indication.NONSTREAMING)))
        {
            startUpdating();
            _updating = true;
        }
    }