Skip to content

Commit

Permalink
Merge branch 'rawdata_opendirect' of github.com:gururaajar/rbus into …
Browse files Browse the repository at this point in the history
…rawdata_opendirect
  • Loading branch information
Gururaaja E S R authored and Gururaaja E S R committed Oct 25, 2023
2 parents 2119d82 + 6a0026b commit 5a52409
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/rbus/rbus_asyncsubscribe.c
Original file line number Diff line number Diff line change
Expand Up @@ -184,8 +184,6 @@ static void rbusAsyncSubscribeRetrier_SendSubscriptionRequests()

coreerr = rbus_subscribeToEventTimeout(NULL, item->subscription->eventName,
_event_callback_handler, item->payload, item->subscription, &providerError, 0, false, &response, false);
if(response)
rbusMessage_GetInt32(response, (int32_t*)&subscriptionId);

rtTime_Now(&now);

Expand Down Expand Up @@ -228,6 +226,8 @@ static void rbusAsyncSubscribeRetrier_SendSubscriptionRequests()

if(coreerr == RBUSCORE_SUCCESS)
{
if(response)
rbusMessage_GetUInt32(response, &subscriptionId);
RBUSLOG_INFO("%s: %s subscribe retries succeeded", __FUNCTION__, item->subscription->eventName);
responseErr = RBUS_ERROR_SUCCESS;
}
Expand Down

0 comments on commit 5a52409

Please sign in to comment.