|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.mule.transport.AbstractTransportMessageHandler
org.mule.transport.AbstractMessageRequester
org.mule.transport.amqp.internal.endpoint.requester.MessageRequester
public class MessageRequester
The MessageRequester
is used to consume individual messages from an AMQP broker.
Field Summary | |
---|---|
protected AmqpConnector |
amqpConnector
|
protected MessageConsumer |
messageConsumer
|
protected MessagePropertiesHandler |
messagePropertiesHandler
|
Fields inherited from class org.mule.transport.AbstractTransportMessageHandler |
---|
connected, connector, lifecycleManager, logger, muleMessageFactory, retryTemplate |
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 |
Fields inherited from interface org.mule.api.transport.MessageRequesting |
---|
REQUEST_NO_WAIT, REQUEST_WAIT_INDEFINITELY |
Constructor Summary | |
---|---|
MessageRequester(org.mule.api.endpoint.InboundEndpoint endpoint)
|
Method Summary | |
---|---|
void |
doConnect()
|
void |
doDisconnect()
|
protected org.mule.api.MuleMessage |
doRequest(long timeout)
|
protected String |
getQueueName()
|
Methods inherited from class org.mule.transport.AbstractMessageRequester |
---|
applyInboundTransformers, createLifecycleManager, getEndpoint, getRequesterName, getWorkManager, initialise, request |
Methods inherited from class org.mule.transport.AbstractTransportMessageHandler |
---|
activate, connect, connectHandler, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doDispose, doInitialise, doStart, doStartHandler, doStop, getConnectEventId, getConnectionDescription, getConnector, getLifecycleState, initializeMessageFactory, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopped, isStopping, passivate, setEndpoint, start, stop, toString, validate, validateConnection |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.mule.api.transport.MessageRequester |
---|
activate, createMuleMessage, createMuleMessage, getConnector, passivate, validate |
Methods inherited from interface org.mule.api.transport.Connectable |
---|
connect, disconnect, getConnectionDescription, isConnected, validateConnection |
Methods inherited from interface org.mule.api.lifecycle.Startable |
---|
start |
Methods inherited from interface org.mule.api.lifecycle.Stoppable |
---|
stop |
Methods inherited from interface org.mule.api.lifecycle.Disposable |
---|
dispose |
Methods inherited from interface org.mule.api.lifecycle.LifecycleStateEnabled |
---|
getLifecycleState |
Field Detail |
---|
protected final AmqpConnector amqpConnector
protected MessageConsumer messageConsumer
protected MessagePropertiesHandler messagePropertiesHandler
Constructor Detail |
---|
public MessageRequester(org.mule.api.endpoint.InboundEndpoint endpoint)
Method Detail |
---|
public void doConnect() throws org.mule.transport.ConnectException
doConnect
in class org.mule.transport.AbstractTransportMessageHandler
org.mule.transport.ConnectException
public void doDisconnect() throws org.mule.api.MuleException
doDisconnect
in class org.mule.transport.AbstractTransportMessageHandler
org.mule.api.MuleException
protected org.mule.api.MuleMessage doRequest(long timeout) throws Exception
doRequest
in class org.mule.transport.AbstractMessageRequester
Exception
protected String getQueueName()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |