在opendds中爲用戶過濾動態內容？

-1

我使用的是以數據爲中心的發佈訂閱模型的openDDS。發佈者不斷髮送數據，用戶將收到它。但對於用戶，它必須根據我給出的條件接收過濾的數據。在opendds中爲用戶過濾動態內容？

假設雙方發佈者和用戶使用我的話題結構：

module Messenger { 

#pragma DCPS_DATA_TYPE "Messenger::ChannelData" 
#pragma DCPS_DATA_KEY "Messenger::ChannelData subject_id" 

    struct ChannelData { 
      string from; 
      string subject; 
      long subject_id; 
      string text; 
      long count; 
    }; 
};

OpenDDS有一個概念命名爲內容過濾的話題。我也使用過。

代碼：

// Register Type (Messenger::Message) 
    Messenger::ChannelDataTypeSupport_var ts = 
     new Messenger::ChannelDataTypeSupportImpl(); 

    if (ts->register_type(participant.in(), "") != DDS::RETCODE_OK) { 
     ACE_ERROR_RETURN((LM_ERROR, 
         ACE_TEXT("%N:%l main()") 
         ACE_TEXT(" ERROR: register_type() failed!\n")), -1); 
    } 

    // Create Topic (Movie Discussion List) 
    CORBA::String_var type_name = ts->get_type_name(); 
    DDS::Topic_var topic = 
     participant->create_topic("Movie Discussion List", 
           type_name.in(), 
           TOPIC_QOS_DEFAULT, 
           DDS::TopicListener::_nil(), 
           OpenDDS::DCPS::DEFAULT_STATUS_MASK); 

DDS::ContentFilteredTopic_var cft = 
     participant->create_contentfilteredtopic("MyTopic-Filtered", 
     topic, 
     "count <= 0 ",DDS::StringSeq());

但在上述代碼中，我硬編碼濾波條件計數< = 0。

那麼，有什麼辦法可以爲訂戶提供動態過濾條件來接收過濾的數據嗎？

來源

2014-09-10 Vishvesh Phadnis

而不是0通過％0而不是DDS :: StringSeq（）傳遞一個長度爲1的序列，其中包含應該用於％0的值。快速搜索谷歌會給你幾個例子！

來源

2014-09-16 16:58:51

在opendds中爲用戶過濾動態內容？

回答

相關問題