com.aquenos.cassandra.pvarchiver.server.internode

Class UpdateChannelInformationRequest

java.lang.Object

com.aquenos.cassandra.pvarchiver.server.internode.UpdateChannelInformationRequest

public final class UpdateChannelInformationRequest
extends Object

Request that shall be processed by the ChannelInformationCache.processUpdate(List, List, Iterable, long) method. Such requests are processed by the ApiController and forwarded to the ChannelInformationCache.

Author:

Sebastian Marsching

Constructor Summary

Constructors

Constructor and Description
UpdateChannelInformationRequest(List<ChannelMetaDataDAO.ChannelInformation> channelInformationUpdates, List<UUID> forwardToServers, List<String> missingChannels, long timeStamp) Creates a request.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
List<ChannelMetaDataDAO.ChannelInformation>	getChannelInformationUpdates() Returns the list of channel information objects that are updated with this update.
List<UUID>	getForwardToServers() Returns the list of servers to which the server receiving this request should forward it.
List<String>	getMissingChannels() Returns the list of channels which are missing.
long	getTimeStamp()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

UpdateChannelInformationRequest

public UpdateChannelInformationRequest(List<ChannelMetaDataDAO.ChannelInformation> channelInformationUpdates,
                                       List<UUID> forwardToServers,
                                       List<String> missingChannels,
                                       long timeStamp)

Creates a request.

Parameters:

channelInformationUpdates - updated channel-information objects.

forwardToServers - list of servers which should be notified with the information from the update or null if an empty list shall be used.

missingChannels - channels that are missing now (the channel information is null - typically because the channel has been deleted).

timeStamp - time stamp (as returned by System.currentTimeMillis() of the point in time before the channel information that is sent with this update was retrieved from the database. This information is used when resolving conflicting updates for the same channel.

Throws:

NullPointerException - if channelInformationUpdates or missingChannels is null or channelInformationUpdates, forwardToServers, or missingChannels contains null elements.

Method Detail

getChannelInformationUpdates

public List<ChannelMetaDataDAO.ChannelInformation> getChannelInformationUpdates()

Returns the list of channel information objects that are updated with this update. The list is never null and does never contain null elements. However, it might be empty.

Returns:

channel information objects that contain the updated information.

getForwardToServers

public List<UUID> getForwardToServers()

Returns the list of servers to which the server receiving this request should forward it. The list is never null and does never contain null elements. However, it might be empty.

Returns:

IDs of the servers to which the receiving server should forward this request.

getMissingChannels

public List<String> getMissingChannels()

Returns the list of channels which are missing. A channel is considered missing if a query for its channel information resulted in a null value. Typically, this means that the channel has been deleted. A channel is included in this list when it existed earlier (or was at least expected to exist) and now seems to not exist any longer.

The list is never null and does never contain null elements. However, it might be empty.

Returns:

names of missing channels.

getTimeStamp

public long getTimeStamp()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object