Browse Source

Add logging

master
Jonathan Christison 5 years ago
parent
commit
d9a0ba8896
  1. 3
      quarkus-kafaka-homework/kafka-producer/src/main/java/me/jochrist/kafka/MessageProducer.java

3
quarkus-kafaka-homework/kafka-producer/src/main/java/me/jochrist/kafka/MessageProducer.java

@ -9,12 +9,15 @@ import java.sql.Timestamp;
import java.util.Date;
import java.util.Random;
import java.util.concurrent.TimeUnit;
import org.jboss.logging.Logger;
@ApplicationScoped
public class MessageProducer {
private static final Logger LOG = Logger.getLogger(MessageProducer.class);
@Inject @Channel("user-message") Emitter<String> messageEmitter;
public void sendMessage(String message)
{
LOG.debug("%h emmitting message:\"" + message + "\"");
messageEmitter.send(message);
}
}

Loading…
Cancel
Save