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
Nested classes/interfaces inherited from interface tigase.server.PacketWriterWithTimeout
tigase.server.PacketWriterWithTimeout.Handler
-
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
Fields inherited from interface tigase.disco.XMPPService
CMD_FEATURES, DEF_FEATURES, INFO_XMLNS, ITEMS_XMLNS
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
void
void
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
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
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, setIncoming_filters, setName, setOutgoing_filters, setParent, setSchedulerThreads_size, updateFiltersName
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, reloadScripts, 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.server.MessageReceiver
getDefHostName
Methods inherited from interface tigase.http.PacketWriter
isAdmin
Methods inherited from interface tigase.server.ServerComponent
getComponentId, getComponentInfo, getName, initializationCompleted, isInitializationComplete
Methods inherited from interface tigase.stats.StatisticsContainerIfc
getName
-
Constructor Details
-
HttpMessageReceiver
public HttpMessageReceiver()
-
-
Method Details
-
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
- Overrides:
getDiscoDescription
in classtigase.server.BasicComponent
-
isSubdomain
public boolean isSubdomain()- Overrides:
isSubdomain
in classtigase.server.BasicComponent
-
setActiveModules
-
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
-
write
- 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
-