Changeset 960593bbc3d124660d33345738153237349d5310

Show
Ignore:
Timestamp:
05/22/12 22:07:25 (1 year ago)
Author:
Theo Schlossnagle <jesus@omniti.com>
git-committer:
Theo Schlossnagle <jesus@omniti.com> 1337724445 -0400
git-parent:

[2534eec9709c2c836a34394e9854dda289f8a208]

git-author:
Theo Schlossnagle <jesus@omniti.com> 1337724445 -0400
Message:

make the StratconMessage? implementation use the interface where not tied to esper

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • src/java/com/omniti/reconnoiter/StratconMessage.java

    r24c830d r960593b  
    1414import java.lang.reflect.Method; 
    1515import java.lang.reflect.InvocationTargetException; 
     16import com.omniti.reconnoiter.IEventHandler; 
    1617import com.omniti.reconnoiter.event.*; 
    1718 
    …… 
    6970  public int numparts() { return 0; } 
    7071 
    71   public abstract void handle(EventHandler eh); 
     72  public abstract void handle(IEventHandler eh); 
    7273 
    7374  public StratconMessage() {} 

  • src/java/com/omniti/reconnoiter/event/NoitBundlev2.java

    rf7b7c1e r960593b  
    1010 
    1111import java.util.LinkedList; 
    12 import com.omniti.reconnoiter.EventHandler; 
     12import com.omniti.reconnoiter.IEventHandler; 
    1313import com.omniti.reconnoiter.event.NoitEvent; 
    1414import com.omniti.reconnoiter.event.NoitStatus; 
    …… 
    102102 
    103103  public int numparts() { return 9; } 
    104   public void handle(EventHandler eh) { 
     104  public void handle(IEventHandler eh) { 
    105105    for(NoitEvent e : items) { 
    106106      if (eh.stopProcessing(e, getPrefix()) == false) 

  • src/java/com/omniti/reconnoiter/event/NoitEvent.java

    r8c720f9 r960593b  
    99package com.omniti.reconnoiter.event; 
    1010 
    11 import com.omniti.reconnoiter.EventHandler; 
     11import com.omniti.reconnoiter.IEventHandler; 
    1212import com.omniti.reconnoiter.StratconMessage; 
    1313 
    …… 
    3333    return parts; 
    3434  } 
    35   public void handle(EventHandler eh) { 
    36     eh.getService().getEPRuntime().sendEvent(this); 
     35  public void handle(IEventHandler eh) { 
     36    eh.sendEvent(this); 
    3737  } 
    3838} 

  • src/java/com/omniti/reconnoiter/event/NoitMetric.java

    r2534eec r960593b  
    99package com.omniti.reconnoiter.event; 
    1010 
    11 import com.omniti.reconnoiter.EventHandler; 
     11import com.omniti.reconnoiter.IEventHandler; 
    1212import com.omniti.reconnoiter.StratconMessage; 
    1313import com.omniti.reconnoiter.event.NoitMetricNumeric; 
    …… 
    3434    } 
    3535  } 
    36   public void handle(EventHandler eh) { 
     36  public void handle(IEventHandler eh) { 
    3737    long start = System.nanoTime(); 
    3838    if(nmn != null) eh.sendEvent(nmn); 

  • src/java/com/omniti/reconnoiter/event/StratconQuery.java

    r2534eec r960593b  
    8686  } 
    8787 
    88   public void handle(EventHandler eh) { 
     88  public void handle(IEventHandler ieh) { 
     89    EventHandler eh = (EventHandler)ieh; 
    8990    eh.deregisterQuery(getUUID()); 
    9091 

  • src/java/com/omniti/reconnoiter/event/StratconQueryStop.java

    rd483232 r960593b  
    1212import com.omniti.reconnoiter.StratconMessage; 
    1313import com.omniti.reconnoiter.EventHandler; 
     14import com.omniti.reconnoiter.IEventHandler; 
    1415 
    1516public class StratconQueryStop extends StratconQueryBase { 
    …… 
    3132  public int numparts() { return 3; } 
    3233 
    33   public void handle(EventHandler eh) { 
     34  public void handle(IEventHandler ieh) { 
     35    EventHandler eh = (EventHandler)ieh; 
    3436    eh.deregisterQuery(getUUID()); 
    3537  } 

  • src/java/com/omniti/reconnoiter/event/StratconStatement.java

    rd483232 r960593b  
    1111import com.omniti.reconnoiter.event.StratconQueryBase; 
    1212import com.omniti.reconnoiter.EventHandler; 
     13import com.omniti.reconnoiter.IEventHandler; 
    1314import com.espertech.esper.client.EPStatement; 
    1415import com.espertech.esper.client.UpdateListener; 
    …… 
    3637  public int numparts() { return 4; } 
    3738 
    38   public void handle(EventHandler eh) { 
     39  public void handle(IEventHandler ieh) { 
     40    EventHandler eh = (EventHandler)ieh; 
    3941    eh.deregisterQuery(getUUID()); 
    4042    EPStatement statement = eh.getService().getEPAdministrator().createEPL(getExpression());