org.apache.servicemix.common.endpoints
Class AbstractEndpoint

java.lang.Object
  org.apache.servicemix.common.endpoints.AbstractEndpoint

All Implemented Interfaces:

Endpoint

Direct Known Subclasses:

SimpleEndpoint

public abstract class AbstractEndpoint
extends Object
implements Endpoint

Field Summary

protected javax.wsdl.Definition	definition
protected Document	description
protected String	endpoint
protected QName	interfaceName
protected Log	logger
protected QName	service
protected ServiceUnit	serviceUnit

Constructor Summary

AbstractEndpoint()

AbstractEndpoint(ServiceUnit serviceUnit, QName service, String endpoint)

Method Summary

abstract void	activate() Register this endpoint into the NMR and put the endpoint in a STOPPED state, where the endpoint is able to process incoming requests, but won't consume external requests such as JMS messages or HTTP requests.
abstract void	deactivate() Unregister this endpoint from the NMR.
javax.wsdl.Definition	getDefinition()
Document	getDescription()
String	getEndpoint()
QName	getInterfaceName()
String	getKey()
abstract javax.jbi.messaging.MessageExchange.Role	getRole()
QName	getService()
ServiceUnit	getServiceUnit()
boolean	isExchangeOkay(javax.jbi.messaging.MessageExchange exchange)
void	prepareExchange(javax.jbi.messaging.MessageExchange exchange)
abstract void	process(javax.jbi.messaging.MessageExchange exchange) Process an incoming JBI exchange.
void	setDefinition(javax.wsdl.Definition definition)
void	setDescription(Document description) Associates an XML document with the endpoint.
void	setEndpoint(String endpoint) Sets the name of the endpoint.
void	setInterfaceName(QName interfaceName) Sets the QName of the interface exposed by the endpoint.
void	setService(QName service) Sets the name of the service the endpoint exposes.
void	setServiceUnit(ServiceUnit serviceUnit) Associates an endpoint with a service unit.
abstract void	start() Start consumption of external requests.
abstract void	stop() Stop consumption of external requests.
String	toString()
void	validate() Validate the endpoint at either deployment time for statically defined endpoints or at runtime for dynamic endpoints

Methods inherited from class java.lang.Object

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

Field Detail

service

protected QName service

endpoint

protected String endpoint

interfaceName

protected QName interfaceName

description

protected Document description

definition

protected javax.wsdl.Definition definition

serviceUnit

protected ServiceUnit serviceUnit

logger

protected Log logger

Constructor Detail

AbstractEndpoint

public AbstractEndpoint()

AbstractEndpoint

public AbstractEndpoint(ServiceUnit serviceUnit,
                        QName service,
                        String endpoint)

Method Detail

getEndpoint

public String getEndpoint()

Specified by:

getEndpoint in interface Endpoint

Returns:

Returns the endpoint.

setEndpoint

public void setEndpoint(String endpoint)

Sets the name of the endpoint.

Parameters:

endpoint - a string specifiying the name of the endpoint

getService

public QName getService()

Specified by:

getService in interface Endpoint

Returns:

Returns the service.

setService

public void setService(QName service)

Sets the name of the service the endpoint exposes.

Parameters:

service - a QName specifiying the name of the service

getRole

public abstract javax.jbi.messaging.MessageExchange.Role getRole()

Specified by:

getRole in interface Endpoint

Returns:

Returns the role.

getDescription

public Document getDescription()

Specified by:

getDescription in interface Endpoint

Returns:

Returns the description.

setDescription

public void setDescription(Document description)

Associates an XML document with the endpoint. The XML document describes the endpoint and is typically found in the service unit packaging.

Parameters:

description - a Document describing the endpoint

getInterfaceName

public QName getInterfaceName()

Specified by:

getInterfaceName in interface Endpoint

Returns:

Returns the interfaceName.

setInterfaceName

public void setInterfaceName(QName interfaceName)

Sets the QName of the interface exposed by the endpoint.

Parameters:

interfaceName - a QName specifiying the name of the interface

getServiceUnit

public ServiceUnit getServiceUnit()

Specified by:

getServiceUnit in interface Endpoint

Returns:

Returns the serviceUnit.

setServiceUnit

public void setServiceUnit(ServiceUnit serviceUnit)

Associates an endpoint with a service unit. The service unit is used by the container to manage the endpoint's lifecycle.

Specified by:

setServiceUnit in interface Endpoint

Parameters:

serviceUnit - a ServiceUnit to which the endpoint will be associated

isExchangeOkay

public boolean isExchangeOkay(javax.jbi.messaging.MessageExchange exchange)

Specified by:

isExchangeOkay in interface Endpoint

prepareExchange

public void prepareExchange(javax.jbi.messaging.MessageExchange exchange)
                     throws javax.jbi.messaging.MessagingException

Throws:

javax.jbi.messaging.MessagingException

activate

public abstract void activate()
                       throws Exception

Description copied from interface: Endpoint

Register this endpoint into the NMR and put the endpoint in a STOPPED state, where the endpoint is able to process incoming requests, but won't consume external requests such as JMS messages or HTTP requests.

Specified by:

activate in interface Endpoint

Throws:

Exception

start

public abstract void start()
                    throws Exception

Description copied from interface: Endpoint

Start consumption of external requests.

Specified by:

start in interface Endpoint

Throws:

Exception

stop

public abstract void stop()
                   throws Exception

Description copied from interface: Endpoint

Stop consumption of external requests.

Specified by:

stop in interface Endpoint

Throws:

Exception

deactivate

public abstract void deactivate()
                         throws Exception

Description copied from interface: Endpoint

Unregister this endpoint from the NMR.

Specified by:

deactivate in interface Endpoint

Throws:

Exception

process

public abstract void process(javax.jbi.messaging.MessageExchange exchange)
                      throws Exception

Description copied from interface: Endpoint

Process an incoming JBI exchange.

Specified by:

process in interface Endpoint

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object

validate

public void validate()
              throws javax.jbi.management.DeploymentException

Validate the endpoint at either deployment time for statically defined endpoints or at runtime for dynamic endpoints

Specified by:

validate in interface Endpoint

Throws:

javax.jbi.management.DeploymentException

getDefinition

public javax.wsdl.Definition getDefinition()

setDefinition

public void setDefinition(javax.wsdl.Definition definition)

getKey

public String getKey()

Specified by:

getKey in interface Endpoint