fabric.dissemination.pastry.messages

Class Replicate.Reply

java.lang.Object

fabric.dissemination.pastry.messages.AbstractRawMessage

fabric.dissemination.pastry.messages.Replicate.Reply

All Implemented Interfaces:

Message

Enclosing class:

Replicate

public static class Replicate.Reply
extends AbstractRawMessage

A reply to a replicate message, carrying the requested objects. This is sent by a decider node which decides what objects the sender of the replicate message should receive base on object popularity.

Field Summary

Fields inherited from class fabric.dissemination.pastry.messages.AbstractRawMessage

type

Constructor Summary

Constructors

Constructor and Description
Reply(InputBuffer buf) Deserialization constructor.
Reply(java.util.Map<Pair<RemoteStore,java.lang.Long>,ObjectGlob> globs)

Method Summary

Modifier and Type	Method and Description
void	dispatch(Disseminator disseminator) Handles this message by calling into the given disseminator.
int	getPriority()
java.util.Map<Pair<RemoteStore,java.lang.Long>,ObjectGlob>	globs()
void	serialize(OutputBuffer buf)
java.lang.String	toString()

Methods inherited from class fabric.dissemination.pastry.messages.AbstractRawMessage

getType

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

Reply

public Reply(java.util.Map<Pair<RemoteStore,java.lang.Long>,ObjectGlob> globs)

Reply

public Reply(InputBuffer buf)
      throws java.io.IOException

Deserialization constructor.

Throws:

java.io.IOException

Method Detail

globs

public java.util.Map<Pair<RemoteStore,java.lang.Long>,ObjectGlob> globs()

getPriority

public int getPriority()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

dispatch

public void dispatch(Disseminator disseminator)

Description copied from interface: Message

Handles this message by calling into the given disseminator.

serialize

public void serialize(OutputBuffer buf)
               throws java.io.IOException

Throws:

java.io.IOException