CF NATS Example

gistfile1.java

Nats nats = new NatsConnector().addHost("nats://localhost").connect();
CfNats cfNats = new DefaultCfNats(nats);
cfNats.subscribe(ComponentDiscover.class, new PublicationHandler<ComponentDiscover, ComponentAnnounce>() {
	@Override
	public void onMessage(Publication<ComponentDiscover, ComponentAnnounce> publication) {
		publication.reply(new ComponentAnnounce(...));
	}
});