fabric.messages

Class ObjectUpdateMessage

java.lang.Object

fabric.messages.Message<ObjectUpdateMessage.Response,Message.NoException>

fabric.messages.ObjectUpdateMessage

public class ObjectUpdateMessage
extends Message<ObjectUpdateMessage.Response,Message.NoException>

Represents push notification that an object has been updated.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ObjectUpdateMessage.Response

Nested classes/interfaces inherited from class fabric.messages.Message

Message.MessageType, Message.NoException

Field Summary

Fields

Modifier and Type	Field and Description
LongKeyMap<ObjectGlob>	globs
java.util.List<ObjectGroup>	groups
java.util.List<java.lang.Long>	onums
java.lang.String	store

Fields inherited from class fabric.messages.Message

exceptionClass, messageType

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ObjectUpdateMessage(java.io.DataInput in)
	ObjectUpdateMessage(java.util.List<java.lang.Long> onums, java.util.List<ObjectGroup> updates) Creates an object-update notification to be sent to a worker node.
	ObjectUpdateMessage(java.lang.String store, LongKeyMap<ObjectGlob> updates) Creates an object-update notification to be sent to a dissemination node.

Method Summary

Modifier and Type	Method and Description
ObjectUpdateMessage.Response	dispatch(RemoteIdentity<RemoteWorker> client, MessageHandler h) Visitor method.
protected ObjectUpdateMessage.Response	readResponse(java.io.DataInput in) Creates a Response message of the appropriate type using the provided DataOutput
protected void	writeMessage(java.io.DataOutput out) Writes this message out on the given output stream.
protected void	writeResponse(java.io.DataOutput out, ObjectUpdateMessage.Response r) Writes a Response message of the appropriate type using the provided DataOutput.

Methods inherited from class fabric.messages.Message

readObject, readRef, receive, respond, respond, send, writeObject, writeRef

Methods inherited from class java.lang.Object

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

Field Detail

store

public final java.lang.String store

globs

public final LongKeyMap<ObjectGlob> globs

onums

public final java.util.List<java.lang.Long> onums

groups

public final java.util.List<ObjectGroup> groups

Constructor Detail

ObjectUpdateMessage

public ObjectUpdateMessage(java.lang.String store,
                           LongKeyMap<ObjectGlob> updates)

Creates an object-update notification to be sent to a dissemination node.

Parameters:

store - the store from which the notification originated.

updates - the set of encrypted object updates, keyed by the head object's onum.

ObjectUpdateMessage

public ObjectUpdateMessage(java.util.List<java.lang.Long> onums,
                           java.util.List<ObjectGroup> updates)

Creates an object-update notification to be sent to a worker node.

Parameters:

onums - the onums being updated to which the worker has subscribed.

updates - the set of object updates.

ObjectUpdateMessage

protected ObjectUpdateMessage(java.io.DataInput in)
                       throws java.io.IOException

Throws:

java.io.IOException

Method Detail

dispatch

public ObjectUpdateMessage.Response dispatch(RemoteIdentity<RemoteWorker> client,
                                             MessageHandler h)
                                      throws ProtocolError

Description copied from class: Message

Visitor method.

Specified by:

dispatch in class Message<ObjectUpdateMessage.Response,Message.NoException>

Parameters:

client - the node that is issuing the request.

h - the handler to which this message is to be dispatched.

Throws:

ProtocolError

writeMessage

protected void writeMessage(java.io.DataOutput out)
                     throws java.io.IOException

Description copied from class: Message

Writes this message out on the given output stream.

Specified by:

writeMessage in class Message<ObjectUpdateMessage.Response,Message.NoException>

Throws:

java.io.IOException - if the DataOutput fails.

writeResponse

protected void writeResponse(java.io.DataOutput out,
                             ObjectUpdateMessage.Response r)
                      throws java.io.IOException

Description copied from class: Message

Writes a Response message of the appropriate type using the provided DataOutput.

Specified by:

writeResponse in class Message<ObjectUpdateMessage.Response,Message.NoException>

Throws:

java.io.IOException - if the DataOutput fails.

readResponse

protected ObjectUpdateMessage.Response readResponse(java.io.DataInput in)
                                             throws java.io.IOException

Description copied from class: Message

Creates a Response message of the appropriate type using the provided DataOutput

Specified by:

readResponse in class Message<ObjectUpdateMessage.Response,Message.NoException>

Throws:

java.io.IOException - if the response is malformed, or if the DataInput fails.