Class MessageConsumerOp

java.lang.Object

io.nosqlbench.adapter.s4j.ops.S4JOp

io.nosqlbench.adapter.s4j.ops.MessageConsumerOp

All Implemented Interfaces:

CycleOp<Object>, LongFunction<Object>

public class MessageConsumerOp
extends S4JOp

Field Summary

Fields inherited from class io.nosqlbench.adapter.s4j.ops.S4JOp

asyncApi, commitTransact, destination, jmsContext, maxS4jOpDurationInSec, messageSizeHistogram, s4jAdapterMetrics, s4jOpStartTimeMills, s4jSpace

Constructor Summary

Constructors

Constructor	Description
MessageConsumerOp(S4JAdapterMetrics s4jAdapterMetrics, S4JSpace s4jSpace, javax.jms.JMSContext jmsContext, javax.jms.Destination destination, boolean asyncApi, boolean commitTransact, javax.jms.JMSConsumer jmsConsumer, boolean blockingMsgRecv, float msgAckRatio, long readTimeout, boolean recvNoWait, int slowInSec)

Method Summary

Modifier and Type	Method	Description
Object	apply(long value)	Run an action for the given cycle.

Methods inherited from class java.lang.Object

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

Constructor Details

MessageConsumerOp

public MessageConsumerOp(S4JAdapterMetrics s4jAdapterMetrics,
 S4JSpace s4jSpace,
 javax.jms.JMSContext jmsContext,
 javax.jms.Destination destination,
 boolean asyncApi,
 boolean commitTransact,
 javax.jms.JMSConsumer jmsConsumer,
 boolean blockingMsgRecv,
 float msgAckRatio,
 long readTimeout,
 boolean recvNoWait,
 int slowInSec)

Method Details

apply

public Object apply(long value)

Description copied from interface: CycleOp

Run an action for the given cycle.

Parameters:

value - The cycle value for which an operation is run