summaryrefslogtreecommitdiff
path: root/fml
diff options
context:
space:
mode:
authorfukachan <fukachan>2001-05-19 03:30:37 +0000
committerfukachan <fukachan>2001-05-19 03:30:37 +0000
commit07a6fc7162597bef602759eb4db7b77872f92904 (patch)
tree1bd621e6b6cd28d20aaa7749e8c363ee2c6f80c9 /fml
parent472bbcbc374f446518c13581d834c501d5f92e27 (diff)
downloadfml8-07a6fc7162597bef602759eb4db7b77872f92904.tar.gz
fml8-07a6fc7162597bef602759eb4db7b77872f92904.tar.bz2
fml8-07a6fc7162597bef602759eb4db7b77872f92904.zip
send queue by FML::Process::QueueManager
Diffstat (limited to 'fml')
-rw-r--r--fml/lib/FML/Process/Distribute.pm8
1 files changed, 7 insertions, 1 deletions
diff --git a/fml/lib/FML/Process/Distribute.pm b/fml/lib/FML/Process/Distribute.pm
index 60000e41..d0728ddd 100644
--- a/fml/lib/FML/Process/Distribute.pm
+++ b/fml/lib/FML/Process/Distribute.pm
@@ -4,7 +4,7 @@
# Copyright (C) 2000 Ken'ichi Fukamachi
# All rights reserved.
#
-# $FML: Distribute.pm,v 1.43 2001/04/15 05:58:05 fukachan Exp $
+# $FML: Distribute.pm,v 1.44 2001/04/15 09:05:41 fukachan Exp $
#
package FML::Process::Distribute;
@@ -143,6 +143,12 @@ sub finish
my ($curproc, $args) = @_;
$curproc->inform_reply_messages();
+
+ my $queue_dir = $curproc->{ config }->{ mqueue_dir };
+
+ use FML::Process::QueueManager;
+ my $obj = new FML::Process::QueueManager { directory => $queue_dir };
+ $obj->send($curproc);
}