|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.mule.impl.ImmutableMuleEndpoint
ImmutableMuleEndpoint
describes a Provider in the Mule Server. A endpoint is
a grouping of an endpoint, an endpointUri and a transformer.
Field Summary | |
protected UMOConnector |
connector
The endpoint used to communicate with the external system |
protected boolean |
deleteUnacceptedMessages
determines whether unaccepted filtered events should be removed from the source. |
protected UMOEndpointURI |
endpointUri
The endpointUri on which to send or receive information |
protected UMOFilter |
filter
event filter for this endpoint |
protected SynchronizedBoolean |
initialised
has this endpoint been initialised |
protected static Log |
logger
logger used by this class |
protected java.lang.String |
name
The name for the endpoint |
protected java.util.Map |
properties
Any additional properties for the endpoint |
protected UMOEndpointSecurityFilter |
securityFilter
The security filter to apply to this endpoint |
protected java.lang.Boolean |
synchronous
whether events received by this endpoint should execute in a single thread |
protected UMOTransactionConfig |
transactionConfig
The transaction configuration for this endpoint |
protected UMOTransformer |
transformer
The transformer used to transform the incoming or outgoing data |
protected java.lang.String |
type
Determines whether the endpoint is a receiver or sender or both |
Fields inherited from interface org.mule.umo.endpoint.UMOImmutableEndpoint |
ENDPOINT_TYPE_RECEIVER, ENDPOINT_TYPE_RESPONSE, ENDPOINT_TYPE_SENDER, ENDPOINT_TYPE_SENDER_AND_RECEIVER |
Constructor Summary | |
ImmutableMuleEndpoint(java.lang.String endpoint,
java.lang.String type)
|
|
ImmutableMuleEndpoint(java.lang.String name,
UMOEndpointURI endpointUri,
UMOConnector connector,
UMOTransformer transformer,
java.lang.String type,
java.util.Map properties)
Default constructor |
|
ImmutableMuleEndpoint(UMOImmutableEndpoint source)
|
Method Summary | |
boolean |
canReceive()
Determines whether this endpoint can be used to receive events |
boolean |
canSend()
Determines whether this endpoint can be used to send events |
java.lang.Object |
clone()
Make a deep copy of this endpoint |
static UMOEndpoint |
createEndpointFromUri(UMOEndpointURI uri,
java.lang.String type)
|
boolean |
equals(java.lang.Object o)
|
UMOConnector |
getConnector()
The endpoint that will be used to send the message on. |
static UMOEndpoint |
getEndpointFromUri(java.lang.String uri)
|
static UMOEndpoint |
getEndpointFromUri(UMOEndpointURI uri)
|
UMOEndpointURI |
getEndpointURI()
This specifes the communication endpointUri. |
UMOFilter |
getFilter()
The filter to apply to incoming messages. |
java.lang.String |
getName()
The name is the identifier for the endpoint |
static UMOEndpoint |
getOrCreateEndpointForUri(java.lang.String uriIdentifier,
java.lang.String type)
|
static UMOEndpoint |
getOrCreateEndpointForUri(UMOEndpointURI uri,
java.lang.String type)
|
java.util.Map |
getProperties()
Returns any properties set on this endpoint |
java.lang.String |
getProtocol()
The transport protocol name that the message endpoint communicates over. |
UMOEndpointSecurityFilter |
getSecurityFilter()
Returns an UMOEndpointSecurityFilter for this endpoint. |
UMOTransactionConfig |
getTransactionConfig()
Returns the transaction configuration for this endpoint |
UMOTransformer |
getTransformer()
The transformer is responsible for transforming data when it is received or sent by the UMO (depending on whether this endpoint is a receiver or not). |
java.lang.String |
getType()
Determines whether the message endpoint is a sender or receiver or both. |
int |
hashCode()
|
protected void |
initFromDescriptor(UMOImmutableEndpoint source)
|
void |
initialise()
|
boolean |
isDeleteUnacceptedMessages()
If a filter is configured on this endpoint, this property will determine if message that are not excepted by the filter are deleted |
boolean |
isReadOnly()
|
boolean |
isSynchronous()
Determines if requests originating from this endpoint should be synchronous i.e. |
boolean |
isSynchronousExplicitlySet()
|
java.lang.String |
toString()
|
Methods inherited from class java.lang.Object |
finalize, getClass, notify, notifyAll, wait, wait, wait |
Field Detail |
protected static transient Log logger
protected UMOConnector connector
protected UMOEndpointURI endpointUri
protected UMOTransformer transformer
protected java.lang.String name
protected java.lang.String type
protected java.util.Map properties
protected UMOTransactionConfig transactionConfig
protected UMOFilter filter
protected boolean deleteUnacceptedMessages
protected SynchronizedBoolean initialised
protected UMOEndpointSecurityFilter securityFilter
protected java.lang.Boolean synchronous
Constructor Detail |
public ImmutableMuleEndpoint(java.lang.String endpoint, java.lang.String type) throws UMOException
public ImmutableMuleEndpoint(java.lang.String name, UMOEndpointURI endpointUri, UMOConnector connector, UMOTransformer transformer, java.lang.String type, java.util.Map properties)
public ImmutableMuleEndpoint(UMOImmutableEndpoint source)
Method Detail |
protected void initFromDescriptor(UMOImmutableEndpoint source)
public UMOEndpointURI getEndpointURI()
UMOImmutableEndpoint
getEndpointURI
in interface UMOImmutableEndpoint
public java.lang.String getType()
UMOImmutableEndpoint
getType
in interface UMOImmutableEndpoint
public UMOConnector getConnector()
UMOImmutableEndpoint
getConnector
in interface UMOImmutableEndpoint
public java.lang.String getName()
UMOImmutableEndpoint
getName
in interface UMOImmutableEndpoint
public UMOTransformer getTransformer()
UMOImmutableEndpoint
getTransformer
in interface UMOImmutableEndpoint
public java.util.Map getProperties()
UMOImmutableEndpoint
getProperties
in interface UMOImmutableEndpoint
public java.lang.Object clone()
UMOImmutableEndpoint
clone
in interface UMOImmutableEndpoint
public boolean isReadOnly()
isReadOnly
in interface UMOImmutableEndpoint
public java.lang.String toString()
public java.lang.String getProtocol()
UMOImmutableEndpoint
getProtocol
in interface UMOImmutableEndpoint
public boolean canReceive()
UMOImmutableEndpoint
canReceive
in interface UMOImmutableEndpoint
public boolean canSend()
UMOImmutableEndpoint
canSend
in interface UMOImmutableEndpoint
public UMOTransactionConfig getTransactionConfig()
UMOImmutableEndpoint
getTransactionConfig
in interface UMOImmutableEndpoint
public boolean equals(java.lang.Object o)
public int hashCode()
public UMOFilter getFilter()
UMOImmutableEndpoint
getFilter
in interface UMOImmutableEndpoint
public static UMOEndpoint createEndpointFromUri(UMOEndpointURI uri, java.lang.String type) throws UMOException
UMOException
public static UMOEndpoint getEndpointFromUri(java.lang.String uri)
public static UMOEndpoint getEndpointFromUri(UMOEndpointURI uri) throws UMOException
UMOException
public static UMOEndpoint getOrCreateEndpointForUri(java.lang.String uriIdentifier, java.lang.String type) throws UMOException
UMOException
public static UMOEndpoint getOrCreateEndpointForUri(UMOEndpointURI uri, java.lang.String type) throws UMOException
UMOException
public boolean isDeleteUnacceptedMessages()
UMOImmutableEndpoint
isDeleteUnacceptedMessages
in interface UMOImmutableEndpoint
public void initialise() throws InitialisationException
initialise
in interface Initialisable
InitialisationException
public UMOEndpointSecurityFilter getSecurityFilter()
getSecurityFilter
in interface UMOImmutableEndpoint
UMOEndpointSecurityFilter
public boolean isSynchronous()
isSynchronous
in interface UMOImmutableEndpoint
public boolean isSynchronousExplicitlySet()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |