public class DynamicURIInboundEndpoint extends Object implements InboundEndpoint
INITIAL_STATE_STARTED, INITIAL_STATE_STOPPEDREQUEST_NO_WAIT, REQUEST_WAIT_INDEFINITELY| Constructor and Description |
|---|
DynamicURIInboundEndpoint(InboundEndpoint endpoint) |
DynamicURIInboundEndpoint(InboundEndpoint endpoint,
EndpointURI dynamicEndpointURI) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(Object obj) |
ConnectionStrategy |
getConnectionStrategy()
Returns the connection strategy this endpoint should use when connecting to the underlying resource
|
Connector |
getConnector()
The endpoint that will be used to send the message on.
|
String |
getEncoding()
Decides the encoding to be used for events received by this endpoint
|
EndpointURI |
getEndpointURI()
This specifess the communication endpointUri.
|
Filter |
getFilter()
The filter to apply to incoming messages.
|
String |
getInitialState()
Sets the state the endpoint will be loaded in.
|
MuleContext |
getMuleContext() |
String |
getName()
The name is the identifier for the endpoint
|
Map |
getProperties()
Returns any properties set on this endpoint
|
Object |
getProperty(Object key)
Retrieves a property set on the endpoint
|
String |
getProtocol()
The transport protocol name that the message endpoint communicates over.
|
int |
getRemoteSyncTimeout()
The timeout value for remoteSync invocations
|
List |
getResponseTransformers()
The transformers used when a response is returned from invoking this endpoint.
|
EndpointSecurityFilter |
getSecurityFilter()
Returns an EndpointSecurityFilter for this endpoint.
|
TransactionConfig |
getTransactionConfig()
Returns the transaction configuration for this endpoint
|
List |
getTransformers()
Transformers are responsible for transforming data when it is received or
sent by the UMO (depending on whether this endpoint is a receiver or not).
|
int |
hashCode() |
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 |
isRemoteSync()
For certain providers that support the notion of a backchannel such as sockets
(outputStream) or Jms (ReplyTo) Mule can automatically wait for a response
from a backchannel when dispatching over these protocols.
|
boolean |
isSynchronous()
Determines if requests originating from this endpoint should be synchronous
i.e.
|
MuleMessage |
request(long timeout)
Make a specific request to the underlying transport
|
void |
setEndpointURI(EndpointURI dynamicEndpointURI) |
public DynamicURIInboundEndpoint(InboundEndpoint endpoint)
public DynamicURIInboundEndpoint(InboundEndpoint endpoint, EndpointURI dynamicEndpointURI)
public EndpointURI getEndpointURI()
ImmutableEndpointgetEndpointURI in interface ImmutableEndpointpublic void setEndpointURI(EndpointURI dynamicEndpointURI)
public ConnectionStrategy getConnectionStrategy()
ImmutableEndpointgetConnectionStrategy in interface ImmutableEndpointpublic Connector getConnector()
ImmutableEndpointgetConnector in interface ImmutableEndpointpublic String getEncoding()
ImmutableEndpointgetEncoding in interface ImmutableEndpointpublic Filter getFilter()
ImmutableEndpointgetFilter in interface ImmutableEndpointpublic String getInitialState()
ImmutableEndpointgetInitialState in interface ImmutableEndpointpublic MuleContext getMuleContext()
getMuleContext in interface ImmutableEndpointpublic String getName()
ImmutableEndpointgetName in interface ImmutableEndpointpublic Map getProperties()
ImmutableEndpointgetProperties in interface ImmutableEndpointpublic Object getProperty(Object key)
ImmutableEndpointgetProperty in interface ImmutableEndpointkey - the name of the propertypublic String getProtocol()
ImmutableEndpointgetProtocol in interface ImmutableEndpointpublic int getRemoteSyncTimeout()
ImmutableEndpointgetRemoteSyncTimeout in interface ImmutableEndpointpublic List getResponseTransformers()
ImmutableEndpointgetResponseTransformers in interface ImmutableEndpointpublic EndpointSecurityFilter getSecurityFilter()
ImmutableEndpointgetSecurityFilter in interface ImmutableEndpointEndpointSecurityFilterpublic TransactionConfig getTransactionConfig()
ImmutableEndpointgetTransactionConfig in interface ImmutableEndpointpublic List getTransformers()
ImmutableEndpointgetTransformers in interface ImmutableEndpointpublic boolean isDeleteUnacceptedMessages()
ImmutableEndpointisDeleteUnacceptedMessages in interface ImmutableEndpointpublic boolean isReadOnly()
isReadOnly in interface ImmutableEndpointpublic boolean isRemoteSync()
ImmutableEndpointisRemoteSync in interface ImmutableEndpointpublic boolean isSynchronous()
ImmutableEndpointisSynchronous in interface ImmutableEndpointpublic MuleMessage request(long timeout) throws Exception
MessageRequestingrequest in interface MessageRequestingtimeout - the maximum time the operation should block before returning.
The call should return immediately if there is data available. If
no data becomes available before the timeout elapses, null will be
returnedException - if the call to the underlying protocal causes an exceptionCopyright © 2003-2012 MuleSource, Inc.. All Rights Reserved.