Package tigase.eventbus.component
Class SubscribeModule
java.lang.Object
tigase.component.modules.AbstractModule
tigase.eventbus.component.AbstractEventBusModule
tigase.eventbus.component.SubscribeModule
- All Implemented Interfaces:
Module,Initializable,UnregisterAware
@Bean(name="subscribe",
active=true)
public class SubscribeModule
extends AbstractEventBusModule
implements Initializable, UnregisterAware
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsFields inherited from class tigase.component.modules.AbstractModule
eventBus, log, writerFields inherited from interface tigase.component.modules.Module
EMPTY_FEATURES -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidMethod called before bean unregister.voidclusterNodeConnected(JID node) voidclusterNodeDisconnected(JID node) String[]Returns XMPP features offered by module.Returns critera used by Component to select module to handle incoming stanza.voidMethod will be called, when bean will be created, configured and ready to use.protected voidonAddHandler(String eventName, String eventPackage) voidProcess incoming stanza.protected ElementprocessClusterSubscription(Packet packet) protected ElementprocessNonClusterSubscription(Packet packet) protected voidsendSubscribeRequest(String to, Collection<Element> subscriptionElements) Methods inherited from class tigase.eventbus.component.AbstractEventBusModule
isClusteredEventBus, nextStanzaIDMethods inherited from class tigase.component.modules.AbstractModule
fireEvent, getEventBus, getWriter, setEventBus, setWriter, write, write
-
Field Details
-
ID
- See Also:
-
-
Constructor Details
-
SubscribeModule
public SubscribeModule()
-
-
Method Details
-
beforeUnregister
public void beforeUnregister()Description copied from interface:UnregisterAwareMethod called before bean unregister.- Specified by:
beforeUnregisterin interfaceUnregisterAware
-
clusterNodeConnected
-
clusterNodeDisconnected
-
getFeatures
Description copied from interface:ModuleReturns XMPP features offered by module. Features will be returned by Service Discovery.- Specified by:
getFeaturesin interfaceModule- Returns:
- array of features or
null.
-
getModuleCriteria
Description copied from interface:ModuleReturns critera used by Component to select module to handle incoming stanza.- Specified by:
getModuleCriteriain interfaceModule- Returns:
- criteria of selecting module.
-
initialize
public void initialize()Description copied from interface:InitializableMethod will be called, when bean will be created, configured and ready to use.- Specified by:
initializein interfaceInitializable
-
onAddHandler
-
process
Description copied from interface:ModuleProcess incoming stanza.- Specified by:
processin interfaceModule- Parameters:
packet- receivedstanza.- Throws:
ComponentException- if stanza can't be processed correctly. ComponentException is converted to error stanza and returned to stanza sender.TigaseStringprepException- if there was an error during stringprep processing.
-
processClusterSubscription
- Throws:
TigaseStringprepException
-
processNonClusterSubscription
protected Element processNonClusterSubscription(Packet packet) throws TigaseStringprepException, ComponentException -
sendSubscribeRequest
-