Add push-based channels and improve broker notifications
Change-Id: Ie3c7cae0f015d6bc01dd912499565bb12c15abc3
diff --git a/asterix-bad/src/main/resources/lang-extension/lang.txt b/asterix-bad/src/main/resources/lang-extension/lang.txt
index 02aba78..2d7ba75 100644
--- a/asterix-bad/src/main/resources/lang-extension/lang.txt
+++ b/asterix-bad/src/main/resources/lang-extension/lang.txt
@@ -101,15 +101,18 @@
CreateChannelStatement ccs = null;
String fqFunctionName = null;
Expression period = null;
+ boolean push = false;
}
{
(
- "repetitive" "channel" nameComponents = QualifiedName()
+ "repetitive"
+ ( "push" { push = true; } )?
+ "channel" nameComponents = QualifiedName()
<USING> appliedFunction = FunctionSignature()
"period" period = FunctionCallExpr()
{
ccs = new CreateChannelStatement(nameComponents.first,
- nameComponents.second, appliedFunction, period);
+ nameComponents.second, appliedFunction, period, push);
}
)
{