call recv to pull responses off the wire
authorerickson <erickson@dcc99617-32d9-48b4-a31d-7c20da2025e4>
Wed, 12 May 2010 02:55:24 +0000 (02:55 +0000)
committererickson <erickson@dcc99617-32d9-48b4-a31d-7c20da2025e4>
Wed, 12 May 2010 02:55:24 +0000 (02:55 +0000)
git-svn-id: svn://svn.open-ils.org/ILS/trunk@16417 dcc99617-32d9-48b4-a31d-7c20da2025e4

Open-ILS/src/support-scripts/marc_stream_importer.pl

index d7a0687..60ba741 100755 (executable)
@@ -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;
 }