public class InboundEndpointsDataStore extends Object
Modifier and Type | Method and Description |
---|---|
Map<Integer,List<InboundEndpointInfoDTO>> |
getAllListeningEndpointData()
Get details of all endpoints
|
Map<String,Set<String>> |
getAllPollingingEndpointData()
Get details of all polling endpoints
|
static InboundEndpointsDataStore |
getInstance() |
String |
getListeningEndpointName(int port,
String tenantDomain)
Get endpoint name for given port and domain
|
boolean |
isEndpointRegistryEmpty(int port)
Check whether endpoint registry is empty for a particular port
|
boolean |
isPollingEndpointRegistered(String tenantDomain,
String name)
Check polling endpoint from data store
|
void |
registerListeningEndpoint(int port,
String tenantDomain,
String protocol,
String name,
org.apache.synapse.inbound.InboundProcessorParams params)
Register endpoint in the InboundEndpointsDataStore
|
void |
registerPollingingEndpoint(String tenantDomain,
String name)
Register endpoint in the InboundEndpointsDataStore
|
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
|
void |
unregisterListeningEndpoint(int port,
String tenantDomain)
Unregister an endpoint from data store
|
void |
unregisterPollingEndpoint(String tenantDomain,
String name)
Unregister an endpoint from data store
|
public static InboundEndpointsDataStore getInstance()
public void registerListeningEndpoint(int port, String tenantDomain, String protocol, String name, org.apache.synapse.inbound.InboundProcessorParams params)
port
- listener porttenantDomain
- tenant domainprotocol
- protocolname
- endpoint namepublic void registerPollingingEndpoint(String tenantDomain, String name)
tenantDomain
- tenant domainname
- endpoint namepublic 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)
port
- listener porttenantDomain
- tenant domainprotocol
- protocolname
- endpoint namepublic String getListeningEndpointName(int port, String tenantDomain)
port
- porttenantDomain
- tenant domainpublic void unregisterListeningEndpoint(int port, String tenantDomain)
port
- porttenantDomain
- tenant domain namepublic void unregisterPollingEndpoint(String tenantDomain, String name)
tenantId
- name
- public boolean isPollingEndpointRegistered(String tenantDomain, String name)
tenantDomain
- name
- public boolean isEndpointRegistryEmpty(int port)
port
- portpublic Map<Integer,List<InboundEndpointInfoDTO>> getAllListeningEndpointData()
Copyright © 2019 WSO2. All rights reserved.