|
| |
|
| org.mule.api.transport.Connector
All known Subclasses: org.mule.transport.AbstractConnector,
| INT_VALUE_NOT_SET | | int INT_VALUE_NOT_SET(Code) | | |
| getDispatcherFactory | | MessageDispatcherFactory getDispatcherFactory()(Code) | | The dispatcher factory is used to create a message dispatcher of the current
request
the factory to use when a dispatcher request is madr |
| getProtocol | | String getProtocol()(Code) | | the primary protocol name for endpoints of this connector |
| getRequesterFactory | | MessageRequesterFactory getRequesterFactory()(Code) | | The requester factory is used to create a message requester of the current
request
the factory to use when a request is made |
| handleException | | void handleException(Exception exception)(Code) | |
Parameters:
exception - the exception that was caught |
| isDisposed | | boolean isDisposed()(Code) | | false if the connector is alive and well or true if the connector isbeing destroyed |
| isDisposing | | boolean isDisposing()(Code) | | false if the connector is alive and well or true if the connector hasbeen told to dispose |
| isRemoteSyncEnabled | | boolean isRemoteSyncEnabled()(Code) | | |
| isStarted | | boolean isStarted()(Code) | | true if the endpoint is started |
| isSyncEnabled | | boolean isSyncEnabled(String protocol)(Code) | | Used to define is this connectors endpoints' should be synchronous by default rather than using mule's
instance wide default. The endpoint is passed through to this method so that transports like axis/xfire
can determine if synchronous should be default depending on the endpoint transport e.g. http/vm/jms
etc.
Parameters:
endpoint -
See Also: ImmutableEndpoint.isSynchronous |
| registerListener | | MessageReceiver registerListener(Service service, InboundEndpoint endpoint) throws Exception(Code) | | This creates a MessageReceiver associated with this endpoint
and registers it with the connector
Parameters:
service - the listening service
Parameters:
endpoint - the endpoint contains the listener endpointUri on which tolisten on.
throws:
Exception - if the MessageReceiver cannot be created or the Receivercannot be registered |
| request | | MuleMessage request(String uri, long timeout) throws Exception(Code) | | Make a specific request to the underlying transport
Parameters:
uri - the endpoint uri to use when connecting to the resource
Parameters:
timeout - the maximum time the operation should block before returning.The call should return immediately if there is data available. Ifno data becomes available before the timeout elapses, null will bereturned the result of the request wrapped in a MuleMessage object. Null will bereturned if no data was avaialable
throws:
Exception - if the call to the underlying protocal cuases an exception |
| request | | MuleMessage request(InboundEndpoint endpoint, long timeout) throws Exception(Code) | | Make a specific request to the underlying transport
Parameters:
endpoint - the endpoint to use when connecting to the resource
Parameters:
timeout - the maximum time the operation should block before returning.The call should return immediately if there is data available. Ifno data becomes available before the timeout elapses, null will bereturned the result of the request wrapped in a MuleMessage object. Null will bereturned if no data was avaialable
throws:
Exception - if the call to the underlying protocal cuases an exception |
| setDispatcherFactory | | void setDispatcherFactory(MessageDispatcherFactory factory)(Code) | | The dispatcher factory is used to create a message dispatcher of the current
request
Parameters:
factory - the factory to use when a dispatcher request is madr |
| setRequesterFactory | | void setRequesterFactory(MessageRequesterFactory factory)(Code) | | The requester factory is used to create a message requester of the current
request
Parameters:
factory - the factory to use when a request is made |
| supportsProtocol | | boolean supportsProtocol(String protocol)(Code) | | true if the protocol is supported by this connector. |
| unregisterListener | | void unregisterListener(Service service, InboundEndpoint endpoint) throws Exception(Code) | |
Parameters:
service - the listening service
Parameters:
endpoint - the associated endpointDescriptor with the listener
throws:
Exception - if the listener cannot be unregistered. If a listener is notassociated with the given endpoint this will not throw anexception |
|
|
|