Class InboundEndpointsDataStore
- java.lang.Object
-
- org.wso2.carbon.inbound.endpoint.persistence.InboundEndpointsDataStore
-
public class InboundEndpointsDataStore extends Object
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Map<Integer,List<InboundEndpointInfoDTO>>
getAllListeningEndpointData()
Get details of all endpointsMap<String,Set<String>>
getAllPollingingEndpointData()
Get details of all polling endpointsstatic InboundEndpointsDataStore
getInstance()
String
getListeningEndpointName(int port, String tenantDomain)
Get endpoint name for given port and domainboolean
isEndpointRegistryEmpty(int port)
Check whether endpoint registry is empty for a particular portboolean
isPollingEndpointRegistered(String tenantDomain, String name)
Check polling endpoint from data storevoid
registerListeningEndpoint(int port, String tenantDomain, String protocol, String name, org.apache.synapse.inbound.InboundProcessorParams params)
Register endpoint in the InboundEndpointsDataStorevoid
registerPollingingEndpoint(String tenantDomain, String name)
Register endpoint in the InboundEndpointsDataStorevoid
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 InboundEndpointsDataStorevoid
unregisterListeningEndpoint(int port, String tenantDomain)
Unregister an endpoint from data storevoid
unregisterPollingEndpoint(String tenantDomain, String name)
Unregister an endpoint from data store
-
-
-
Method Detail
-
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 porttenantDomain
- tenant domainprotocol
- protocolname
- endpoint name
-
registerPollingingEndpoint
public void registerPollingingEndpoint(String tenantDomain, String name)
Register endpoint in the InboundEndpointsDataStore- Parameters:
tenantDomain
- tenant domainname
- 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 porttenantDomain
- tenant domainprotocol
- protocolname
- endpoint name
-
getListeningEndpointName
public String getListeningEndpointName(int port, String tenantDomain)
Get endpoint name for given port and domain- Parameters:
port
- porttenantDomain
- tenant domain- Returns:
- endpoint name
-
unregisterListeningEndpoint
public void unregisterListeningEndpoint(int port, String tenantDomain)
Unregister an endpoint from data store- Parameters:
port
- porttenantDomain
- 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
-
-