org.mule.transport.amqp.internal.endpoint.requester
Class MessageRequester

java.lang.Object
  extended by org.mule.transport.AbstractTransportMessageHandler
      extended by org.mule.transport.AbstractMessageRequester
          extended by org.mule.transport.amqp.internal.endpoint.requester.MessageRequester
All Implemented Interfaces:
org.mule.api.lifecycle.Disposable, org.mule.api.lifecycle.Initialisable, org.mule.api.lifecycle.Lifecycle, org.mule.api.lifecycle.LifecycleStateEnabled, org.mule.api.lifecycle.Startable, org.mule.api.lifecycle.Stoppable, org.mule.api.transport.Connectable, org.mule.api.transport.MessageRequester, org.mule.api.transport.MessageRequesting

public class MessageRequester
extends org.mule.transport.AbstractMessageRequester

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

amqpConnector

protected final AmqpConnector amqpConnector

messageConsumer

protected MessageConsumer messageConsumer

messagePropertiesHandler

protected MessagePropertiesHandler messagePropertiesHandler
Constructor Detail

MessageRequester

public MessageRequester(org.mule.api.endpoint.InboundEndpoint endpoint)
Method Detail

doConnect

public void doConnect()
               throws org.mule.transport.ConnectException
Overrides:
doConnect in class org.mule.transport.AbstractTransportMessageHandler
Throws:
org.mule.transport.ConnectException

doDisconnect

public void doDisconnect()
                  throws org.mule.api.MuleException
Overrides:
doDisconnect in class org.mule.transport.AbstractTransportMessageHandler
Throws:
org.mule.api.MuleException

doRequest

protected org.mule.api.MuleMessage doRequest(long timeout)
                                      throws Exception
Specified by:
doRequest in class org.mule.transport.AbstractMessageRequester
Throws:
Exception

getQueueName

protected String getQueueName()


Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.