| java.lang.Object
 com.sun.jbi.messaging.EndpointRegistry
| EndpointRegistry | | public class EndpointRegistry implements ConnectionManager(Code) | | In-memory store of all endpoints that have been registered with the NMS.
author:
Sun Microsystems, Inc. |
| Inner Class :class Endpoint | |
| Method Summary | |
| public synchronized void | addEndpointConnection(QName fromService, String fromEndpoint, QName toService, String toEndpoint, Link linkType)
| | public synchronized void | addInterfaceConnection(QName fromInterface, QName toService, String toEndpoint)
| | void | clear()
| | int | countEndpoints(int type)
| | public RegisteredEndpoint | getExternalEndpoint(QName service, String endpoint)
| | public RegisteredEndpoint[] | getExternalEndpointsForInterface(QName interfaceName, MessageService msgSvc)
| | public RegisteredEndpoint[] | getExternalEndpointsForService(QName service)
| | final static synchronized EndpointRegistry | getInstance()
Get an instance of the registry. | | public RegisteredEndpoint | getInternalEndpoint(QName service, String endpoint)
Return a registered endpoint with the specified name, if one exists. | | public RegisteredEndpoint | getInternalEndpointByName(String epName)
Return a registered endpoint with the specified name, if one exists. | | public RegisteredEndpoint[] | getInternalEndpointsForInterface(QName interfaceName, MessageService msgSvc)
Find internal endpoints that implement the specified interface. | | RegisteredEndpoint[] | getInternalEndpointsForService(QName service, boolean convertLinks)
Retrieves all internal endpoints, including linked endpoints established
through service connections.
Parameters:
service - the service QName
Parameters:
convertLinks - true if a service connection link should be converted to its corresponding internal (e.g. | | public RegisteredEndpoint | getLinkedEndpointByName(String epName)
Return a linked endpoint with the specified name, if one exists. | | public String[] | getLinkedEndpointsByChannel(String dcName)
Return a list of linked endpoint owned by the specified channel. | | ServiceEndpoint[] | listEndpoints(int type)
| | public synchronized RegisteredEndpoint | registerExternalEndpoint(ServiceEndpoint endpoint, String ownerId)
| | public synchronized RegisteredEndpoint | registerInternalEndpoint(QName service, String endpoint, String ownerId)
| | public synchronized void | removeEndpoint(ServiceEndpoint ref)
Remove an endpoint reference from the registry. | | public synchronized boolean | removeEndpointConnection(QName fromService, String fromEndpoint, QName toService, String toEndpoint)
| | public synchronized boolean | removeInterfaceConnection(QName fromInterface, QName toService, String toEndpoint)
| | public RegisteredEndpoint | resolveLinkedEndpoint(LinkedEndpoint link)
Translates a linked endpoint to its internal counterpart based on
a service connection specification. | | public String | toString()
|
| addEndpointConnection | | public synchronized void addEndpointConnection(QName fromService, String fromEndpoint, QName toService, String toEndpoint, Link linkType) throws javax.jbi.messaging.MessagingException(Code) | | ######################################################################
##################### CONNECTION MANAGEMENT ##########################
####################################################################
|
| countEndpoints | | int countEndpoints(int type)(Code) | | |
| getInternalEndpointByName | | public RegisteredEndpoint getInternalEndpointByName(String epName)(Code) | | Return a registered endpoint with the specified name, if one exists.
|
| getInternalEndpointsForInterface | | public RegisteredEndpoint[] getInternalEndpointsForInterface(QName interfaceName, MessageService msgSvc)(Code) | | Find internal endpoints that implement the specified interface. If
a service connection exists for the interface, that connection is
used exclusive of any other services provided in JBI.
|
| getInternalEndpointsForService | | RegisteredEndpoint[] getInternalEndpointsForService(QName service, boolean convertLinks)(Code) | | Retrieves all internal endpoints, including linked endpoints established
through service connections.
Parameters:
service - the service QName
Parameters:
convertLinks - true if a service connection link should be converted to its corresponding internal (e.g. hard) endpoint. False if the linkedendpoint should be returned directly. |
| getLinkedEndpointByName | | public RegisteredEndpoint getLinkedEndpointByName(String epName)(Code) | | Return a linked endpoint with the specified name, if one exists.
|
| getLinkedEndpointsByChannel | | public String[] getLinkedEndpointsByChannel(String dcName)(Code) | | Return a list of linked endpoint owned by the specified channel.
|
| registerInternalEndpoint | | public synchronized RegisteredEndpoint registerInternalEndpoint(QName service, String endpoint, String ownerId) throws javax.jbi.messaging.MessagingException(Code) | | ######################################################################
####################### INTERNAL ENDPOINTS ###########################
####################################################################
|
| removeEndpoint | | public synchronized void removeEndpoint(ServiceEndpoint ref)(Code) | | Remove an endpoint reference from the registry. Invoking this method
will also set the reference to inactive status.
|
| removeEndpointConnection | | public synchronized boolean removeEndpointConnection(QName fromService, String fromEndpoint, QName toService, String toEndpoint)(Code) | | |
| removeInterfaceConnection | | public synchronized boolean removeInterfaceConnection(QName fromInterface, QName toService, String toEndpoint)(Code) | | |
| resolveLinkedEndpoint | | public RegisteredEndpoint resolveLinkedEndpoint(LinkedEndpoint link)(Code) | | Translates a linked endpoint to its internal counterpart based on
a service connection specification.
|
|
|