won.protocol.model

Class MessageContainer

java.lang.Object

won.protocol.model.MessageContainer

All Implemented Interfaces:

VersionedEntity

Direct Known Subclasses:

AtomMessageContainer, ConnectionMessageContainer

@Entity
public abstract class MessageContainer
extends java.lang.Object
implements VersionedEntity

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.Long	id

Constructor Summary

Constructors

Constructor and Description
MessageContainer()
MessageContainer(java.net.URI parentUri)

Method Summary

Modifier and Type	Method and Description
void	addPendingConfirmation(java.net.URI toBeConfirmed, java.util.Set<java.net.URI> transitiveConfirmations)
void	addUnconfirmed(java.net.URI toAdd)
java.lang.Long	getId()
java.util.Date	getLastUpdate()
java.net.URI	getParentUri()
java.util.Map<java.net.URI,java.util.Set<java.net.URI>>	getPendingConfirmations()
java.util.Set<java.net.URI>	getUnconfirmedAndIncrementAndCleanup() Returns the set of unconfirmed message URIs, increments the counter for each URI and removes the entries whose counts are now greater than WonConstants.MAX_CONFIRMATIONS.
int	getUnconfirmedCount()
int	getVersion()
void	incrementVersion()
java.util.Set<URICount>	peekAtUnconfirmed() Get the list of unconfirmed messages WITHOUT affecting counters.
void	removePendingConfirmations(java.util.Collection<java.net.URI> toDelete)
void	removeUnconfirmed(java.util.Collection<java.net.URI> toRemove)
void	removeUnconfirmed(java.net.URI toRemove)
void	setId(java.lang.Long id)
void	setParentUri(java.net.URI parentUri)
void	setVersion(int version)

Methods inherited from class java.lang.Object

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

Field Detail

id

protected java.lang.Long id

Constructor Detail

MessageContainer

public MessageContainer()

MessageContainer

public MessageContainer(java.net.URI parentUri)

Method Detail

incrementVersion

public void incrementVersion()

Specified by:

incrementVersion in interface VersionedEntity

getLastUpdate

public java.util.Date getLastUpdate()

Specified by:

getLastUpdate in interface VersionedEntity

getId

public java.lang.Long getId()

setId

public void setId(java.lang.Long id)

getVersion

public int getVersion()

Specified by:

getVersion in interface VersionedEntity

setVersion

public void setVersion(int version)

getParentUri

public java.net.URI getParentUri()

setParentUri

public void setParentUri(java.net.URI parentUri)

getUnconfirmedAndIncrementAndCleanup

public java.util.Set<java.net.URI> getUnconfirmedAndIncrementAndCleanup()

Returns the set of unconfirmed message URIs, increments the counter for each URI and removes the entries whose counts are now greater than WonConstants.MAX_CONFIRMATIONS.

Returns:

the unconfirmed message URIs

peekAtUnconfirmed

public java.util.Set<URICount> peekAtUnconfirmed()

Get the list of unconfirmed messages WITHOUT affecting counters. Should only be used for diagnostic purposes.

Returns:

getUnconfirmedCount

public int getUnconfirmedCount()

addUnconfirmed

public void addUnconfirmed(java.net.URI toAdd)

removeUnconfirmed

public void removeUnconfirmed(java.net.URI toRemove)

removeUnconfirmed

public void removeUnconfirmed(java.util.Collection<java.net.URI> toRemove)

getPendingConfirmations

public java.util.Map<java.net.URI,java.util.Set<java.net.URI>> getPendingConfirmations()

removePendingConfirmations

public void removePendingConfirmations(java.util.Collection<java.net.URI> toDelete)

addPendingConfirmation

public void addPendingConfirmation(java.net.URI toBeConfirmed,
                                   java.util.Set<java.net.URI> transitiveConfirmations)