Rename setConfirmMode() to confirmSelect()
This commit is contained in:
parent
e0b04ad7e0
commit
eeee1c3c5f
|
|
@ -979,7 +979,7 @@ PUBLISHER CONFIRMS
|
||||||
|
|
||||||
RabbitMQ supports lightweight method of confirming that broker received and processed
|
RabbitMQ supports lightweight method of confirming that broker received and processed
|
||||||
a message. For this method to work, the channel needs to be put in so-called _confirm mode_.
|
a message. For this method to work, the channel needs to be put in so-called _confirm mode_.
|
||||||
This is done using setConfirmMode() method. When channel is successfully put in
|
This is done using confirmSelect() method. When channel is successfully put in
|
||||||
confirm mode, the server and client count messages (starting from 1) and server sends
|
confirm mode, the server and client count messages (starting from 1) and server sends
|
||||||
acknowledgments for every message it processed (it can also acknowledge multiple message at
|
acknowledgments for every message it processed (it can also acknowledge multiple message at
|
||||||
once).
|
once).
|
||||||
|
|
@ -1001,7 +1001,7 @@ channel.onNack([&](uint64 deliveryTag, bool multiple, bool requeue) {
|
||||||
});
|
});
|
||||||
|
|
||||||
// put channel in confirm mode
|
// put channel in confirm mode
|
||||||
channel.setConfirmMode().onSuccess([&]() {
|
channel.confirmSelect().onSuccess([&]() {
|
||||||
channel.publish("my-exchange", "my-key", "my first message");
|
channel.publish("my-exchange", "my-key", "my first message");
|
||||||
// message counter is now 1, will call onAck/onNack with deliverTag=1
|
// message counter is now 1, will call onAck/onNack with deliverTag=1
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -133,9 +133,9 @@ public:
|
||||||
* This function returns a deferred handler. Callbacks can be installed
|
* This function returns a deferred handler. Callbacks can be installed
|
||||||
* using onSuccess(), onError() and onFinalize() methods.
|
* using onSuccess(), onError() and onFinalize() methods.
|
||||||
*/
|
*/
|
||||||
Deferred &setConfirmMode()
|
Deferred &confirmSelect()
|
||||||
{
|
{
|
||||||
return _implementation->setConfirmMode();
|
return _implementation->confirmSelect();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
||||||
|
|
@ -287,7 +287,7 @@ public:
|
||||||
/**
|
/**
|
||||||
* Put channel in a confirm mode (RabbitMQ specific)
|
* Put channel in a confirm mode (RabbitMQ specific)
|
||||||
*/
|
*/
|
||||||
Deferred &setConfirmMode();
|
Deferred &confirmSelect();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Start a transaction
|
* Start a transaction
|
||||||
|
|
|
||||||
|
|
@ -187,7 +187,7 @@ Deferred &ChannelImpl::resume()
|
||||||
* This function returns a deferred handler. Callbacks can be installed
|
* This function returns a deferred handler. Callbacks can be installed
|
||||||
* using onSuccess(), onError() and onFinalize() methods.
|
* using onSuccess(), onError() and onFinalize() methods.
|
||||||
*/
|
*/
|
||||||
Deferred &ChannelImpl::setConfirmMode()
|
Deferred &ChannelImpl::confirmSelect()
|
||||||
{
|
{
|
||||||
// send a transaction frame
|
// send a transaction frame
|
||||||
return push(ConfirmSelectFrame(_id));
|
return push(ConfirmSelectFrame(_id));
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue