Class AmqpBaseOpDispenser

java.lang.Object

io.nosqlbench.nb.api.components.core.NBBaseComponentMetrics

io.nosqlbench.nb.api.components.core.NBBaseComponent

io.nosqlbench.adapters.api.activityimpl.BaseOpDispenser<AmqpTimeTrackOp,AmqpSpace>

io.nosqlbench.adapter.amqp.dispensers.AmqpBaseOpDispenser

All Implemented Interfaces:

OpDispenser<AmqpTimeTrackOp>, OpResultTracker, NBComponent, NBComponentAdvisors, NBComponentEvents, NBComponentMetrics, NBComponentProps, NBComponentServices, NBComponentTimeline, NBProviderSearch, NBTokenWords, NBLabeledElement, AutoCloseable, LongFunction<AmqpTimeTrackOp>

Direct Known Subclasses:

AmqpMsgRecvOpDispenser, AmqpMsgSendOpDispenser

public abstract class AmqpBaseOpDispenser
extends BaseOpDispenser<AmqpTimeTrackOp,AmqpSpace>

Nested Class Summary

Nested classes/interfaces inherited from interface io.nosqlbench.nb.api.labels.NBLabeledElement

NBLabeledElement.BasicLabeledElement

Field Summary

Fields

Modifier and Type	Field	Description
protected final AmqpAdapterMetrics	amqpAdapterMetrics
protected final Map<String,String>	amqpConfMap
protected String	exchangeType
protected final ParsedOp	parsedOp

Fields inherited from class io.nosqlbench.adapters.api.activityimpl.BaseOpDispenser

EXPECTED_RESULT, spaceF, START_TIMERS, STOP_TIMERS, VERIFIER, VERIFIER_IMPORTS, VERIFIER_INIT, verifierTimer

Fields inherited from class io.nosqlbench.nb.api.components.core.NBBaseComponent

bufferOrphanedMetrics, closed_ns, error, errored_ns, metricsBuffer, parent, started_epoch_ms, started_ns, state, teardown_ns

Fields inherited from interface io.nosqlbench.nb.api.components.core.NBComponent

EMPTY_COMPONENT

Fields inherited from interface io.nosqlbench.nb.api.components.core.NBComponentProps

HDRDIGITS, SUMMARY

Fields inherited from interface io.nosqlbench.nb.api.labels.NBLabeledElement

EMPTY

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AmqpBaseOpDispenser(AmqpDriverAdapter adapter, ParsedOp op)

Method Summary

Modifier and Type	Method	Description
protected void	declareExchange(long cycleNum, com.rabbitmq.client.Channel channel, String exchangeName, String exchangeType)
protected long	getChannelExchangeSeqNum(long cycle)
protected long	getConnChannelSeqNum(long cycle)
protected long	getConnSeqNum(long cycle)
protected String	getEffectiveExchangeName(long cycleNum, long connSeqNum, long channelSeqNum, long exchangeSeqNum)
protected String	getEffectiveExchangeNameByCycle(long cycle)
String	getName()
protected LongFunction<String>	lookupMandtoryStrOpValueFunc(String paramName)
protected LongFunction<String>	lookupOptionalStrOpValueFunc(String paramName, String defaultValue)

Methods inherited from class io.nosqlbench.adapters.api.activityimpl.BaseOpDispenser

apply, getLabels, getOpName, getVerifier, onError, onStart, onSuccess

Methods inherited from class io.nosqlbench.nb.api.components.core.NBBaseComponent

addAdvisor, addMetricsCloseable, attachChild, beforeDetach, close, create, detachChild, find, findParentService, getAdvisors, getChildren, getComponentOnlyLabels, getComponentProp, getComponentState, getNanosSinceStart, getParent, getTokens, nanosof_close, nanosof_error, nanosof_start, nanosof_teardown, onError, onEvent, reportExecutionMetric, setComponentProp, started_epoch_ms, teardown, toString

Methods inherited from class io.nosqlbench.nb.api.components.core.NBBaseComponentMetrics

addComponentMetric, addListener, findComponentMetrics, findComponentMetrics, getComponentMetric, getComponentMetrics, removeListener

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.nosqlbench.nb.api.components.core.NBComponentAdvisors

getAdvisorResults

Methods inherited from interface io.nosqlbench.nb.api.components.core.NBComponentMetrics

addComponentMetric, findComponentMetrics, findComponentMetrics, findOneComponentMetric, findOneComponentMetric, getComponentMetric, getComponentMetrics

Methods inherited from interface io.nosqlbench.nb.api.labels.NBLabeledElement

description

Methods inherited from interface io.nosqlbench.adapters.api.activityimpl.OpDispenser

getOp

Field Details

parsedOp

protected final ParsedOp parsedOp

amqpAdapterMetrics

protected final AmqpAdapterMetrics amqpAdapterMetrics

amqpConfMap

protected final Map<String,String> amqpConfMap

exchangeType

protected String exchangeType

Constructor Details

AmqpBaseOpDispenser

protected AmqpBaseOpDispenser(AmqpDriverAdapter adapter,
 ParsedOp op)

Method Details

lookupMandtoryStrOpValueFunc

protected LongFunction<String> lookupMandtoryStrOpValueFunc(String paramName)

lookupOptionalStrOpValueFunc

protected LongFunction<String> lookupOptionalStrOpValueFunc(String paramName,
 String defaultValue)

declareExchange

protected void declareExchange(long cycleNum,
 com.rabbitmq.client.Channel channel,
 String exchangeName,
 String exchangeType)

getConnSeqNum

protected long getConnSeqNum(long cycle)

getConnChannelSeqNum

protected long getConnChannelSeqNum(long cycle)

getChannelExchangeSeqNum

protected long getChannelExchangeSeqNum(long cycle)

getEffectiveExchangeNameByCycle

protected String getEffectiveExchangeNameByCycle(long cycle)

getEffectiveExchangeName

protected String getEffectiveExchangeName(long cycleNum,
 long connSeqNum,
 long channelSeqNum,
 long exchangeSeqNum)

getName

public String getName()