package fr.kosmos.pulsar.multitenant.testapp;

import static fr.kosmos.pulsar.multitenant.testapp.Constants.FORMATTER;

import java.time.ZonedDateTime;

import org.apache.pulsar.client.api.MessageId;
import org.apache.pulsar.client.api.Producer;
import org.apache.pulsar.client.api.PulsarClient;
import org.apache.pulsar.client.api.PulsarClientException;
import org.apache.pulsar.client.api.Schema;

public class SimpleProducer {

	public static void main(String[] args) throws PulsarClientException {
		PulsarClient pulsarClient = Constants.initPulsarClient();
		Producer<String> producer = pulsarClient.newProducer(Schema.STRING)
		                                        .topic("persistent://public/testns/test")
		                                        .create();
		System.out.println(">> pulsar producer created");
		String formattedDate = ZonedDateTime.now().format(FORMATTER);
		String message = String.format("Message de %s", formattedDate);
		MessageId msgId = producer.newMessage().value(message).send();
		System.out.println("deliver msg " + msgId + ", value:"+ message);
		producer.close();
		pulsarClient.close();
	}
}