org.mule.transport.amqp.internal.endpoint.dispatcher
Class DispatcherActionSend

java.lang.Object
  extended by org.mule.transport.amqp.internal.endpoint.dispatcher.DispatcherAction
      extended by org.mule.transport.amqp.internal.endpoint.dispatcher.DispatcherActionSend

public class DispatcherActionSend
extends DispatcherAction


Field Summary
protected  MessageConsumer messageConsumer
           
 
Constructor Summary
DispatcherActionSend()
           
 
Method Summary
 AmqpMessage run(AmqpConnector amqpConnector, com.rabbitmq.client.Channel channel, String exchange, String routingKey, AmqpMessage amqpMessage, long timeout)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

messageConsumer

protected MessageConsumer messageConsumer
Constructor Detail

DispatcherActionSend

public DispatcherActionSend()
Method Detail

run

public AmqpMessage run(AmqpConnector amqpConnector,
                       com.rabbitmq.client.Channel channel,
                       String exchange,
                       String routingKey,
                       AmqpMessage amqpMessage,
                       long timeout)
                throws IOException,
                       InterruptedException
Specified by:
run in class DispatcherAction
Throws:
IOException
InterruptedException


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