From: ISHIKAWA Mutsumi <ishikawa@hanzubon.jp>
Date: Fri, 2 Nov 2012 09:53:28 +0000 (+0900)
Subject: add Queueu Worker based on Jonk
X-Git-Url: http://git.osdn.net/view?p=mubot4fb%2Fmubot4fb.git;a=commitdiff_plain;h=42500bb4aa355a827c01136f8fc1fcb4191ef51d

add Queueu Worker based on Jonk
---

diff --git a/lib/Mubot4FB/Queue/Worker.pm b/lib/Mubot4FB/Queue/Worker.pm
new file mode 100644
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;