Class InboundEndpointsDataStore


  • public class InboundEndpointsDataStore
    extends Object
    • Method Detail

      • registerListeningEndpoint

        public void registerListeningEndpoint​(int port,
                                              String tenantDomain,
                                              String protocol,
                                              String name,
                                              org.apache.synapse.inbound.InboundProcessorParams params)
        Register endpoint in the InboundEndpointsDataStore
        Parameters:
        port - listener port
        tenantDomain - tenant domain
        protocol - protocol
        name - endpoint name
      • registerPollingingEndpoint

        public void registerPollingingEndpoint​(String tenantDomain,
                                               String name)
        Register endpoint in the InboundEndpointsDataStore
        Parameters:
        tenantDomain - tenant domain
        name - endpoint name
      • registerSSLListeningEndpoint

        public void registerSSLListeningEndpoint​(int port,
                                                 String tenantDomain,
                                                 String protocol,
                                                 String name,
                                                 org.apache.synapse.transport.passthru.core.ssl.SSLConfiguration sslConfiguration,
                                                 org.apache.synapse.inbound.InboundProcessorParams params)
        Register SSL endpoint in the InboundEndpointsDataStore
        Parameters:
        port - listener port
        tenantDomain - tenant domain
        protocol - protocol
        name - endpoint name
      • getListeningEndpointName

        public String getListeningEndpointName​(int port,
                                               String tenantDomain)
        Get endpoint name for given port and domain
        Parameters:
        port - port
        tenantDomain - tenant domain
        Returns:
        endpoint name
      • unregisterListeningEndpoint

        public void unregisterListeningEndpoint​(int port,
                                                String tenantDomain)
        Unregister an endpoint from data store
        Parameters:
        port - port
        tenantDomain - tenant domain name
      • unregisterPollingEndpoint

        public void unregisterPollingEndpoint​(String tenantDomain,
                                              String name)
        Unregister an endpoint from data store
        Parameters:
        tenantId -
        name -
      • isPollingEndpointRegistered

        public boolean isPollingEndpointRegistered​(String tenantDomain,
                                                   String name)
        Check polling endpoint from data store
        Parameters:
        tenantDomain -
        name -
      • isEndpointRegistryEmpty

        public boolean isEndpointRegistryEmpty​(int port)
        Check whether endpoint registry is empty for a particular port
        Parameters:
        port - port
        Returns:
        whether no endpoint is registered for a port
      • getAllListeningEndpointData

        public Map<Integer,​List<InboundEndpointInfoDTO>> getAllListeningEndpointData()
        Get details of all endpoints
        Returns:
        information of all endpoints
      • getAllPollingingEndpointData

        public Map<String,​Set<String>> getAllPollingingEndpointData()
        Get details of all polling endpoints
        Returns:
        information of all polling endpoints