private void fireEvent()

in src/main/java/org/apache/fineract/cn/command/internal/CommandBus.java [221:239]

• 19 lines of code
• 3 McCabe index (conditional complexity)

  private <T> void fireEvent(final T eventPayload, final EventEmitter eventEmitter) {
    if (eventPayload != null) {
      this.jmsTemplate.convertAndSend(
          this.gson.toJson(eventPayload),
          message -> {
            if (TenantContextHolder.identifier().isPresent()) {
              message.setStringProperty(
                  TenantHeaderFilter.TENANT_HEADER,
                  TenantContextHolder.checkedGetIdentifier());
            }
            message.setStringProperty(
                eventEmitter.selectorName(),
                eventEmitter.selectorValue()
            );
            return message;
          }
      );
    }
  }