diff options
| author | fukachan <fukachan> | 2001-10-08 20:26:26 +0000 |
|---|---|---|
| committer | fukachan <fukachan> | 2001-10-08 20:26:26 +0000 |
| commit | 0e9db1cef0d95a18b184c2e5ddfeed96a2aff25f (patch) | |
| tree | c99a98b2e9178fe13f9937a508ab0e7bd78a9809 /fml/lib/FML/Process | |
| parent | a0ff50fe8b7110b44a1990c0484052432de98b20 (diff) | |
| download | fml8-0e9db1cef0d95a18b184c2e5ddfeed96a2aff25f.tar.gz fml8-0e9db1cef0d95a18b184c2e5ddfeed96a2aff25f.tar.bz2 fml8-0e9db1cef0d95a18b184c2e5ddfeed96a2aff25f.zip | |
modified finish() to use queue_flush()
Diffstat (limited to 'fml/lib/FML/Process')
| -rw-r--r-- | fml/lib/FML/Process/Distribute.pm | 9 |
1 files changed, 2 insertions, 7 deletions
diff --git a/fml/lib/FML/Process/Distribute.pm b/fml/lib/FML/Process/Distribute.pm index b37bd417..087d8ec3 100644 --- a/fml/lib/FML/Process/Distribute.pm +++ b/fml/lib/FML/Process/Distribute.pm @@ -4,7 +4,7 @@ # Copyright (C) 2000,2001 Ken'ichi Fukamachi # All rights reserved. # -# $FML: Distribute.pm,v 1.47 2001/06/10 11:24:12 fukachan Exp $ +# $FML: Distribute.pm,v 1.48 2001/10/08 15:51:08 fukachan Exp $ # package FML::Process::Distribute; @@ -146,12 +146,7 @@ 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); + $curproc->queue_flush(); } |