Sending alerts from applications

The EmailAdapter properties are:

The following would create a property set smtpprop which could then be specified as the value for smtpPropertiesName:

CREATE PROPERTYSET smtpprop (
  SMTPUSER:'xx@example.com',
  SmtpPassword:'secret', 
  smtpurl:'smtp.example.com', 
  threadCount:"5", 
  senderEmail:"alertsender@example.com" );

To change properties in an existing property set, see ALTER PROPERTYSET.

The SlackAlertAdapter properties are:

See Configure Slack to receive alerts from Striim for more about these properties.

The TeamsAlertAdapter properties are:

See Configure Teams to receive alerts from Striim for more about these properties.

The input stream for a subscription must use the AlertEvent type. Its fields are:

The following sample code (based on PosApp) generates both types of alerts:

CREATE STREAM AlertStream OF Global.AlertEvent;

CREATE CQ GenerateAlerts
INSERT INTO AlertStream
SELECT n.CompanyName,
  m.MerchantId,
  CASE
    WHEN m.Status = 'OK' THEN 'info'
    ELSE 'warning' END,
  CASE
    WHEN m.Status = 'OK' THEN 'cancel'
    ELSE 'raise' END,
  CASE
    WHEN m.Status = 'OK'
      THEN 'Merchant ' + n.companyName + ' count of ' + m.count +
        ' is back between ' + ROUND_DOUBLE(m.lowerLimit,0) + ' and ' + 
        ROUND_DOUBLE(m.upperLimit,0)
    WHEN m.Status = 'TOOHIGH'
      THEN 'Merchant ' + n.companyName + ' count of ' + m.count +
        ' is above upper limit of ' + ROUND_DOUBLE(m.upperLimit,0)
    WHEN m.Status = 'TOOLOW'
      THEN 'Merchant ' + n.companyName + ' count of ' + m.count +
        ' is below lower limit of ' + ROUND_DOUBLE(m.lowerLimit,0)
    ELSE ''
    END
FROM MerchantTxRateWithStatusStream m, NameLookup n
WHERE m.merchantId = n.merchantId;

CREATE SUBSCRIPTION PosAppEmailAlert
USING EmailAdapter (
  SMTPUSER:'sender@example.com',
  SMTPPASSWORD:'********', 
  smtpurl:'smtp.gmail.com',
  starttls_enable:'true',
  subject:"test subject",
  emailList:"recipient@example.com,recipient2.example.com",
  senderEmail:"alertsender@example.com" 
)
INPUT FROM AlertStream;

CREATE SUBSCRIPTION PosAppWebAlert 
USING WebAlertAdapter( ) 
INPUT FROM AlertStream;

When a merchant's status changes to TOOLOW or TOOHIGH, Striim will send an alert such as, "WARNING - alert from Striim - POSUnusualActivity - 2013-12-20 13:55:14 - Merchant Urban Outfitters Inc. count of 12012 is below lower limit of 13304.347826086958." The "raise" value for the flag field instructs the subscription not to send another alert until the status returns to OK.

When sending alerts with the EmailAdapter, you can populate the subject, sender address, and recipient addresses with values from the fields of the subscription's input stream.

To do this, first create a custom alert stream with the extra fields you want to use. The first five fields must be identical to Global.AlertEvent. To those, you may add fields containing the subjects, sender addresses, and recipient addresses.

CREATE TYPE CustomEmailAlert (   
   name String,
   keyVal String,
   severity String,
   flag String,
   message String,
   emailsubject String,
   senderEmail String,
   receipientList String 
);
CREATE STREAM CustomAlertStream OF CustomEmailAlert;

Reference the subject, sender, and recipient fields in the EmailAdapter properties as follows:

CREATE SUBSCRIPTION alertSubscription USING EmailAdapter (
  smtpurl:'localhost:25',
  subject: '%emailsubject%',
  senderEmail:,
  emailList: 
)
INPUT FROM MyAlertStream;
CREATE SUBSCRIPTION PosAppCustomEmailAlert
USING EmailAdapter (
  SMTPUSER:'sender@example.com',
  SMTPPASSWORD:'********', 
  smtpurl:'smtp.gmail.com',
  starttls_enable:'true',
  subject:'%emailsubject%',
  emailList:'%receipientlist%',
  senderEmail:'%senderEmaiId%' 
)
INPUT FROM AlertStream;

You do not need to use all three. For example, you could populate only emailList with field values:

  subject:"test subject",
  emailList:'%receipientlist%',
  senderEmail:"alertsender@example.com"

The values in the recipientlist field may include multiple email addresses separated by commas (no spaces).