Package tigase.pubsub.cluster

Class ClusteredNodeStrategy

java.lang.Object

tigase.pubsub.cluster.AbstractStrategy

tigase.pubsub.cluster.ClusteredNodeStrategy

All Implemented Interfaces:

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

public class ClusteredNodeStrategy
extends AbstractStrategy
implements StrategyIfc

ClusteredNodeStrategy - all pubsub nodes are shared between all cluster nodes, which implies forwarding of packet information across the cluster with the exception of create/remove operation on nodes (to avoid race conditions).

Author:

andrzej

Field Summary

Fields

Modifier and Type	Field	Description
static String[]	FORWARD_ELEMENTS
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
ClusteredNodeStrategy()

Method Summary

Modifier and Type	Method	Description
boolean	filterOutPacket(tigase.server.Packet packet)
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	onItemPublishedEvent(tigase.pubsub.modules.PublishItemModule.ItemPublishedEvent event)
void	onItemRetractedEvent(tigase.pubsub.modules.RetractItemModule.ItemRetractedEvent event)
void	packetProcessed()
boolean	sendException(tigase.server.Packet packet, tigase.component.exceptions.ComponentException ex)
void	userRemoved(tigase.xmpp.jid.BareJID serviceJid)
tigase.pubsub.AbstractNodeConfig	wrapNodeConfig(tigase.xmpp.jid.BareJID serviceJid, String nodeName, tigase.pubsub.AbstractNodeConfig config)
tigase.pubsub.repository.cached.NodeSubscriptions	wrapNodeSubscriptions(tigase.pubsub.repository.NodeSubscriptions nodeSubscriptions)

Methods inherited from class tigase.pubsub.cluster.AbstractStrategy

beforeUnregister, getLocalNodeJid, getNodeForHashCode, getNodeForServiceJid, getNodesConnected, getNodesConnectedWithLocal, initialize, isNodeConfigure, nodeConnected, nodeDisconnected, prepareCommandData, setClusterController, setConfig, setLocalNodeJid, setPubSubComponent

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, setClusterController, setConfig, setPubSubComponent

Field Detail

FORWARD_ELEMENTS

public static final String[] FORWARD_ELEMENTS

nodesModifications

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

Constructor Detail

ClusteredNodeStrategy

public ClusteredNodeStrategy()

Method Detail

filterOutPacket

public boolean filterOutPacket(tigase.server.Packet packet)

Specified by:

filterOutPacket in interface StrategyIfc

getNodesForPacket

public List<tigase.xmpp.jid.JID> getNodesForPacket(tigase.server.Packet packet)
                                            throws tigase.pubsub.exceptions.PubSubException

Specified by:

getNodesForPacket in interface StrategyIfc

Throws:

tigase.pubsub.exceptions.PubSubException

isLocalNode

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

Specified by:

isLocalNode 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()

onItemPublishedEvent

public void onItemPublishedEvent(tigase.pubsub.modules.PublishItemModule.ItemPublishedEvent event)

Overrides:

onItemPublishedEvent in class AbstractStrategy

onItemRetractedEvent

public void onItemRetractedEvent(tigase.pubsub.modules.RetractItemModule.ItemRetractedEvent event)

Overrides:

onItemRetractedEvent in class AbstractStrategy

sendException

public boolean sendException(tigase.server.Packet packet,
                             tigase.component.exceptions.ComponentException ex)

Specified by:

sendException in interface StrategyIfc

Overrides:

sendException in class AbstractStrategy

isOnlineLocally

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

Specified by:

isOnlineLocally in interface StrategyIfc

wrapNodeConfig

public tigase.pubsub.AbstractNodeConfig wrapNodeConfig(tigase.xmpp.jid.BareJID serviceJid,
                                                       String nodeName,
                                                       tigase.pubsub.AbstractNodeConfig config)

Specified by:

wrapNodeConfig in interface StrategyIfc

Overrides:

wrapNodeConfig in class AbstractStrategy

wrapNodeSubscriptions

public tigase.pubsub.repository.cached.NodeSubscriptions wrapNodeSubscriptions(tigase.pubsub.repository.NodeSubscriptions nodeSubscriptions)

Specified by:

wrapNodeSubscriptions in interface StrategyIfc

Overrides:

wrapNodeSubscriptions in class AbstractStrategy

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