Class AmqpAdapterUtil

java.lang.Object

io.nosqlbench.adapter.amqp.util.AmqpAdapterUtil

public class AmqpAdapterUtil
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	AmqpAdapterUtil.AMQP_EXCHANGE_TYPES
static enum	AmqpAdapterUtil.AMQP_PUB_CONFIRM_MODE

Field Summary

Fields

Modifier and Type	Field	Description
static int	AMQP_PUBLISH_CONFIRM_BATCH_NUM_MIN
static int	DFT_AMQP_PUBLISH_CONFIRM_BATCH_NUM
static int	DFT_AMQP_PUBLISH_CONFIRM_TIMEOUT_MS

Constructor Summary

Constructors

Constructor	Description
AmqpAdapterUtil()

Method Summary

Modifier and Type	Method	Description
static String	getValidAmqpExchangeTypeList()
static String	getValidAmqpPublisherConfirmModeList()
static void	messageErrorHandling(Exception exception, boolean strictErrorHandling, String errorMsg)
static void	pauseCurThreadExec(int pauseInSec)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

AMQP_PUBLISH_CONFIRM_BATCH_NUM_MIN

public static int AMQP_PUBLISH_CONFIRM_BATCH_NUM_MIN

DFT_AMQP_PUBLISH_CONFIRM_BATCH_NUM

public static int DFT_AMQP_PUBLISH_CONFIRM_BATCH_NUM

DFT_AMQP_PUBLISH_CONFIRM_TIMEOUT_MS

public static int DFT_AMQP_PUBLISH_CONFIRM_TIMEOUT_MS

Constructor Details

AmqpAdapterUtil

public AmqpAdapterUtil()

Method Details

getValidAmqpExchangeTypeList

public static String getValidAmqpExchangeTypeList()

getValidAmqpPublisherConfirmModeList

public static String getValidAmqpPublisherConfirmModeList()

pauseCurThreadExec

public static void pauseCurThreadExec(int pauseInSec)

messageErrorHandling

public static void messageErrorHandling(Exception exception,
 boolean strictErrorHandling,
 String errorMsg)