in pekko-connectors-sample-sqs-java/src/main/java/alpakka/sample/sqssample/EnrichActor.java [42:49]
public Receive<Enrich> createReceive() {
return newReceiveBuilder()
.onMessage(Enrich.class, message -> {
getContext().getLog().debug("actor received '{}'", message);
message.replyTo.tell(new Enriched(message.toString()));
return this;
}).build();
}