TransportProperty workerGroup = new TransportProperty();
int workerGroupSize = Runtime.getRuntime().availableProcessors() * 2;
workerGroup.setName(Constants.SERVER_BOOTSTRAP_WORKER_GROUP_SIZE);
workerGroup.setValue(workerGroupSize);
transportProperties.add(transportProperty);
<BUG>transportProperties.add(workerGroup);
for (ListenerConfiguration listenerConfiguration : listenerConfigurations) {</BUG>
HTTPTransportListener listener =
new HTTPTransportListener(transportProperties, Collections.singleton(listenerConfiguration));
<BUG>transportManager.registerTransport(listener);
httpTransportContextHolder
.setMessageProcessor(new MSF4JMessageProcessor(listenerConfiguration.getId(), msRegistry));</BUG>
}

TransportProperty workerGroup = new TransportProperty();
int workerGroupSize = Runtime.getRuntime().availableProcessors() * 2;
workerGroup.setName(Constants.SERVER_BOOTSTRAP_WORKER_GROUP_SIZE);
workerGroup.setValue(workerGroupSize);
transportProperties.add(transportProperty);
transportProperties.add(workerGroup);
httpTransportContextHolder.setMessageProcessor(new MSF4JMessageProcessor());
for (int port : ports) {
ListenerConfiguration listenerConfiguration = new ListenerConfiguration("netty-" + port, "0.0.0.0", port);
HTTPTransportListener listener =
new HTTPTransportListener(transportProperties, Collections.singleton(listenerConfiguration));
transportManager.registerTransport(listener);
DataHolder.getInstance().getMicroservicesRegistries().put("netty-" + port, msRegistry);
