fabric.dissemination.pastry.messages

Class AbstractUpdate<UpdateType extends FastSerializable>

java.lang.Object

fabric.dissemination.pastry.messages.AbstractRawMessage

fabric.dissemination.pastry.messages.AbstractUpdate<UpdateType>

All Implemented Interfaces:

Message

Direct Known Subclasses:

ObjectUpdate

public abstract class AbstractUpdate<UpdateType extends FastSerializable>
extends AbstractRawMessage

Represents a push notification that a glob has been updated.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractUpdate.Reply A reply to an update message.

Field Summary

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

type

Constructor Summary

Constructors

Constructor and Description
AbstractUpdate(RawMessageType messageType, InputBuffer buf, Endpoint endpoint, NodeHandle sender) Deserialization constructor.
AbstractUpdate(RawMessageType messageType, NodeHandle sender, Id id, java.lang.String store, long onum, AbstractGlob<UpdateType> update)

Method Summary

Modifier and Type	Method and Description
void	dispatch(Disseminator disseminator) Handles this message by calling into the given disseminator.
static <T extends FastSerializable> AbstractUpdate<T>	getInstance(NodeHandle sender, Id id, java.lang.String store, long onum, AbstractGlob<T> update)
int	getPriority()
Id	id() The random id of this message.
long	onum() The object number of the updated object.
NodeHandle	sender() The sender of this message.
void	serialize(OutputBuffer buf)
java.lang.String	store() The store where the updated object resides.
java.lang.String	toString()
AbstractGlob<UpdateType>	update() The updated glob.

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

AbstractUpdate

public AbstractUpdate(RawMessageType messageType,
                      NodeHandle sender,
                      Id id,
                      java.lang.String store,
                      long onum,
                      AbstractGlob<UpdateType> update)

AbstractUpdate

public AbstractUpdate(RawMessageType messageType,
                      InputBuffer buf,
                      Endpoint endpoint,
                      NodeHandle sender)
               throws java.io.IOException

Deserialization constructor.

Throws:

java.io.IOException

Method Detail

getInstance

public static <T extends FastSerializable> AbstractUpdate<T> getInstance(NodeHandle sender,
                                                                         Id id,
                                                                         java.lang.String store,
                                                                         long onum,
                                                                         AbstractGlob<T> update)

sender

public NodeHandle sender()

The sender of this message.

id

public Id id()

The random id of this message.

store

public java.lang.String store()

The store where the updated object resides.

onum

public long onum()

The object number of the updated object.

update

public AbstractGlob<UpdateType> update()

The updated glob.

getPriority

public int getPriority()

dispatch

public void dispatch(Disseminator disseminator)

Description copied from interface: Message

Handles this message by calling into the given disseminator.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

serialize

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

Throws:

java.io.IOException