Package org.wso2.carbon.inbound.endpoint.persistence

Class InboundEndpointsDataStore

java.lang.Object
org.wso2.carbon.inbound.endpoint.persistence.InboundEndpointsDataStore
public class InboundEndpointsDataStore extends Object

  • Method Details

    • getInstance

      public static InboundEndpointsDataStore getInstance()

    • 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:
      name -
      tenantId -

    • 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