package fr.kosmos.pulsar.multitenant.testapp;

import java.time.format.DateTimeFormatter;

import org.apache.pulsar.client.api.PulsarClient;
import org.apache.pulsar.client.api.PulsarClientException;

public class Constants {

	public static final DateTimeFormatter FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mm:ss.SSSX");


	private static final String SERVICE_URL = "pulsar://localhost:6650";

	static PulsarClient initPulsarClient() throws PulsarClientException {
		PulsarClient pulsarClient = PulsarClient.builder()
		                                        .serviceUrl(SERVICE_URL).build();
		System.out.println(">> pulsar client created");
		return pulsarClient;
	}
}