Package tigase.pubsub.cluster

Class PartitionedStrategy

java.lang.Object

tigase.pubsub.cluster.AbstractStrategy

tigase.pubsub.cluster.PartitionedStrategy

All Implemented Interfaces:

tigase.kernel.beans.Initializable, tigase.kernel.beans.UnregisterAware, StrategyIfc

@Bean(name="strategy",
      parent=PubSubComponentClustered.class,
      active=true)
public class PartitionedStrategy
extends AbstractStrategy
implements StrategyIfc

PartitionedStrategy is a class implementing StrategyIfc which is responible for selecting a node which will process particular packet. This implementation is selecting node for a packet using partitioning strategy.

Author:

andrzej

Field Summary

Fields

Modifier and Type	Field	Description
protected ThreadLocal<ArrayDeque<tigase.xml.Element>>	nodesModifications

Fields inherited from class tigase.pubsub.cluster.AbstractStrategy

cl_controller, config, eventBus, localNodeJid, NODE_ATTR, nodeConfigureElemNames, PUBSUB_PATH, pubSubComponent

Constructor Summary

Constructors

Constructor	Description
PartitionedStrategy()

Method Summary

Modifier and Type	Method	Description
boolean	filterOutPacket(tigase.server.Packet packet)
tigase.xmpp.jid.JID	getNodeForServiceNode(tigase.xmpp.jid.JID serviceJid, String node)
List<tigase.xmpp.jid.JID>	getNodesForPacket(tigase.server.Packet packet)
boolean	isLocalNode(tigase.xmpp.jid.BareJID serviceJid, String node)
boolean	isOnlineLocally(tigase.xmpp.jid.JID jid)
void	nodeAddedToCollection(tigase.xmpp.jid.BareJID serviceJid, String nodeName, String collection)
void	nodeAddedToRootCollection(tigase.xmpp.jid.BareJID serviceJid, String nodeName)
void	nodeAffiliationsChanged(tigase.xmpp.jid.BareJID serviceJid, String nodeName, Map<tigase.xmpp.jid.BareJID,tigase.pubsub.repository.stateless.UsersAffiliation> changedAffiliations)
void	nodeConfigurationChanged(tigase.xmpp.jid.BareJID serviceJid, String nodeName)
void	nodeRemovedFromCollection(tigase.xmpp.jid.BareJID serviceJid, String nodeName, String collection)
void	nodeRemovedFromRootCollection(tigase.xmpp.jid.BareJID serviceJid, String nodeName)
void	nodeSubscriptionsChanged(tigase.xmpp.jid.BareJID serviceJid, String nodeName, Map<tigase.xmpp.jid.BareJID,tigase.pubsub.repository.stateless.UsersSubscription> changedSubscriptions)
void	notifyNodeConfigurationChanges()
void	packetProcessed()
void	userRemoved(tigase.xmpp.jid.BareJID serviceJid)

Methods inherited from class tigase.pubsub.cluster.AbstractStrategy

beforeUnregister, getLocalNodeJid, getNodeForHashCode, getNodeForServiceJid, getNodesConnected, getNodesConnectedWithLocal, initialize, isNodeConfigure, nodeConnected, nodeDisconnected, onItemPublishedEvent, onItemRetractedEvent, prepareCommandData, sendException, setClusterController, setConfig, setLocalNodeJid, setPubSubComponent, wrapNodeConfig, wrapNodeSubscriptions

Methods inherited from class java.lang.Object

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

Methods inherited from interface tigase.pubsub.cluster.StrategyIfc

getLocalNodeJid, getNodesConnected, getNodesConnectedWithLocal, nodeConnected, nodeDisconnected, sendException, setClusterController, setConfig, setPubSubComponent, wrapNodeConfig, wrapNodeSubscriptions

Field Detail

nodesModifications

protected final ThreadLocal<ArrayDeque<tigase.xml.Element>> nodesModifications

Constructor Detail

PartitionedStrategy

public PartitionedStrategy()

Method Detail

filterOutPacket

public boolean filterOutPacket(tigase.server.Packet packet)

Specified by:

filterOutPacket in interface StrategyIfc

getNodeForServiceNode

public tigase.xmpp.jid.JID getNodeForServiceNode(tigase.xmpp.jid.JID serviceJid,
                                                 String node)

getNodesForPacket

public List<tigase.xmpp.jid.JID> getNodesForPacket(tigase.server.Packet packet)

Specified by:

getNodesForPacket in interface StrategyIfc

isLocalNode

public boolean isLocalNode(tigase.xmpp.jid.BareJID serviceJid,
                           String node)

Specified by:

isLocalNode in interface StrategyIfc

isOnlineLocally

public boolean isOnlineLocally(tigase.xmpp.jid.JID jid)

Specified by:

isOnlineLocally in interface StrategyIfc

nodeAddedToCollection

public void nodeAddedToCollection(tigase.xmpp.jid.BareJID serviceJid,
                                  String nodeName,
                                  String collection)

Specified by:

nodeAddedToCollection in interface StrategyIfc

nodeAddedToRootCollection

public void nodeAddedToRootCollection(tigase.xmpp.jid.BareJID serviceJid,
                                      String nodeName)

Specified by:

nodeAddedToRootCollection in interface StrategyIfc

nodeRemovedFromCollection

public void nodeRemovedFromCollection(tigase.xmpp.jid.BareJID serviceJid,
                                      String nodeName,
                                      String collection)

Specified by:

nodeRemovedFromCollection in interface StrategyIfc

nodeRemovedFromRootCollection

public void nodeRemovedFromRootCollection(tigase.xmpp.jid.BareJID serviceJid,
                                          String nodeName)

Specified by:

nodeRemovedFromRootCollection in interface StrategyIfc

nodeConfigurationChanged

public void nodeConfigurationChanged(tigase.xmpp.jid.BareJID serviceJid,
                                     String nodeName)

Specified by:

nodeConfigurationChanged in interface StrategyIfc

nodeAffiliationsChanged

public void nodeAffiliationsChanged(tigase.xmpp.jid.BareJID serviceJid,
                                    String nodeName,
                                    Map<tigase.xmpp.jid.BareJID,tigase.pubsub.repository.stateless.UsersAffiliation> changedAffiliations)

Specified by:

nodeAffiliationsChanged in interface StrategyIfc

nodeSubscriptionsChanged

public void nodeSubscriptionsChanged(tigase.xmpp.jid.BareJID serviceJid,
                                     String nodeName,
                                     Map<tigase.xmpp.jid.BareJID,tigase.pubsub.repository.stateless.UsersSubscription> changedSubscriptions)

Specified by:

nodeSubscriptionsChanged in interface StrategyIfc

notifyNodeConfigurationChanges

public void notifyNodeConfigurationChanges()

packetProcessed

public void packetProcessed()

Specified by:

packetProcessed in interface StrategyIfc

Overrides:

packetProcessed in class AbstractStrategy

userRemoved

public void userRemoved(tigase.xmpp.jid.BareJID serviceJid)

Specified by:

userRemoved in interface StrategyIfc