in chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/NATSResourceAdapter.java [82:94]
public void start(BootstrapContext bootstrapContext) throws ResourceAdapterInternalException {
workManager = bootstrapContext.getWorkManager();
try {
cf = new
StreamingConnectionFactory(new Options.Builder().natsUrl(baseAddress)
.clusterId(clusterId).clientId(clientId).build());
connection = cf.createConnection();
} catch (Throwable t) {
LOGGER.log(Level.SEVERE, "Error starting connection to NATS server", t);
}
}