Changeset 0f5161443456635a93cac5b1a773512418ebd578
- Timestamp:
- 05/23/09 04:16:49
(9 years ago)
- Author:
- Theo Schlossnagle <jesus@omniti.com>
- git-committer:
- Theo Schlossnagle <jesus@omniti.com> 1243052209 +0000
- git-parent:
[8fd52de5ff1b33c4e303bd9c73fcd27898353757]
- git-author:
- Theo Schlossnagle <jesus@omniti.com> 1243052209 +0000
- Message:
make the NoitMetricNumeric? event a Java class instead on XMLDOM-based event. This gives us control. fixes #135
-
Files:
-
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
r24eac7c |
r0f51614 |
|
26 | 26 | com/omniti/reconnoiter/AMQOutput.java \ |
---|
27 | 27 | com/omniti/reconnoiter/event/NoitEvent.java \ |
---|
| 28 | com/omniti/reconnoiter/event/NoitMetricNumeric.java \ |
---|
28 | 29 | com/omniti/reconnoiter/event/StratconQuery.java \ |
---|
29 | 30 | com/omniti/reconnoiter/event/StratconQueryStop.java \ |
---|
… | … | |
32 | 33 | |
---|
33 | 34 | SUPPORT=lib/activemq-all-5.2.0.jar lib/antlr-runtime-3.1.1.jar lib/esper-3.0.0.jar \ |
---|
34 | | lib/log4j-1.2.15.jar lib/spring-beans-2.5.5.jar lib/spring-context-2.5.5.jar |
---|
| 35 | lib/log4j-1.2.15.jar lib/spring-beans-2.5.5.jar lib/spring-context-2.5.5.jar \ |
---|
| 36 | lib/cglib-nodep-2.2.jar |
---|
35 | 37 | |
---|
36 | 38 | all: reconnoiter.jar |
---|
r546c63f |
r0f51614 |
|
11 | 11 | import com.omniti.reconnoiter.AMQBrokerSingleton; |
---|
12 | 12 | import com.omniti.reconnoiter.StratconMessage; |
---|
13 | | import com.omniti.reconnoiter.event.StratconQuery; |
---|
14 | | import com.omniti.reconnoiter.event.StratconQueryStop; |
---|
15 | | import com.omniti.reconnoiter.event.NoitEvent; |
---|
| 13 | import com.omniti.reconnoiter.event.*; |
---|
16 | 14 | import java.lang.System; |
---|
17 | 15 | import java.lang.Runnable; |
---|
… | … | |
99 | 97 | epService.getEPRuntime().sendEvent(((NoitEvent) m).getDocument()); |
---|
100 | 98 | } |
---|
| 99 | else if(m instanceof NoitMetricNumeric) { |
---|
| 100 | epService.getEPRuntime().sendEvent((NoitMetricNumeric) m); |
---|
| 101 | } |
---|
101 | 102 | } catch(Exception ie) { |
---|
102 | 103 | System.err.println(ie); |
---|
r546c63f |
r0f51614 |
|
14 | 14 | import com.omniti.reconnoiter.AMQListener; |
---|
15 | 15 | import com.omniti.reconnoiter.event.NoitEvent; |
---|
| 16 | import com.omniti.reconnoiter.event.NoitMetricNumeric; |
---|
16 | 17 | import com.espertech.esper.client.*; |
---|
17 | 18 | import com.espertech.esper.client.soda.*; |
---|
… | … | |
24 | 25 | |
---|
25 | 26 | Configuration config = new Configuration(); |
---|
| 27 | config.addEventTypeAutoName("com.omniti.reconnoiter.event"); |
---|
26 | 28 | EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider(config); |
---|
27 | | config.addEventTypeAutoName("com.omniti.reconnoiter.event"); |
---|
28 | 29 | NoitEvent.registerTypes(epService); |
---|
29 | 30 | |
---|
r546c63f |
r0f51614 |
|
17 | 17 | import org.w3c.dom.Document; |
---|
18 | 18 | import org.w3c.dom.Element; |
---|
| 19 | import org.w3c.dom.Text; |
---|
19 | 20 | import org.w3c.dom.Node; |
---|
| 21 | import org.w3c.dom.NodeList; |
---|
20 | 22 | |
---|
21 | 23 | import com.omniti.reconnoiter.event.*; |
---|
… | … | |
47 | 49 | // We have events |
---|
48 | 50 | if(tag.equals("NoitStatus") || |
---|
49 | | tag.equals("NoitMetricNumeric") || |
---|
50 | 51 | tag.equals("NoitMetricText") || |
---|
51 | 52 | tag.equals("NoitCheck")) |
---|
52 | 53 | return new NoitEvent(document); |
---|
| 54 | else if(tag.equals("NoitMetricNumeric")) { |
---|
| 55 | // Numerics have a value that can be in scientific notation. |
---|
| 56 | // This document gets passed places that do Xpath 1.0 queries |
---|
| 57 | // which don't understand scientific notation... we have to hack it. |
---|
| 58 | return new NoitMetricNumeric(document); |
---|
| 59 | } |
---|
53 | 60 | // and requests |
---|
54 | 61 | else if(tag.equals("StratconQuery")) |
---|
… | … | |
58 | 65 | } |
---|
59 | 66 | catch(Exception e) { |
---|
| 67 | System.err.println("makeMessage: " + e); |
---|
60 | 68 | } |
---|
61 | 69 | return null; |
---|
r546c63f |
r0f51614 |
|
47 | 47 | epService.getEPAdministrator().getConfiguration() |
---|
48 | 48 | .addEventType("NoitStatus", cfg); |
---|
49 | | |
---|
| 49 | /* |
---|
50 | 50 | cfg = new ConfigurationEventTypeXMLDOM(); |
---|
51 | 51 | cfg.addXPathProperty("uuid", "/NoitMetricNumeric/id", XPathConstants.STRING); |
---|
… | … | |
56 | 56 | epService.getEPAdministrator().getConfiguration() |
---|
57 | 57 | .addEventType("NoitMetricNumeric", cfg); |
---|
58 | | |
---|
| 58 | */ |
---|
59 | 59 | cfg = new ConfigurationEventTypeXMLDOM(); |
---|
60 | 60 | cfg.addXPathProperty("uuid", "/NoitMetricText/id", XPathConstants.STRING); |
---|
ra907717 |
r0f51614 |
|
4 | 4 | JARS="reconnoiter.jar activemq-all-5.2.0.jar antlr-runtime-3.1.1.jar \ |
---|
5 | 5 | esper-3.0.0.jar log4j-1.2.15.jar \ |
---|
6 | | spring-beans-2.5.5.jar spring-context-2.5.5.jar" |
---|
| 6 | spring-beans-2.5.5.jar spring-context-2.5.5.jar \ |
---|
| 7 | cglib-nodep-2.2.jar" |
---|
7 | 8 | |
---|
8 | 9 | DIRS=". lib @prefix@/java" |
---|