public class AMQPTransportProducerTx extends Object
Constructor and Description |
---|
AMQPTransportProducerTx(boolean lightWeightPublisherConfirm,
com.rabbitmq.client.Channel channel) |
public AMQPTransportProducerTx(boolean lightWeightPublisherConfirm, com.rabbitmq.client.Channel channel)
public void start() throws IOException
IOException
public void end() throws InterruptedException, IOException
InterruptedException
IOException
Copyright © 2005-2017 Apache Software Foundation. All Rights Reserved.