Class S4JSpace

java.lang.Object

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

io.nosqlbench.adapter.s4j.S4JSpace

All Implemented Interfaces:

Space, NBNamedElement, AutoCloseable

public class S4JSpace
extends BaseSpace<S4JSpace>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	S4JSpace.JMSDestinationCacheKey
static final record	S4JSpace.JMSGenObjCacheKey

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

BaseSpace.BasicSpace

Field Summary

Fields

Modifier and Type	Field	Description
protected final ConcurrentHashMap<S4JSpace.JMSGenObjCacheKey,javax.jms.JMSConsumer>	jmsConsumers
protected final ConcurrentHashMap<S4JSpace.JMSDestinationCacheKey,javax.jms.Destination>	jmsDestinations
protected final ConcurrentHashMap<S4JSpace.JMSGenObjCacheKey,javax.jms.JMSProducer>	jmsProducers

Constructor Summary

Constructors

Constructor	Description
S4JSpace(S4JDriverAdapter adapter, long idx, NBConfiguration cfg)

Method Summary

Modifier and Type	Method	Description
void	close()
static NBConfigModel	getConfigModel()
javax.jms.JMSContext	getConnLvlJMSContext(String jmsContextIdentifier)
String	getConnLvlJmsContextIdentifier(int jmsConnSeqNum)
javax.jms.JMSConsumer	getJmsConsumer(S4JSpace.JMSGenObjCacheKey key, Supplier<javax.jms.JMSConsumer> jmsConsumerSupplier)
javax.jms.Destination	getJmsDestination(S4JSpace.JMSDestinationCacheKey key, Supplier<javax.jms.Destination> jmsDestinationSupplier)
javax.jms.JMSProducer	getJmsProducer(S4JSpace.JMSGenObjCacheKey key, Supplier<javax.jms.JMSProducer> jmsProducerSupplier)
org.apache.commons.lang3.tuple.Pair<Boolean,String>	getLargePayloadSimPair()
int	getMaxNumConn()
int	getMaxNumSessionPerConn()
long	getMaxS4JOpTimeInSec()
javax.jms.JMSContext	getOrCreateConnLvlJMSContext(com.datastax.oss.pulsar.jms.PulsarConnectionFactory s4jConnFactory, S4JClientConf s4JClientConf, int sessionMode)
long	getS4JActivityStartTimeMills()
S4JClientConf	getS4JClientConf()
String	getS4jClientConfFileName()
S4JJMSContextWrapper	getS4JJMSContextWrapper(S4JSpace.JMSGenObjCacheKey key, Supplier<S4JJMSContextWrapper> s4JJMSContextWrapperSupplier)
String	getSessionLvlJmsContextIdentifier(int jmsConnSeqNum, int jmsSessionSeqNum)
int	getSessionMode()
long	getTotalCycleNum()
long	getTotalNullMsgRecvdCnt()
long	getTotalOpResponseCnt()
int	getTxnBatchTrackingCnt()
long	incTotalNullMsgRecvdCnt()
long	incTotalOpResponseCnt()
void	incTxnBatchTrackingCnt()
void	initializeSpace(S4JClientConf s4JClientConnInfo)
boolean	isStrictMsgErrorHandling()
boolean	isTrackingMsgRecvCnt()
void	processMsgAck(javax.jms.JMSContext jmsContext, javax.jms.Message message, float msgAckRatio, int slowAckInSec)
void	setS4JActivityStartTimeMills(long startTime)
void	setTotalCycleNum(long cycleNum)
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

Field Details

jmsDestinations

protected final ConcurrentHashMap<S4JSpace.JMSDestinationCacheKey,javax.jms.Destination> jmsDestinations

jmsProducers

protected final ConcurrentHashMap<S4JSpace.JMSGenObjCacheKey,javax.jms.JMSProducer> jmsProducers

jmsConsumers

protected final ConcurrentHashMap<S4JSpace.JMSGenObjCacheKey,javax.jms.JMSConsumer> jmsConsumers

Constructor Details

S4JSpace

public S4JSpace(S4JDriverAdapter adapter,
 long idx,
 NBConfiguration cfg)

Method Details

close

public void close()

getConfigModel

public static NBConfigModel getConfigModel()

getConnLvlJMSContext

public javax.jms.JMSContext getConnLvlJMSContext(String jmsContextIdentifier)

getS4JJMSContextWrapper

public S4JJMSContextWrapper getS4JJMSContextWrapper(S4JSpace.JMSGenObjCacheKey key,
 Supplier<S4JJMSContextWrapper> s4JJMSContextWrapperSupplier)

getJmsDestination

public javax.jms.Destination getJmsDestination(S4JSpace.JMSDestinationCacheKey key,
 Supplier<javax.jms.Destination> jmsDestinationSupplier)

getJmsProducer

public javax.jms.JMSProducer getJmsProducer(S4JSpace.JMSGenObjCacheKey key,
 Supplier<javax.jms.JMSProducer> jmsProducerSupplier)

getJmsConsumer

public javax.jms.JMSConsumer getJmsConsumer(S4JSpace.JMSGenObjCacheKey key,
 Supplier<javax.jms.JMSConsumer> jmsConsumerSupplier)

getS4JActivityStartTimeMills

public long getS4JActivityStartTimeMills()

setS4JActivityStartTimeMills

public void setS4JActivityStartTimeMills(long startTime)

getMaxS4JOpTimeInSec

public long getMaxS4JOpTimeInSec()

getSessionMode

public int getSessionMode()

getS4jClientConfFileName

public String getS4jClientConfFileName()

getS4JClientConf

public S4JClientConf getS4JClientConf()

isTrackingMsgRecvCnt

public boolean isTrackingMsgRecvCnt()

getMaxNumSessionPerConn

public int getMaxNumSessionPerConn()

getMaxNumConn

public int getMaxNumConn()

isStrictMsgErrorHandling

public boolean isStrictMsgErrorHandling()

getTxnBatchTrackingCnt

public int getTxnBatchTrackingCnt()

incTxnBatchTrackingCnt

public void incTxnBatchTrackingCnt()

getTotalOpResponseCnt

public long getTotalOpResponseCnt()

incTotalOpResponseCnt

public long incTotalOpResponseCnt()

getTotalNullMsgRecvdCnt

public long getTotalNullMsgRecvdCnt()

incTotalNullMsgRecvdCnt

public long incTotalNullMsgRecvdCnt()

getTotalCycleNum

public long getTotalCycleNum()

setTotalCycleNum

public void setTotalCycleNum(long cycleNum)

getLargePayloadSimPair

public org.apache.commons.lang3.tuple.Pair<Boolean,String> getLargePayloadSimPair()

initializeSpace

public void initializeSpace(S4JClientConf s4JClientConnInfo)

shutdownSpace

public void shutdownSpace()

processMsgAck

public void processMsgAck(javax.jms.JMSContext jmsContext,
 javax.jms.Message message,
 float msgAckRatio,
 int slowAckInSec)
                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getConnLvlJmsContextIdentifier

public String getConnLvlJmsContextIdentifier(int jmsConnSeqNum)

getSessionLvlJmsContextIdentifier

public String getSessionLvlJmsContextIdentifier(int jmsConnSeqNum,
 int jmsSessionSeqNum)

getOrCreateConnLvlJMSContext

public javax.jms.JMSContext getOrCreateConnLvlJMSContext(com.datastax.oss.pulsar.jms.PulsarConnectionFactory s4jConnFactory,
 S4JClientConf s4JClientConf,
 int sessionMode)