org.wso2.carbon.inbound.endpoint.persistence

Class InboundEndpointsDataStore

java.lang.Object

org.wso2.carbon.inbound.endpoint.persistence.InboundEndpointsDataStore

public class InboundEndpointsDataStore
extends Object

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 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