com.lightbend.lagom.javadsl.testkit

Class ProducerStub<T>

Object

com.lightbend.lagom.javadsl.testkit.ProducerStub<T>

public final class ProducerStub<T>
extends Object

Stubs the production end of a Topic so that test writers can mock message production from upstream services into topics consumed by services under test.

Constructor Summary

Constructors

Constructor and Description
ProducerStub(String topicName, akka.actor.ActorSystem actorSystem, akka.stream.Materializer materializer)

Method Summary

Modifier and Type	Method and Description
void	send(Message<T> message) Send a message wrapped with metadata to the topic.
void	send(T message) Sends the message via the Topic where this ProducerStub is connected to.
Topic<T>	topic() Returns the Topic where this ProducerStub is connected to.

Methods inherited from class Object

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

Constructor Detail

ProducerStub

public ProducerStub(String topicName,
                    akka.actor.ActorSystem actorSystem,
                    akka.stream.Materializer materializer)

Method Detail

send

public void send(T message)

Sends the message via the Topic where this ProducerStub is connected to.

Parameters:

message -

send

public void send(Message<T> message)

Send a message wrapped with metadata to the topic.

Parameters:

message - The message to send.

topic

public Topic<T> topic()

Returns the Topic where this ProducerStub is connected to.