From: erickson <erickson@dcc99617-32d9-48b4-a31d-7c20da2025e4> Date: Wed, 12 May 2010 02:55:24 +0000 (+0000) Subject: call recv to pull responses off the wire X-Git-Url: https://old-git.evergreen-ils.org/?a=commitdiff_plain;h=c763f69a39b817f5ad73bfa007de8f2c539cb0b2;p=contrib%2FConifer.git call recv to pull responses off the wire git-svn-id: svn://svn.open-ils.org/ILS/trunk@16417 dcc99617-32d9-48b4-a31d-7c20da2025e4 --- diff --git a/Open-ILS/src/support-scripts/marc_stream_importer.pl b/Open-ILS/src/support-scripts/marc_stream_importer.pl index d7a0687a9e..60ba74157e 100755 --- a/Open-ILS/src/support-scripts/marc_stream_importer.pl +++ b/Open-ILS/src/support-scripts/marc_stream_importer.pl @@ -274,14 +274,14 @@ sub bib_queue_import { # clean up the successfully imported vandelay records to prevent queue bloat my $pcrud = OpenSRF::AppSession->create('open-ils.pcrud'); $pcrud->connect; - $pcrud->request('open-ils.pcrud.transaction.begin', $authtoken); + $pcrud->request('open-ils.pcrud.transaction.begin', $authtoken)->recv; my $err; foreach (@cleanup_recs) { try { - $pcrud->request('open-ils.pcrud.delete.vqbr', $authtoken, $_); + $pcrud->request('open-ils.pcrud.delete.vqbr', $authtoken, $_)->recv; } catch Error with { $err = shift; @@ -289,7 +289,7 @@ sub bib_queue_import { }; } - $pcrud->request('open-ils.pcrud.transaction.commit', $authtoken) unless $err; + $pcrud->request('open-ils.pcrud.transaction.commit', $authtoken)->recv unless $err; $pcrud->disconnect; }