Class RepeatedPublishSpec

java.lang.Object

io.micronaut.mqtt.test.intercept.RepeatedPublishSpec

All Implemented Interfaces:

AbstractMQTTTest

public abstract class RepeatedPublishSpec
extends Object
implements AbstractMQTTTest

Every call of a publisher method publishes its own payload, not only the first, and so does every instance of a publisher.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RepeatedPublishSpec.RepeatedSubscriber	Records the payloads received on TOPIC.

Nested classes/interfaces inherited from interface AbstractMQTTTest

AbstractMQTTTest.MQTTContainer

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TOPIC

Constructor Summary

Constructors

Constructor	Description
RepeatedPublishSpec()

Method Summary

Modifier and Type	Method	Description
abstract Class<? extends RepeatedPublishClient>	getClient()
abstract Class<? extends PrototypePublishClient>	getPrototypeClient()
abstract Class<? extends RepeatedPublishSpec.RepeatedSubscriber>	getSubscriber()

Methods inherited from class Object

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

Methods inherited from interface AbstractMQTTTest

startContext, startContext

Field Details

TOPIC

public static final String TOPIC

See Also:

• Constant Field Values

Constructor Details

RepeatedPublishSpec

public RepeatedPublishSpec()

Method Details

getClient

public abstract Class<? extends RepeatedPublishClient> getClient()

getPrototypeClient

public abstract Class<? extends PrototypePublishClient> getPrototypeClient()

Returns:

A publisher of prototype scope, of which each instance has its own executable methods

getSubscriber

public abstract Class<? extends RepeatedPublishSpec.RepeatedSubscriber> getSubscriber()