Merge branch 'rawdata_opendirect' of github.com:gururaajar/rbus into …

…rawdata_opendirect
rdkcentral · Oct 30, 2023 · f02d3af · f02d3af
2 parents 20d3c30 + 42797c3
commit f02d3af
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/src/core/rbuscore.c b/src/core/rbuscore.c
@@ -1735,7 +1735,7 @@ rbusCoreError_t rbus_publishSubscriberEvent(const char* object_name,  const char
         uint8_t* data;
         uint32_t dataLength;
         rbusMessage_ToBytes(out, &data, &dataLength);
-        rtRouteDirect_SendMessage (pPrivCliInfo, data, dataLength, false, (char*)event_name, subscriptionId);
+        rtRouteDirect_SendMessage (pPrivCliInfo, data, dataLength, (char*)event_name, subscriptionId);
     }
     else
     {

diff --git a/src/rbus/rbus.c b/src/rbus/rbus.c
@@ -5675,7 +5675,7 @@ rbusError_t  rbusEvent_PublishRawData(
         const rtPrivateClientInfo *pPrivCliInfo = _rbuscore_find_server_privateconnection (subscription->eventName, subscription->listener);
         if(pPrivCliInfo && subscription->rawData)
         {
-            ret = rtRouteDirect_SendMessage (pPrivCliInfo, eventData->rawData, eventData->rawDataLen, true, subscription->eventName, subscription->subscriptionId);
+            ret = rtRouteDirect_SendMessage (pPrivCliInfo, eventData->rawData, eventData->rawDataLen, subscription->eventName, subscription->subscriptionId);
             if(RT_OK != ret)
             {
                rc = RBUS_ERROR_BUS_ERROR;

diff --git a/src/rtmessage/rtrouteBase.h b/src/rtmessage/rtrouteBase.h
@@ -81,6 +81,6 @@ rtError rtRouteBase_BindListener(char const* socket_name, int no_delay, int inde
 rtError rtRouteBase_CloseListener(rtListener *pListener);
 
 rtError rtRouteDirect_StartInstance(const char* socket_name, rtDriectClientHandler messageHandler);
-rtError rtRouteDirect_SendMessage(const rtPrivateClientInfo* pClient, uint8_t const* pInBuff, int inLength, bool rawData, char* subEventName, uint32_t subscriptionId);
+rtError rtRouteDirect_SendMessage(const rtPrivateClientInfo* pClient, uint8_t const* pInBuff, int inLength, char* subEventName, uint32_t subscriptionId);
 
 #endif /* __RTROUTEBASE_H__ */