ragconnect.mustache

{{#usesMqtt}}{{> mqtt}}{{/usesMqtt}}
{{> handler}}
aspect RagConnect {
  {{#TokenReceiveDefinitions}}
  {{> receiveDefinition}}
  {{/TokenReceiveDefinitions}}

  {{#TokenSendDefinitions}}
  {{> sendDefinition}}
  {{/TokenSendDefinitions}}

  {{#TypeReceiveDefinitions}}
  {{> receiveDefinition}}
  {{/TypeReceiveDefinitions}}

  {{#TypeSendDefinitions}}
  {{> sendDefinition}}
  {{/TypeSendDefinitions}}

  class RagConnectRejectMappingException extends RuntimeException {}
  private static void ASTNode.reject() {
    throw new RagConnectRejectMappingException();
  }

  {{#MappingDefinitions}}
  {{#isUsed}}
  {{> mappingDefinition}}
  {{/isUsed}}
  {{/MappingDefinitions}}

  {{#DependencyDefinitions}}
  {{> dependencyDefinition}}
  {{/DependencyDefinitions}}

  {{#tokenComponentsThatNeedProxy}}
  {{> tokenComponent}}
  {{/tokenComponentsThatNeedProxy}}

  {{> ListAspect}}

  public void {{rootNodeName}}.ragconnectCheckIncremental() {
  {{#incrementalOptionActive}}
    // check if --tracing is active
    trace().getReceiver();
    // check if tracing of INC_FLUSH_ATTR is possible, i.e., if --tracing=flush
    ASTState.Trace.Event checkTracing = ASTState.Trace.Event.INC_FLUSH_ATTR;
    // check if --rewrite is active
    mayHaveRewrite();
    // check if --incremental is active
    Object checkIncremental = inc_throwAway_visited;
  {{/incrementalOptionActive}}
  }
}

{{#incrementalOptionActive}}
aspect RagConnectObserver {

  class RagConnectObserver implements ASTState.Trace.Receiver {

    class RagConnectObserverEntry {
      final RagConnectToken connectToken;
      final ASTNode node;
      final String attributeString;
      final Runnable attributeCall;

      RagConnectObserverEntry(RagConnectToken connectToken, ASTNode node, String attributeString, Runnable attributeCall) {
        this.connectToken = connectToken;
        this.node = node;
        this.attributeString = attributeString;
        this.attributeCall = attributeCall;