Uses of Class
org.acemq.workloads.scenario.Scenario

Packages that use Scenario

Package	Description
org.acemq.workloads.scenario

Uses of Scenario in org.acemq.workloads.scenario

Methods in org.acemq.workloads.scenario that return Scenario

Modifier and Type	Method	Description
Scenario	Scenario.consumers(String queueName, Consumer<ConsumerGroupNode> spec)	Attaches consumers to a queue that is already in the scenario.
Scenario	Scenario.describedAs(String text)
Scenario	Scenario.exchange(String name, String type)
static Scenario	Scenario.named(String name)
Scenario	Scenario.producer(String name, Consumer<ProducerNode> spec)
Scenario	Scenario.queue(String name)
Scenario	Scenario.queue(String name, Consumer<QueueNode> spec)
Scenario	Scenario.runFor(Duration duration)
Scenario	ScenarioHandle.scenario()
Scenario	ScenarioReport.scenario()
Scenario	ScenarioFile.toScenario()
Scenario	Scenario.useExisting()	Runs against the topology as it already exists.
Scenario	Scenario.warmup(Duration warmup)

Methods in org.acemq.workloads.scenario with parameters of type Scenario

Modifier and Type	Method	Description
static ScenarioFile	ScenarioFile.of(Scenario scenario, String broker, String management, Map<String,Object> ui)
static ScenarioFile	ScenarioFile.of(Scenario scenario, String broker, String management, Map<String,Object> ui, ScenarioFile.SecurityJson security)	The same, keeping a security block the caller already has.
static ScenarioReport	ScenarioRunner.run(Scenario scenario, String brokerUrl)	Runs it and waits.
static ScenarioReport	ScenarioRunner.run(Scenario scenario, String brokerUrl, org.acemq.amqp.security.Security security)	Runs it against a broker that needs TLS, and waits.
static ScenarioReport	ScenarioRunner.run(Scenario scenario, String brokerUrl, org.acemq.amqp.security.Security security, ScenarioListener listener, AtomicBoolean stopRequested)	Runs it on this thread, reporting as it goes and stopping when asked.
static ScenarioHandle	ScenarioRunner.start(Scenario scenario, String brokerUrl, org.acemq.amqp.security.Security security, ScenarioListener listener)	Starts it against a broker that needs TLS.
static ScenarioHandle	ScenarioRunner.start(Scenario scenario, String brokerUrl, ScenarioListener listener)	Starts it on a thread of its own and reports as it goes.