org.mule.endpoint
Class DefaultInboundEndpoint
java.lang.Object
org.mule.endpoint.AbstractEndpoint
org.mule.endpoint.DefaultInboundEndpoint
- All Implemented Interfaces:
- Serializable, ImmutableEndpoint, InboundEndpoint, MessageRequesting
public class DefaultInboundEndpoint
- extends AbstractEndpoint
- implements InboundEndpoint
- See Also:
- Serialized Form
Constructor Summary |
DefaultInboundEndpoint(Connector connector,
EndpointURI endpointUri,
List transformers,
List responseTransformers,
String name,
Map properties,
TransactionConfig transactionConfig,
Filter filter,
boolean deleteUnacceptedMessage,
EndpointSecurityFilter securityFilter,
boolean synchronous,
int responseTimeout,
String initialState,
String endpointEncoding,
String endpointBuilderName,
MuleContext muleContext,
RetryPolicyTemplate retryPolicyTemplate)
|
Method Summary |
MuleMessage |
request(long timeout)
Make a specific request to the underlying transport |
Methods inherited from class org.mule.endpoint.AbstractEndpoint |
equal, equals, getConnector, getEncoding, getEndpointBuilderName, getEndpointURI, getFilter, getInitialState, getMuleContext, getName, getProperties, getProperty, getProtocol, getResponseTimeout, getResponseTransformers, getRetryPolicyTemplate, getSecurityFilter, getTransactionConfig, getTransformers, hashCode, isDeleteUnacceptedMessages, isReadOnly, isSynchronous, toString, updateTransformerEndpoints |
Methods inherited from interface org.mule.api.endpoint.ImmutableEndpoint |
getConnector, getEncoding, getEndpointBuilderName, getEndpointURI, getFilter, getInitialState, getMuleContext, getName, getProperties, getProperty, getProtocol, getResponseTimeout, getResponseTransformers, getRetryPolicyTemplate, getSecurityFilter, getTransactionConfig, getTransformers, isDeleteUnacceptedMessages, isReadOnly, isSynchronous |
DefaultInboundEndpoint
public DefaultInboundEndpoint(Connector connector,
EndpointURI endpointUri,
List transformers,
List responseTransformers,
String name,
Map properties,
TransactionConfig transactionConfig,
Filter filter,
boolean deleteUnacceptedMessage,
EndpointSecurityFilter securityFilter,
boolean synchronous,
int responseTimeout,
String initialState,
String endpointEncoding,
String endpointBuilderName,
MuleContext muleContext,
RetryPolicyTemplate retryPolicyTemplate)
request
public MuleMessage request(long timeout)
throws Exception
- Description copied from interface:
MessageRequesting
- Make a specific request to the underlying transport
- Specified by:
request
in interface MessageRequesting
- Parameters:
timeout
- 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
returned
- Returns:
- the result of the request wrapped in a MuleMessage object. Null will be
returned if no data was avaialable
- Throws:
Exception
- if the call to the underlying protocal causes an exception
Copyright © 2003-2009 MuleSource, Inc.. All Rights Reserved.