subhrendus / rocksteady Goto Github PK

On Ubuntu systems the rpm command fails (Obviously) and the build does not 
succeed. Probably need to make the build platform agnostic?


INFO] [rpm:rpm {execution: default}]
[WARNING] /bin/sh: rpm: not found
[INFO] ------------------------------------------------------------------------
[ERROR] BUILD ERROR
[INFO] ------------------------------------------------------------------------
[INFO] RPM query for default vendor returned: '127' executing '/bin/sh -c rpm 
-E '%{_host_vendor}''
[INFO] ------------------------------------------------------------------------
[INFO] For more information, run Maven with the -e switch
[INFO] ------------------------------------------------------------------------

What steps will reproduce the problem?
1.run rocksteady
2.rabbitmqctl list_exchanges name  durable auto_delete

What is the expected output? What do you see instead?
in classes/META-INF/rocksteady.properties
rabbitDurable=true
rabbitAutoDelete=false
rabbitExchangeType=topic
while 
rabbitmqctl list_exchanges  durable auto_delete
always return  false false


What version of the product are you using? On what operating system?

1.0.0,debian 6,
Please provide any additional information below.

mqChannel.exchangeDeclare(rabbitExchange, rabbitExchangeType, false, 
rabbitDurable, rabbitAutoDelete, null);

please read
http://www.rabbitmq.com/javadoc/com/rabbitmq/client/Channel.html#exchangeDeclare
(java.lang.String, java.lang.String, boolean, boolean, boolean, java.util.Map)




Index: src/main/java/com/admob/rocksteady/router/MessageManager.java
===================================================================
--- src/main/java/com/admob/rocksteady/router/MessageManager.java       
(revision 118)
+++ src/main/java/com/admob/rocksteady/router/MessageManager.java       
(working copy)
@@ -169,7 +169,7 @@
       mqChannel = mqConnection.createChannel();
       // Now we have connection
       //mqChannel.exchangeDelete(rabbitExchange);
-      mqChannel.exchangeDeclare(rabbitExchange, rabbitExchangeType, false, 
rabbitDurable, rabbitAutoDelete, null);
+      mqChannel.exchangeDeclare(rabbitExchange, rabbitExchangeType, 
rabbitDurable, rabbitAutoDelete, false, null);

       // Add a random string to queue name so each instance of rocksteady will
       // have its own queue

It would be great to have a testing framework for epl statements. Sample data 
and then what listeners are expected to fire. Any thoughts on this?

Please change project license to GPLv2 - if it uses Esper APIs it couldn't be 
Apache licensed

Patch attached. Now running "mvn package" will generate an RPM under 
target/rpm. "mvn rpm:rpm" rebuilds the RPM only.

Spring dependencies are not correctly configured in pom

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>org.springframework.core</artifactId>
    <version>${spring.version}</version>
</dependency>

Shoud be (notice: artifactId)

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-core</artifactId>
    <version>${spring.version}</version>
</dependency>

I'd like to send just one set of stats to an AMQP exchange for consumption by 
both rocksteady and graphite -- but they seem to expect slightly different 
formats.

Rocksteady expects a message to have: "metric_name value timestamp"

graphite expects the message to have metric_name as the routing key, and the 
message just: "value timestamp"

There could be a config option to use the routing key as metric name, and only 
expect "value timestamp" in the payload.

Do you have example rules/esper plugins to apply the holt-winters prediction 
algorithm in an EPL statement?