Class RepeatedPublishSpec.RepeatedSubscriber

java.lang.Object

io.micronaut.mqtt.test.intercept.RepeatedPublishSpec.RepeatedSubscriber

Enclosing class:

RepeatedPublishSpec

public abstract static class RepeatedPublishSpec.RepeatedSubscriber
extends Object

Records the payloads received on RepeatedPublishSpec.TOPIC.

Constructor Summary

Constructors

Constructor	Description
RepeatedSubscriber()

Method Summary

Modifier and Type	Method	Description
protected void	receive(String payload)

Methods inherited from class Object

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

Constructor Details

RepeatedSubscriber

public RepeatedSubscriber()

Method Details

receive

protected void receive(String payload)