static int commitTransaction () {
int ret = 1;
const jsonObject* data;
- int req_id = osrfAppSessionMakeRequest( session, NULL, "open-ils.cstore.transaction.commit", 1, NULL );
+ int req_id = osrfAppSessionSendRequest( session, NULL, "open-ils.cstore.transaction.commit", 1 );
osrfMessage* res = osrfAppSessionRequestRecv( session, req_id, 5 );
if ( (data = osrfMessageGetResult(res)) ) {
if(!(trans_id = jsonObjectGetString(data))) {
static int rollbackTransaction () {
int ret = 1;
const jsonObject* data;
- int req_id = osrfAppSessionMakeRequest( session, NULL, "open-ils.cstore.transaction.rollback", 1, NULL );
+ int req_id = osrfAppSessionSendRequest( session, NULL, "open-ils.cstore.transaction.rollback", 1 );
osrfMessage* res = osrfAppSessionRequestRecv( session, req_id, 5 );
if ( (data = osrfMessageGetResult(res)) ) {
if(!(trans_id = jsonObjectGetString(data))) {
static int startTransaction () {
int ret = 1;
jsonObject* data;
- int req_id = osrfAppSessionMakeRequest( session, NULL, "open-ils.cstore.transaction.begin", 1, NULL );
+ int req_id = osrfAppSessionSendRequest( session, NULL, "open-ils.cstore.transaction.begin", 1 );
osrfMessage* res = osrfAppSessionRequestRecv( session, req_id, 5 );
if ( (data = osrfMessageGetResult(res)) ) {
if(!(trans_id = jsonObjectToSimpleString(data))) {
jsonObjectSetIndex( params, 1, jsonParse("{\"quiet\":\"true\"}") );
jsonObject* data;
- int req_id = osrfAppSessionMakeRequest( session, params, method_name, 1, NULL );
+ int req_id = osrfAppSessionSendRequest( session, params, method_name, 1 );
jsonObjectFree(params);
osrfMessage* res = osrfAppSessionRequestRecv( session, req_id, 5 );
if(!(service && method)) return NULL;
osrfLogDebug(OSRF_LOG_MARK, "oilsUtilsQuickReq(): %s - %s", service, method );
osrfAppSession* session = osrfAppSessionClientInit( service );
- int reqid = osrfAppSessionMakeRequest( session, params, method, 1, NULL );
+ int reqid = osrfAppSessionSendRequest( session, params, method, 1 );
osrfMessage* omsg = osrfAppSessionRequestRecv( session, reqid, 60 );
jsonObject* result = jsonObjectClone(osrfMessageGetResult(omsg));
osrfMessageFree(omsg);
}
osrfAppSession* session = osrfAppSessionClientInit(service);
- int req_id = osrfAppSessionMakeRequest( session, params, method, 1, NULL );
+ int req_id = osrfAppSessionSendRequest( session, params, method, 1 );
osrfMessage* omsg;
while( (omsg = osrfAppSessionRequestRecv( session, req_id, 120 )) ) {