summary |
shortlog |
log |
commit | commitdiff |
tree
raw |
patch |
inline | side by side (from parent 1:
194a4fa)
--
streamlined the naming of attributes and parameters
@Bean
public QueryStreamProcessor streamProcessor(
ServerProperties serverProperties,
@Bean
public QueryStreamProcessor streamProcessor(
ServerProperties serverProperties,
- QueryApplicationProperties properties,
+ QueryApplicationProperties applicationProperties,
ObjectMapper mapper,
ConfigurableApplicationContext context) throws IOException
{
String host;
if (serverProperties.getAddress() == null)
{
ObjectMapper mapper,
ConfigurableApplicationContext context) throws IOException
{
String host;
if (serverProperties.getAddress() == null)
{
- HostInfo bootstrapServer = HostInfo.buildFromEndpoint(properties.getBootstrapServer());
+ HostInfo bootstrapServer = HostInfo.buildFromEndpoint(applicationProperties.getBootstrapServer());
Socket socket = new Socket();
socket.connect(new InetSocketAddress(bootstrapServer.host(), bootstrapServer.port()));
host = socket.getLocalAddress().getHostAddress();
Socket socket = new Socket();
socket.connect(new InetSocketAddress(bootstrapServer.host(), bootstrapServer.port()));
host = socket.getLocalAddress().getHostAddress();
Integer port = serverProperties.getPort() == null ? 8080 : serverProperties.getPort();
return new QueryStreamProcessor(
Integer port = serverProperties.getPort() == null ? 8080 : serverProperties.getPort();
return new QueryStreamProcessor(
- properties.getApplicationId(),
+ applicationProperties.getApplicationId(),
new HostInfo(host, port),
new HostInfo(host, port),
- properties.getBootstrapServer(),
- properties.getUsersInputTopic(),
- properties.getRankingInputTopic(),
+ applicationProperties.getBootstrapServer(),
+ applicationProperties.getUsersInputTopic(),
+ applicationProperties.getRankingInputTopic(),