cleanup Mubot4FB::Queue

diff --git a/lib/Mubot4FB/Queue.pm b/lib/Mubot4FB/Queue.pm
index 3e8cb31..98e6de3 100644 (file)
--- a/lib/Mubot4FB/Queue.pm
+++ b/lib/Mubot4FB/Queue.pm
@@ -7,33 +7,17 @@ package Mubot4FB::Queue;
 use strict;
 use utf8;
 
-use Qudo;
+use base 'Qudo';
 
 use Data::Dumper;
 
 sub new {
-       my ($proto, $cfg, $dbh) = @_;
-       my $class = ref $proto || $proto;
-       my $self = {cfg => $cfg};
-       bless $self, $class;
-
-       $self->init();
-       return $self;
-}
-
-sub init {
-       my ($me) = @_;
-
-       return $me->{queue} = Qudo->new(driver_class => 'DBI',
-                                       databases => [+{dsn => 'DBI:mysql:'.$me->{cfg}->{database},
-                                                       username => $me->{cfg}->{db_user},
-                                                       password => $me->{cfg}->{db_pass}}]);
-}
-
-sub enqueue {
-       my ($me, $funcname, $arg) = @_;
-       warn Dumper($arg);
-       $me->{queue}->enqueue($funcname, $arg);
+       my ($class, $cfg) = @_;
+       $class->SUPER::new(driver_class => 'DBI',
+                          databases => [+{dsn => 'DBI:mysql:'.$cfg->{database},
+                                          username => $cfg->{db_user},
+                                          password => $cfg->{db_pass}}],
+                          default_hooks => [qw/Qudo::Hook::Serialize::JSON/]);
 }
 
 1;