Package tigase.http
Class HttpMessageReceiver
- java.lang.Object
-
- tigase.server.BasicComponent
-
- tigase.server.AbstractMessageReceiver
-
- tigase.http.HttpMessageReceiver
-
- All Implemented Interfaces:
tigase.cluster.api.ClusteredComponentIfc
,tigase.conf.Configurable
,tigase.disco.XMPPService
,PacketWriter
,tigase.kernel.beans.config.ConfigurationChangedAware
,tigase.kernel.beans.Initializable
,tigase.kernel.beans.RegistrarBean
,tigase.server.MessageReceiver
,tigase.server.PacketWriterWithTimeout
,tigase.server.ServerComponent
,tigase.stats.StatisticsContainer
,tigase.stats.StatisticsContainerIfc
,tigase.vhosts.VHostListener
@Bean(name="http", parent=tigase.kernel.core.Kernel.class, active=true) @ConfigType({DefaultMode,SetupMode}) public class HttpMessageReceiver extends tigase.server.AbstractMessageReceiver implements PacketWriter, tigase.kernel.beans.RegistrarBean
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class tigase.server.BasicComponent
tigase.server.BasicComponent.ServerInfoVHostItemExtension
-
Nested classes/interfaces inherited from interface tigase.http.PacketWriter
PacketWriter.Callback
-
-
Field Summary
-
Fields inherited from class tigase.server.AbstractMessageReceiver
HOUR, INCOMING_FILTERS_PROP_KEY, INCOMING_FILTERS_PROP_VAL, MAX_QUEUE_SIZE_PROP_KEY, MAX_QUEUE_SIZE_PROP_VAL, maxInQueueSize, maxOutQueueSize, maxQueueSize, MINUTE, OUTGOING_FILTERS_PROP_KEY, OUTGOING_FILTERS_PROP_VAL, PACKET_DELIVERY_RETRY_COUNT_PROP_KEY, SCHEDULER_THREADS_PROP_KEY, SECOND
-
Fields inherited from class tigase.server.BasicComponent
admins, ALL_PROP_KEY, COMMAND_PROP_NODE, scriptCommands, scriptEngineManager, SCRIPTS_DIR_PROP_DEF, SCRIPTS_DIR_PROP_KEY, trusted, vHostManager
-
Fields inherited from interface tigase.conf.Configurable
ADMINS_PROP_KEY, AMP_CLASS_NAME, AMP_CLUST_CLASS_NAME, AUTH_DOMAIN_POOL_CLASS, AUTH_REPO_DOMAINS_PROP_KEY, AUTH_REPO_PARAMS_NODE, AUTH_REPO_POOL_CLASS, AUTH_REPO_URL_PROP_KEY, BOSH_CLUST_COMP_CLASS_NAME, BOSH_COMP_CLASS_NAME, C2S_CLUST_COMP_CLASS_NAME, C2S_COMP_CLASS_NAME, CL_COMP_CLASS_NAME, CLUSTER_CONECT, CLUSTER_CONTR_CLASS_NAME, CLUSTER_LISTEN, CLUSTER_MODE, CLUSTER_NODES, CLUSTER_NODES_PROP_KEY, COMP_PROT_CLASS_NAME, COMPONENT_ID_PROP_KEY, DEF_AMP_NAME, DEF_BOSH_NAME, DEF_C2S_NAME, DEF_CL_COMP_NAME, DEF_CLUST_CONTR_NAME, DEF_COMP_PROT_NAME, DEF_EVENTBUS_NAME, DEF_EXT_COMP_NAME, DEF_HOSTNAME_PROP_KEY, DEF_MONITOR_NAME, DEF_S2S_NAME, DEF_SM_NAME, DEF_STATS_NAME, DEF_VHOST_MAN_NAME, DEF_WS2S_NAME, DERBY_REPO_CLASS_PROP_VAL, DERBY_REPO_URL_PROP_VAL, DRUPAL_REPO_URL_PROP_VAL, DRUPALWP_REPO_CLASS_PROP_VAL, DUMMY_REPO_CLASS_PROP_VAL, EVENTBUS_CLASS_NAME, EXT_COMP_CLASS_NAME, GEN_ADMINS, GEN_AUTH_DB, GEN_AUTH_DB_URI, GEN_COMP_CLASS, GEN_COMP_NAME, GEN_CONF, GEN_CONFIG, GEN_CONFIG_ALL, GEN_CONFIG_COMP, GEN_CONFIG_CS, GEN_CONFIG_DEF, GEN_CONFIG_SM, GEN_DEBUG, GEN_DEBUG_PACKAGES, GEN_EXT_COMP, GEN_MAX_QUEUE_SIZE, GEN_SCRIPT_DIR, GEN_SM_PLUGINS, GEN_SREC_ADMINS, GEN_SREC_DB, GEN_SREC_DB_URI, GEN_TEST, GEN_TRUSTED, GEN_USER_DB, GEN_USER_DB_URI, GEN_USER_DB_URI_PROP_KEY, GEN_VIRT_HOSTS, HOSTNAMES_PROP_KEY, LIBRESOURCE_REPO_CLASS_PROP_VAL, LIBRESOURCE_REPO_URL_PROP_VAL, MONITOR_CLASS_NAME, MONITOR_CLUST_CLASS_NAME, MONITORING, MYSQL_REPO_CLASS_PROP_VAL, MYSQL_REPO_URL_PROP_VAL, PGSQL_REPO_CLASS_PROP_VAL, PGSQL_REPO_URL_PROP_VAL, ROUTER_COMP_CLASS_NAME, S2S_CLUST_COMP_CLASS_NAME, S2S_COMP_CLASS_NAME, SHARED_AUTH_REPO_PARAMS_PROP_KEY, SHARED_AUTH_REPO_PROP_KEY, SHARED_USER_REPO_PARAMS_PROP_KEY, SHARED_USER_REPO_PROP_KEY, SM_CLUST_COMP_CLASS_NAME, SM_COMP_CLASS_NAME, STANZA_WHITE_CHAR_ACK, STANZA_XMPP_ACK, STATS_CLASS_NAME, STRINGPREP_PROCESSOR, TIGASE_AUTH_REPO_CLASS_PROP_VAL, TIGASE_AUTH_REPO_URL_PROP_VAL, TIGASE_CUSTOM_AUTH_REPO_CLASS_PROP_VAL, TRUSTED_PROP_KEY, USER_DOMAIN_POOL_CLASS, USER_REPO_DOMAINS_PROP_KEY, USER_REPO_PARAMS_NODE, USER_REPO_POOL_CLASS, USER_REPO_POOL_SIZE, USER_REPO_POOL_SIZE_PROP_KEY, USER_REPO_URL_PROP_KEY, VHOST_MAN_CLASS_NAME, VHOST_MAN_CLUST_CLASS_NAME, WS2S_CLASS_NAME, WS2S_CLUST_CLASS_NAME, XML_REPO_CLASS_PROP_VAL, XML_REPO_URL_PROP_VAL, XMPP_STANZA_ACK
-
-
Constructor Summary
Constructors Constructor Description HttpMessageReceiver()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
everyHour()
void
everyMinute()
void
everySecond()
String
getDiscoDescription()
tigase.xml.Element
getDiscoInfo(String node, tigase.xmpp.jid.JID jid, tigase.xmpp.jid.JID from)
List<tigase.xml.Element>
getDiscoItems(String node, tigase.xmpp.jid.JID jid, tigase.xmpp.jid.JID from)
void
getStatistics(tigase.stats.StatisticsList list)
boolean
isSubdomain()
void
processPacket(tigase.server.Packet packet)
void
register(tigase.kernel.core.Kernel kernel)
void
requestTimedOut(String key)
void
setActiveModules(List<Module> activeModules)
void
start()
void
stop()
void
unregister(tigase.kernel.core.Kernel kernel)
boolean
write(Module module, tigase.server.Packet packet)
boolean
write(Module module, tigase.server.Packet packet, Integer timeout, PacketWriter.Callback callback)
-
Methods inherited from class tigase.server.AbstractMessageReceiver
addOutPacket, addOutPacketNB, addOutPackets, addOutPacketWithTimeout, addOutPacketWithTimeout, addPacket, addPacketNB, addPackets, addRegexRouting, addTimerTask, addTimerTask, addTimerTask, addTimerTaskWithTimeout, addTimerTaskWithTimeout, beanConfigurationChanged, clearRegexRoutings, getMaxQueueSize, getRegexRoutings, getResourceForPacketWithTimeout, hashCodeForPacket, isInRegexRoutings, newPacketId, processingInThreads, processingOutThreads, processOutPacket, processPacket, release, removeRegexRouting, schedulerThreads, setCompId, setIncomingFilters, setName, setOutogingFilters, setParent, setSchedulerThreads_size
-
Methods inherited from class tigase.server.BasicComponent
addComponentDomain, canCallCommand, canCallCommand, checkCommandAcl, checkCommandAcl, createScriptEngineManager, getComponentId, getComponentInfo, getDefaults, getDefHostName, getDefVHostItem, getDiscoCategory, getDiscoCategoryType, getDiscoExtensionsForm, getDiscoFeatures, getDiscoFeatures, getName, getNodesConnected, getNodesConnectedWithLocal, getScriptCommands, getScriptItems, getServiceEntity, getServiceEntityCaps, getVHostItem, handlesLocalDomains, handlesNameSubdomains, handlesNonLocalDomains, initBindings, initializationCompleted, initialize, isAdmin, isInitializationComplete, isLocalDomain, isLocalDomainOrComponent, isNonAdminCommands, isTrusted, isTrusted, nodeConnected, nodeDisconnected, onNodeConnected, onNodeDisconnected, processScriptCommand, removeComponentDomain, removeServiceDiscoveryItem, setAdmins, setClusterController, setCommandsACL, setProperties, setScriptsBaseDir, setVHostManager, updateServiceDiscoveryItem, updateServiceDiscoveryItem, updateServiceDiscoveryItem, updateServiceEntity
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface tigase.http.PacketWriter
isAdmin
-
-
-
-
Method Detail
-
everyHour
public void everyHour()
- Overrides:
everyHour
in classtigase.server.AbstractMessageReceiver
-
everyMinute
public void everyMinute()
- Overrides:
everyMinute
in classtigase.server.AbstractMessageReceiver
-
everySecond
public void everySecond()
- Overrides:
everySecond
in classtigase.server.AbstractMessageReceiver
-
start
public void start()
- Specified by:
start
in interfacetigase.server.MessageReceiver
- Overrides:
start
in classtigase.server.AbstractMessageReceiver
-
stop
public void stop()
- Overrides:
stop
in classtigase.server.AbstractMessageReceiver
-
getDiscoDescription
public String getDiscoDescription()
- Overrides:
getDiscoDescription
in classtigase.server.BasicComponent
-
isSubdomain
public boolean isSubdomain()
- Overrides:
isSubdomain
in classtigase.server.BasicComponent
-
getDiscoInfo
public tigase.xml.Element getDiscoInfo(String node, tigase.xmpp.jid.JID jid, tigase.xmpp.jid.JID from)
- Specified by:
getDiscoInfo
in interfacetigase.disco.XMPPService
- Overrides:
getDiscoInfo
in classtigase.server.BasicComponent
-
getDiscoItems
public List<tigase.xml.Element> getDiscoItems(String node, tigase.xmpp.jid.JID jid, tigase.xmpp.jid.JID from)
- Specified by:
getDiscoItems
in interfacetigase.disco.XMPPService
- Overrides:
getDiscoItems
in classtigase.server.BasicComponent
-
getStatistics
public void getStatistics(tigase.stats.StatisticsList list)
- Specified by:
getStatistics
in interfacetigase.stats.StatisticsContainerIfc
- Overrides:
getStatistics
in classtigase.server.AbstractMessageReceiver
-
processPacket
public void processPacket(tigase.server.Packet packet)
- Specified by:
processPacket
in classtigase.server.AbstractMessageReceiver
-
requestTimedOut
public void requestTimedOut(String key)
-
write
public boolean write(Module module, tigase.server.Packet packet)
- Specified by:
write
in interfacePacketWriter
-
write
public boolean write(Module module, tigase.server.Packet packet, Integer timeout, PacketWriter.Callback callback)
- Specified by:
write
in interfacePacketWriter
-
register
public void register(tigase.kernel.core.Kernel kernel)
- Specified by:
register
in interfacetigase.kernel.beans.RegistrarBean
-
unregister
public void unregister(tigase.kernel.core.Kernel kernel)
- Specified by:
unregister
in interfacetigase.kernel.beans.RegistrarBean
-
-