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

Class InboundEndpointsDataStore