We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ffd4a9a commit c11469bCopy full SHA for c11469b
src/njsConnection.cpp
@@ -2535,8 +2535,8 @@ void njsConnection::Async_Subscribe(njsBaton *baton)
2535
params.groupingClass = (uint8_t) baton->subscrGroupingClass;
2536
params.groupingValue = baton->subscrGroupingValue;
2537
params.groupingType = (uint8_t) baton->subscrGroupingType;
2538
- if (dpiConn_newSubscription(baton->dpiConnHandle, ¶ms,
2539
- &baton->dpiSubscrHandle, NULL) < 0) {
+ if (dpiConn_subscribe(baton->dpiConnHandle, ¶ms,
+ &baton->dpiSubscrHandle) < 0) {
2540
baton->GetDPIError();
2541
return;
2542
}
0 commit comments