ConsumerParameters |
ConsumerParameters.setAutoAck(boolean autoAck) |
ConsumerParameters |
ConsumerParameters.setChannel(com.rabbitmq.client.Channel channel) |
ConsumerParameters |
ConsumerParameters.setCompletionHandler(MulticastSet.CompletionHandler completionHandler) |
ConsumerParameters |
ConsumerParameters.setConsumerArguments(java.util.Map<java.lang.String,java.lang.Object> consumerArguments) |
ConsumerParameters |
ConsumerParameters.setConsumerLatencyIndicator(com.rabbitmq.perf.ValueIndicator<java.lang.Long> consumerLatenciesIndicator) |
ConsumerParameters |
ConsumerParameters.setExecutorService(java.util.concurrent.ExecutorService executorService) |
ConsumerParameters |
ConsumerParameters.setExitWhen(com.rabbitmq.perf.PerfTest.EXIT_WHEN exitWhen) |
ConsumerParameters |
ConsumerParameters.setId(java.lang.String id) |
ConsumerParameters |
ConsumerParameters.setMsgLimit(int msgLimit) |
ConsumerParameters |
ConsumerParameters.setMultiAckEvery(int multiAckEvery) |
ConsumerParameters |
ConsumerParameters.setNack(boolean nack) |
ConsumerParameters |
ConsumerParameters.setPerformanceMetrics(PerformanceMetrics performanceMetrics) |
ConsumerParameters |
ConsumerParameters.setPolling(boolean polling) |
ConsumerParameters |
ConsumerParameters.setPollingInterval(int pollingInterval) |
ConsumerParameters |
ConsumerParameters.setQueueNames(java.util.List<java.lang.String> queueNames) |
ConsumerParameters |
ConsumerParameters.setRateLimit(float rateLimit) |
ConsumerParameters |
ConsumerParameters.setRecoveryProcess(com.rabbitmq.perf.Recovery.RecoveryProcess recoveryProcess) |
ConsumerParameters |
ConsumerParameters.setRequeue(boolean requeue) |
ConsumerParameters |
ConsumerParameters.setStartListener(com.rabbitmq.perf.StartListener startListener) |
ConsumerParameters |
ConsumerParameters.setTimestampProvider(TimestampProvider timestampProvider) |
ConsumerParameters |
ConsumerParameters.setTxSize(int txSize) |