Class LdapConnectionManager

java.lang.Object
tigase.server.BasicComponent
tigase.server.AbstractMessageReceiver
tigase.socks5.AbstractConnectionManager<LdapIOService<Object>>
tigase.ldap.LdapConnectionManager
All Implemented Interfaces:
tigase.cluster.api.ClusteredComponentIfc, tigase.conf.Configurable, tigase.disco.XMPPService, tigase.kernel.beans.config.ConfigurationChangedAware, tigase.kernel.beans.Initializable, tigase.kernel.beans.RegistrarBean, tigase.net.IOServiceListener<LdapIOService<Object>>, tigase.server.MessageReceiver, tigase.server.PacketWriterWithTimeout, tigase.server.ServerComponent, tigase.stats.StatisticsContainer, tigase.stats.StatisticsContainerIfc, tigase.vhosts.VHostListener
@Bean(name="ldap", parent=tigase.kernel.core.Kernel.class, active=false) @ConfigType(DefaultMode) public class LdapConnectionManager extends tigase.socks5.AbstractConnectionManager<LdapIOService<Object>>

  • Nested Class Summary

    Nested classes/interfaces inherited from class tigase.socks5.AbstractConnectionManager

    tigase.socks5.AbstractConnectionManager.PortConfigBean, tigase.socks5.AbstractConnectionManager.PortsConfigBean, tigase.socks5.AbstractConnectionManager.SecPortConfigBean

    Nested classes/interfaces inherited from class tigase.server.BasicComponent

    tigase.server.BasicComponent.ServerInfoVHostItemExtension

    Nested classes/interfaces inherited from interface tigase.server.PacketWriterWithTimeout

    tigase.server.PacketWriterWithTimeout.Handler

  • Field Summary

    Fields inherited from class tigase.socks5.AbstractConnectionManager

    net_buffer, NET_BUFFER_HT_PROP_VAL, NET_BUFFER_ST_PROP_VAL, PORT_CLASS_PROP_KEY, PORT_IFC_PROP_KEY, PORT_IFC_PROP_VAL, PORT_KEY, PORT_SOCKET_PROP_KEY, PORT_TYPE_PROP_KEY, PORTS_PROP_KEY, PROP_KEY, services

    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

    Constructors
    Constructor
    Description
    LdapConnectionManager()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected int[]
    getDefaultPorts()
     
    protected int[]
    getDefaultSSLPorts()
     
    String
    getDiscoDescription()
     
    protected LdapIOService<Object>
    getIOServiceInstance()
     
    boolean
    isAnonymousAccessAllowed()
     
    boolean
    isAnyoneCanQuery()
     
    void
    packetsReady(LdapIOService<Object> serv)
     
    void
    processPacket(tigase.server.Packet packet)
     
    protected void
    processRequest(LdapIOService<Object> serv, com.unboundid.ldap.protocol.LDAPMessage message)
     
    protected void
    processRequest(LDAPSession session, com.unboundid.ldap.protocol.ProtocolOp request, Consumer<com.unboundid.ldap.protocol.ProtocolOp> consumer)
     
    void
    register(tigase.kernel.core.Kernel kernel)
     
    void
    serviceStarted(LdapIOService<Object> serv)
     
    void
    tlsHandshakeCompleted(LdapIOService<Object> service)
     

    Methods inherited from class tigase.socks5.AbstractConnectionManager

    connectWaitingTasks, doForAllServices, everyMinute, getDefPorts, getPorts, getStatistics, initializationCompleted, isHighThroughput, releaseListener, serviceStopped, start, stop, unregister

    Methods inherited from class tigase.server.AbstractMessageReceiver

    addOutPacket, addOutPacketNB, addOutPackets, addOutPacketWithTimeout, addOutPacketWithTimeout, addPacket, addPacketNB, addPackets, addRegexRouting, addTimerTask, addTimerTask, addTimerTask, addTimerTaskWithTimeout, addTimerTaskWithTimeout, beanConfigurationChanged, clearRegexRoutings, everyHour, everySecond, 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, getCommandACL, getComponentId, getComponentInfo, getDefaults, getDefHostName, getDefVHostItem, getDiscoCategory, getDiscoCategoryType, getDiscoExtensionsForm, getDiscoFeatures, getDiscoFeatures, getDiscoInfo, getDiscoItems, getName, getNodesConnected, getNodesConnectedWithLocal, getScriptCommands, getScriptItems, getServiceEntity, getServiceEntityCaps, getVHostItem, handlesLocalDomains, handlesNameSubdomains, handlesNonLocalDomains, hasNonAdminCommands, initBindings, initialize, isAdmin, isInitializationComplete, isLocalDomain, isLocalDomainOrComponent, isNonAdminCommands, isSubdomain, isTrusted, isTrusted, nodeConnected, nodeDisconnected, onNodeConnected, onNodeDisconnected, processScriptCommand, reloadScripts, removeComponentDomain, removeServiceDiscoveryItem, setAdmins, setClusterController, setCommandsACL, setProperties, setScriptsBaseDir, setVHostManager, updateServiceDiscoveryItem, updateServiceDiscoveryItem, updateServiceDiscoveryItem, updateServiceEntity

    Methods inherited from class 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.server.ServerComponent

    getComponentId, getComponentInfo, getName, isInitializationComplete

    Methods inherited from interface tigase.stats.StatisticsContainerIfc

    getName

  • Constructor Details

    • LdapConnectionManager

      public LdapConnectionManager()

  • Method Details

    • isAnonymousAccessAllowed

      public boolean isAnonymousAccessAllowed()

    • isAnyoneCanQuery

      public boolean isAnyoneCanQuery()

    • serviceStarted

      public void serviceStarted(LdapIOService<Object> serv)
      Overrides:
      serviceStarted in class tigase.socks5.AbstractConnectionManager<LdapIOService<Object>>

    • packetsReady

      public void packetsReady(LdapIOService<Object> serv) throws IOException
      Throws:
      IOException

    • processRequest

      protected void processRequest(LdapIOService<Object> serv, com.unboundid.ldap.protocol.LDAPMessage message) throws IOException
      Throws:
      IOException

    • processRequest

      protected void processRequest(LDAPSession session, com.unboundid.ldap.protocol.ProtocolOp request, Consumer<com.unboundid.ldap.protocol.ProtocolOp> consumer) throws Throwable
      Throws:
      Throwable

    • getDiscoDescription

      public String getDiscoDescription()
      Overrides:
      getDiscoDescription in class tigase.server.BasicComponent

    • processPacket

      public void processPacket(tigase.server.Packet packet)
      Specified by:
      processPacket in class tigase.server.AbstractMessageReceiver

    • tlsHandshakeCompleted

      public void tlsHandshakeCompleted(LdapIOService<Object> service)

    • getDefaultPorts

      protected int[] getDefaultPorts()
      Specified by:
      getDefaultPorts in class tigase.socks5.AbstractConnectionManager<LdapIOService<Object>>

    • getDefaultSSLPorts

      protected int[] getDefaultSSLPorts()
      Overrides:
      getDefaultSSLPorts in class tigase.socks5.AbstractConnectionManager<LdapIOService<Object>>

    • getIOServiceInstance

      protected LdapIOService<Object> getIOServiceInstance() throws IOException
      Specified by:
      getIOServiceInstance in class tigase.socks5.AbstractConnectionManager<LdapIOService<Object>>
      Throws:
      IOException

    • register

      public void register(tigase.kernel.core.Kernel kernel)
      Specified by:
      register in interface tigase.kernel.beans.RegistrarBean
      Overrides:
      register in class tigase.socks5.AbstractConnectionManager<LdapIOService<Object>>