add Queueu Worker based on Jonk

diff --git a/lib/Mubot4FB/Queue/Worker.pm b/lib/Mubot4FB/Queue/Worker.pm
new file mode 100644 (file)
index 0000000..aab9420
--- /dev/null
+++ b/lib/Mubot4FB/Queue/Worker.pm
@@ -0,0 +1,31 @@
+#!/usr/bin/perl
+#
+# Copyright (c) 2012 ISHIKAWA Mutsumi <ishikawa@hanzubon.jp>
+# This program is covered by the GNU General Public License 2
+#
+package Mubot4FB::Queue::Worker;
+use strict;
+use utf8;
+
+use base 'Jonk::Worker';
+
+use JSON::XS;
+
+use Data::Dumper;
+
+sub new {
+       my ($class, $cfg, $func, $dbh) = @_;
+       my $self = $class->SUPER::new($dbh, {functions => [$func]});
+       $self->{cfg} = $cfg;
+       bless $self, $class;
+       return $self;
+}
+
+sub dequeue {
+       my ($me) = @_;
+       my $job = $me->SUPER::dequeue;
+       $job->{arg} = decode_json($job->{arg});
+       return $job;
+}
+
+1;