Changeset 15847 for lang/perl/Mvalve
- Timestamp:
- 07/15/08 15:15:16 (5 years ago)
- Files:
-
- 1 modified
-
lang/perl/Mvalve/trunk/lib/Mvalve/Base.pm (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
-
lang/perl/Mvalve/trunk/lib/Mvalve/Base.pm
r15846 r15847 83 83 84 84 $done = 1; 85 my $retry = $self->state_get($time_key);86 my $next = (time + $interval) * 1000;87 85 88 if ( ! $retry || $retry < $next ) { 89 $retry = $next; 90 } 91 $message->header( &Mvalve::Const::RETRY_HEADER, $retry ); 86 my $retry = $self->state_get($time_key); 87 my $next = (time + $interval) * 1000; 92 88 93 Mvalve::trace( "defer to $table (retry = $retry)" ) if &Mvalve::Const::MVALVE_TRACE; 94 $rv = $self->q_insert( 95 table => $table, 96 data => { 97 destination => $destination, 98 ready => $retry, 99 message => $message->serialize, 89 if ( ! $retry || $retry < $next ) { 90 $retry = $next; 100 91 } 101 );92 $message->header( &Mvalve::Const::RETRY_HEADER, $retry ); 102 93 103 Mvalve::trace( "q_insert results in $rv" ) if &Mvalve::Const::MVALVE_TRACE; 94 Mvalve::trace( "defer to $table (retry = $retry)" ) if &Mvalve::Const::MVALVE_TRACE; 95 $rv = $self->q_insert( 96 table => $table, 97 data => { 98 destination => $destination, 99 ready => $retry, 100 message => $message->serialize, 101 } 102 ); 104 103 105 if ($rv) { 106 $retry += $interval; 107 $self->state_set($time_key, $retry); 108 } 104 Mvalve::trace( "q_insert results in $rv" ) if &Mvalve::Const::MVALVE_TRACE; 105 106 if ($rv) { 107 $retry += $interval; 108 $self->state_set($time_key, $retry); 109 } 109 110 } 110 111
![(please configure the [header_logo] section in trac.ini)](/share/chrome/site/your_project_logo.png)