|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.mule.transport.AbstractConnector org.mule.transport.vm.VMConnector
public class VMConnector
VMConnector
A simple endpoint wrapper to allow a Mule service to
Field Summary | |
---|---|
static String |
VM
|
Fields inherited from class org.mule.transport.AbstractConnector |
---|
connected, createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatchers, disposed, exceptionListener, initialised, logger, muleContext, name, numberOfConcurrentTransactedReceivers, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, started, startOnConnect |
Fields inherited from interface org.mule.api.transport.Connector |
---|
INT_VALUE_NOT_SET |
Fields inherited from interface org.mule.api.lifecycle.Initialisable |
---|
PHASE_NAME |
Fields inherited from interface org.mule.api.lifecycle.Startable |
---|
PHASE_NAME |
Fields inherited from interface org.mule.api.lifecycle.Stoppable |
---|
PHASE_NAME |
Fields inherited from interface org.mule.api.lifecycle.Disposable |
---|
PHASE_NAME |
Constructor Summary | |
---|---|
VMConnector()
|
Method Summary | |
---|---|
MessageReceiver |
createReceiver(Service service,
InboundEndpoint endpoint)
Create a Message receiver for this connector |
protected void |
doConnect()
Template method where any connections should be made for the connector |
protected void |
doDisconnect()
Template method where any connected resources used by the connector should be disconnected |
protected void |
doDispose()
Template method to perform any work when destroying the connectoe |
protected void |
doInitialise()
|
protected void |
doStart()
Template method to perform any work when starting the connectoe |
protected void |
doStop()
Template method to perform any work when stopping the connectoe |
MessageAdapter |
getMessageAdapter(Object message)
Gets a MessageAdapter for the endpoint for the given message
(data) |
String |
getProtocol()
|
QueueManager |
getQueueManager()
|
QueueProfile |
getQueueProfile()
|
int |
getQueueTimeout()
|
protected MessageReceiver |
getReceiverByEndpoint(EndpointURI endpointUri)
|
boolean |
isQueueEvents()
|
boolean |
isResponseEnabled()
|
void |
setQueueEvents(boolean queueEvents)
|
void |
setQueueProfile(QueueProfile queueProfile)
|
void |
setQueueTimeout(int queueTimeout)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public static final String VM
Constructor Detail |
---|
public VMConnector()
Method Detail |
---|
protected void doInitialise() throws InitialisationException
doInitialise
in class AbstractConnector
InitialisationException
protected void doDispose()
AbstractConnector
doDispose
in class AbstractConnector
protected void doConnect() throws Exception
AbstractConnector
doConnect
in class AbstractConnector
Exception
protected void doDisconnect() throws Exception
AbstractConnector
doDisconnect
in class AbstractConnector
Exception
protected void doStart() throws MuleException
AbstractConnector
doStart
in class AbstractConnector
MuleException
- if the method failsprotected void doStop() throws MuleException
AbstractConnector
doStop
in class AbstractConnector
MuleException
- if the method failspublic MessageReceiver createReceiver(Service service, InboundEndpoint endpoint) throws Exception
AbstractConnector
createReceiver
in class AbstractConnector
service
- the service that will receive events from this receiver,
the listenerendpoint
- the endpoint that defies this inbound communication
TransportServiceDescriptor
initialised using the service and endpoint.
Exception
- if there is a problem creating the receiver. This exception
really depends on the underlying transport, thus any exception
could be thrownpublic MessageAdapter getMessageAdapter(Object message) throws MessagingException
AbstractConnector
MessageAdapter
for the endpoint for the given message
(data)
getMessageAdapter
in interface Connector
getMessageAdapter
in class AbstractConnector
message
- the data with which to initialise the
MessageAdapter
MessageAdapter
for the endpoint
MessagingException
- if the message parameter is not supportedMessageAdapter
public String getProtocol()
public boolean isQueueEvents()
public void setQueueEvents(boolean queueEvents)
public QueueProfile getQueueProfile()
public void setQueueProfile(QueueProfile queueProfile)
protected MessageReceiver getReceiverByEndpoint(EndpointURI endpointUri) throws EndpointException
EndpointException
public boolean isResponseEnabled()
isResponseEnabled
in interface Connector
isResponseEnabled
in class AbstractConnector
public int getQueueTimeout()
public void setQueueTimeout(int queueTimeout)
public QueueManager getQueueManager()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |