Event Gateways - Settings

// Get gateway statistics
helper = getGatewayHelper();

// List all gateways and their states
gateways = helper.getGateways();
for (gateway in gateways) {
  state = helper.getGatewayState(gateway);
  writeOutput("#gateway#: #state#<br>");
}

// Get queue information
queueInfo = helper.getQueueInfo();
writeDump(queueInfo);

// Monitor specific gateway
gatewayStats = helper.getGatewayStatistics("SMS_Notifications");
writeOutput("Queue depth: #gatewayStats.queueDepth#<br>");
writeOutput("Messages processed: #gatewayStats.messagesProcessed#<br>");
writeOutput("Messages failed: #gatewayStats.messagesFailed#<br>");

// Check gateway status
if (helper.getGatewayState("SMS_Notifications") != "RUNNING") {
  // Gateway is down - send alert
  writeLog(
    file = "gateway-monitor",
    type = "error",
    text = "SMS_Notifications gateway is not running"
  );

  // Attempt restart
  helper.startGateway("SMS_Notifications");
}

// Scheduled task to monitor gateway health
// Run every 5 minutes

component {

  public void function run() {
    var helper = getGatewayHelper();
    var gateways = helper.getGateways();
    var issues = [];

    // Check each gateway
    for (var gateway in gateways) {
      var state = helper.getGatewayState(gateway);

      if (state != "RUNNING") {
        arrayAppend(issues, {
          gateway: gateway,
          issue: "Not running",
          state: state
        });

        // Attempt automatic restart
        try {
          helper.startGateway(gateway);
          writeLog(
            file = "gateway-monitor",
            text = "Auto-restarted gateway: #gateway#"
          );
        } catch (any e) {
          writeLog(
            file = "gateway-monitor",
            type = "error",
            text = "Failed to restart #gateway#: #e.message#"
          );
        }
      }

      // Check queue depth
      var stats = helper.getGatewayStatistics(gateway);
      if (stats.queueDepth > 500) {
        arrayAppend(issues, {
          gateway: gateway,
          issue: "High queue depth",
          queueDepth: stats.queueDepth
        });
      }
    }

    // Send alerts if issues found
    if (arrayLen(issues)) {
      sendGatewayAlert(issues);
    }
  }

  private void function sendGatewayAlert(required array issues) {
    var message = "Gateway Issues Detected:#chr(10)#";

    for (var issue in arguments.issues) {
      message &= "- #issue.gateway#: #issue.issue#";
      if (structKeyExists(issue, "queueDepth")) {
        message &= " (depth: #issue.queueDepth#)";
      }
      message &= chr(10);
    }

    // Send email alert
    cfmail(
      to = "ops@example.com",
      from = "cfserver@example.com",
      subject = "ColdFusion Gateway Alert",
      type = "text"
    ) {
      writeOutput(message);
    }
  }

}