Rice Pastry API

rice.pastry.socket
Class SocketCollectionManager.MessageRetry

java.lang.Object
  extended byrice.selector.TimerTask
      extended byrice.pastry.socket.SocketCollectionManager.MessageRetry
All Implemented Interfaces:
CancellableTask, java.lang.Comparable
Enclosing class:
SocketCollectionManager

protected class SocketCollectionManager.MessageRetry
extends TimerTask

Internal class which represents a message which is currently delayed, waiting for an open socket. The message will be tried using exponential backoff up to BACKOFF_LIMIT times before being dropped.

Version:
$Id: pretty.settings 2305 2005-03-11 20:22:33Z jeffh $
Author:
jeffh

Field Summary
protected  SocketSourceRouteManager.AddressManager am
          DESCRIBE THE FIELD
protected  SocketBuffer message
          DESCRIBE THE FIELD
protected  SourceRoute route
          DESCRIBE THE FIELD
protected  long timeout
          DESCRIBE THE FIELD
protected  int tries
          DESCRIBE THE FIELD
 
Fields inherited from class rice.selector.TimerTask
cancelled, fixedRate, nextExecutionTime, period
 
Constructor Summary
SocketCollectionManager.MessageRetry(SourceRoute route, SocketBuffer message, SocketSourceRouteManager.AddressManager am)
          Constructor, taking a message and the route
 
Method Summary
 void run()
          Main processing method for the DeadChecker object
 
Methods inherited from class rice.selector.TimerTask
cancel, compareTo, execute, isCancelled, scheduledExecutionTime
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

tries

protected int tries
DESCRIBE THE FIELD


timeout

protected long timeout
DESCRIBE THE FIELD


route

protected SourceRoute route
DESCRIBE THE FIELD


message

protected SocketBuffer message
DESCRIBE THE FIELD


am

protected SocketSourceRouteManager.AddressManager am
DESCRIBE THE FIELD

Constructor Detail

SocketCollectionManager.MessageRetry

public SocketCollectionManager.MessageRetry(SourceRoute route,
                                            SocketBuffer message,
                                            SocketSourceRouteManager.AddressManager am)
Constructor, taking a message and the route

Parameters:
message - The message
route - The route
am - DESCRIBE THE PARAMETER
Method Detail

run

public void run()
Main processing method for the DeadChecker object

Specified by:
run in interface CancellableTask
Specified by:
run in class TimerTask

Rice Pastry API

Copyright © 2001-2005 - Rice Pastry.


Imprint-Dataprotection