Changeset 565

Timestamp:

02/25/09 19:33:25 (9 months ago)

Author:

ykerherve

Message:

Added on_exception_cb and retry_count parameters to the driver, to pass down
to Gearman::Task

Files:

• trunk/lib/Data/ObjectDriver/Driver/GearmanDBI.pm (modified) (3 diffs)

trunk/lib/Data/ObjectDriver/Driver/GearmanDBI.pm

@@ -9 +9 @@
 use Data::Dumper;
 
-__PACKAGE__->mk_accessors(qw( dbi client func driver_arg enabled_cb uniqify_cb ));
+__PACKAGE__->mk_accessors(qw(
+    dbi client func driver_arg enabled_cb uniqify_cb
+    on_exception_cb retry_count
+));
 
 sub init {
@@ -67 +70 @@
     my $client  = $driver->client;
 
+    my %options = ();
+    $options{on_exception} = $driver->on_exception_cb
+        if $driver->on_exception_cb;
+    $options{retry_count}  = $driver->retry_count
+        if $driver->retry_count;
+
     my $res = $client->do_task( $func =>
         \Storable::nfreeze( {
@@ -75 +84 @@
         } ),
         {
-            uniq => $uniq  # coalesce all requests for this data
+            uniq => $uniq, # coalesce all requests for this data
+            %options,
         }
     );