receiveDefinition.mustache 369 Bytes
Newer Older
René Schöne's avatar
René Schöne committed
1
  public void {{parentTypeName}}.{{connectMethod}}(String topic) {
René Schöne's avatar
René Schöne committed
2
    {{handlerAttribute}}().newConnection(topic, message -> {
René Schöne's avatar
René Schöne committed
3
4
      {{> mappingApplication}}
      {{#loggingEnabledForReads}}
René Schöne's avatar
René Schöne committed
5
      System.out.println("[Receive] " + topic + " -> {{tokenName}} = " + {{lastResult}});
René Schöne's avatar
René Schöne committed
6
      {{/loggingEnabledForReads}}
7
      set{{tokenName}}({{lastResult}});
René Schöne's avatar
René Schöne committed
8
9
    });
  }