Class AmqpSpace

java.lang.Object

io.nosqlbench.adapters.api.activityimpl.uniform.BaseSpace<AmqpSpace>

io.nosqlbench.adapter.amqp.AmqpSpace

All Implemented Interfaces:

Space, NBNamedElement, AutoCloseable

public class AmqpSpace
extends BaseSpace<AmqpSpace>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	AmqpSpace.AmqpChannelKey

Nested classes/interfaces inherited from class io.nosqlbench.adapters.api.activityimpl.uniform.BaseSpace

BaseSpace.BasicSpace

Constructor Summary

Constructors

Constructor	Description
AmqpSpace(AmqpDriverAdapter adapter, long idx, NBConfiguration cfg)

Method Summary

Modifier and Type	Method	Description
void	close()
long	getActivityStartTimeMills()
int	getAmqpChannelExchangeNum()
com.rabbitmq.client.Channel	getAmqpChannels(AmqpSpace.AmqpChannelKey key, Supplier<com.rabbitmq.client.Channel> channelSupplier)
AmqpClientConf	getAmqpClientConf()
int	getAmqpConnChannelNum()
com.rabbitmq.client.Connection	getAmqpConnection(Long id)
int	getAmqpConnNum()
int	getAmqpExchangeQueueNum()
String	getAmqpExchangeType()
int	getAmqpMsgClntNum()
static NBConfigModel	getConfigModel()
long	getMaxOpTimeInSec()
long	getTotalCycleNum()
long	getTotalThreadNum()
void	initializeSpace(AmqpClientConf amqpClientConf)
boolean	isStrictMsgErrorHandling()
void	setTotalCycleNum(long cycleNum)
void	setTotalThreadNum(long threadNum)
void	shutdownSpace()

Methods inherited from class io.nosqlbench.adapters.api.activityimpl.uniform.BaseSpace

getName

Methods inherited from class java.lang.Object

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

Constructor Details

AmqpSpace

public AmqpSpace(AmqpDriverAdapter adapter,
 long idx,
 NBConfiguration cfg)

Method Details

close

public void close()

getConfigModel

public static NBConfigModel getConfigModel()

getAmqpConnection

public com.rabbitmq.client.Connection getAmqpConnection(Long id)

getAmqpChannels

public com.rabbitmq.client.Channel getAmqpChannels(AmqpSpace.AmqpChannelKey key,
 Supplier<com.rabbitmq.client.Channel> channelSupplier)

getActivityStartTimeMills

public long getActivityStartTimeMills()

getMaxOpTimeInSec

public long getMaxOpTimeInSec()

getAmqpClientConf

public AmqpClientConf getAmqpClientConf()

getAmqpExchangeType

public String getAmqpExchangeType()

getAmqpConnNum

public int getAmqpConnNum()

getAmqpConnChannelNum

public int getAmqpConnChannelNum()

getAmqpChannelExchangeNum

public int getAmqpChannelExchangeNum()

getAmqpExchangeQueueNum

public int getAmqpExchangeQueueNum()

getAmqpMsgClntNum

public int getAmqpMsgClntNum()

isStrictMsgErrorHandling

public boolean isStrictMsgErrorHandling()

getTotalCycleNum

public long getTotalCycleNum()

setTotalCycleNum

public void setTotalCycleNum(long cycleNum)

getTotalThreadNum

public long getTotalThreadNum()

setTotalThreadNum

public void setTotalThreadNum(long threadNum)

initializeSpace

public void initializeSpace(AmqpClientConf amqpClientConf)

shutdownSpace

public void shutdownSpace()