Interface for a RedeliveryPolicy object that controls how message Redelivery is handled in ActiveMQ-CPP when a transaction is rolled back.
More...
#include <src/main/activemq/core/RedeliveryPolicy.h>
Interface for a RedeliveryPolicy object that controls how message Redelivery is handled in ActiveMQ-CPP when a transaction is rolled back.
- Since
- 3.2.0
activemq::core::RedeliveryPolicy::RedeliveryPolicy |
( |
| ) |
|
|
protected |
virtual activemq::core::RedeliveryPolicy::~RedeliveryPolicy |
( |
| ) |
|
|
virtual |
Checks the supplied properties object for properties matching the configurable settings of this class.
The default implementation looks for properties named with the prefix cms.RedeliveryPolicy.XXX where XXX is the name of a property with a public setter method. For instance cms.RedeliveryPolicy.useExponentialBackOff will be used to set the value of the use exponential back off toggle.
Subclasses can override this method to add more configuration options or to exclude certain parameters from being set via the properties object.
- Parameters
-
properties | The Properties object used to configure this object. |
- Exceptions
-
NumberFormatException | if a property that is numeric cannot be converted |
IllegalArgumentException | if a property can't be converted to the correct type. |
virtual double activemq::core::RedeliveryPolicy::getBackOffMultiplier |
( |
| ) |
const |
|
pure virtual |
virtual short activemq::core::RedeliveryPolicy::getCollisionAvoidancePercent |
( |
| ) |
const |
|
pure virtual |
virtual long long activemq::core::RedeliveryPolicy::getInitialRedeliveryDelay |
( |
| ) |
const |
|
pure virtual |
virtual int activemq::core::RedeliveryPolicy::getMaximumRedeliveries |
( |
| ) |
const |
|
pure virtual |
virtual long long activemq::core::RedeliveryPolicy::getMaximumRedeliveryDelay |
( |
| ) |
const |
|
pure virtual |
virtual long long activemq::core::RedeliveryPolicy::getNextRedeliveryDelay |
( |
long long |
previousDelay | ) |
|
|
pure virtual |
Given the last used redelivery delay calculate the next value of the delay based on the settings in this Policy instance.
- Parameters
-
previousDelay | The last delay that was used between message redeliveries. |
- Returns
- the new delay to use before attempting another redelivery.
Implemented in activemq::core::policies::DefaultRedeliveryPolicy.
virtual long long activemq::core::RedeliveryPolicy::getRedeliveryDelay |
( |
| ) |
const |
|
pure virtual |
virtual bool activemq::core::RedeliveryPolicy::isUseCollisionAvoidance |
( |
| ) |
const |
|
pure virtual |
virtual bool activemq::core::RedeliveryPolicy::isUseExponentialBackOff |
( |
| ) |
const |
|
pure virtual |
virtual void activemq::core::RedeliveryPolicy::setBackOffMultiplier |
( |
double |
value | ) |
|
|
pure virtual |
virtual void activemq::core::RedeliveryPolicy::setCollisionAvoidancePercent |
( |
short |
value | ) |
|
|
pure virtual |
virtual void activemq::core::RedeliveryPolicy::setInitialRedeliveryDelay |
( |
long long |
value | ) |
|
|
pure virtual |
virtual void activemq::core::RedeliveryPolicy::setMaximumRedeliveries |
( |
int |
maximumRedeliveries | ) |
|
|
pure virtual |
virtual void activemq::core::RedeliveryPolicy::setMaximumRedeliveryDelay |
( |
long long |
value | ) |
|
|
pure virtual |
Sets the maximum amount of time that the redelivery delay is allowed to increase to before it is capped.
By default this value is set to -1 which disables any maximum delay.
- Parameters
-
value | The maximum redelivery delay value in milliseconds. |
Implemented in activemq::core::policies::DefaultRedeliveryPolicy.
virtual void activemq::core::RedeliveryPolicy::setRedeliveryDelay |
( |
long long |
value | ) |
|
|
pure virtual |
virtual void activemq::core::RedeliveryPolicy::setUseCollisionAvoidance |
( |
bool |
value | ) |
|
|
pure virtual |
virtual void activemq::core::RedeliveryPolicy::setUseExponentialBackOff |
( |
bool |
value | ) |
|
|
pure virtual |
const long long activemq::core::RedeliveryPolicy::NO_MAXIMUM_REDELIVERIES |
|
static |
The documentation for this class was generated from the following file: