rice.pastry.socket
Class SocketCollectionManager.MessageRetry

java.lang.Object
  rice.selector.TimerTask
      rice.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,v 1.3 2005/03/11 20:22:33 jeffh Exp $

Author:

jeffh

Field Summary

protected Message	message DESCRIBE THE FIELD
protected SourceRoute	route DESCRIBE THE FIELD
protected long	timeout DESCRIBE THE FIELD
protected int	tries DESCRIBE THE FIELD

Constructor Summary

SocketCollectionManager.MessageRetry(SourceRoute route, Message message)
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, 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 Message message

DESCRIBE THE FIELD

Constructor Detail

SocketCollectionManager.MessageRetry

public SocketCollectionManager.MessageRetry(SourceRoute route,
                                            Message message)

Constructor, taking a message and the route

Parameters:

message - The message

route - The route

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