Changeset 0d98102c9b5f193cad2d082eb882d85193da1734

Show
Ignore:
Timestamp:
05/14/12 16:21:19 (3 years ago)
Author:
Theo Schlossnagle <jesus@omniti.com>
git-committer:
Theo Schlossnagle <jesus@omniti.com> 1337012479 -0400
git-parent:

[a6f716d7d5a83b908b2739db317651b19855f337], [372c4a88d11fa6e49da286bb27b6040c45b0b1bb]

git-author:
Phil Maddox <pmaddox@circonus.com> 1337012479 -0400
Message:

Allow observation of each individual component in a bundle.

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved
  • src/java/com/omniti/reconnoiter/EventHandler.java

    r4344abb r372c4a8  
    7070  public void processMessage(StratconMessage m) throws Exception { 
    7171    for ( MessageHandler mh : alternates ) 
    72       if(mh.observe(m) == true) 
     72      if(mh.observe(m, null) == true) 
    7373        return; 
    7474    long start = System.nanoTime(); 
     
    9595    processMessage(messages); 
    9696  } 
     97  public boolean stopProcessing(StratconMessage m, String source) { 
     98    for ( MessageHandler mh : alternates ) 
     99      if(mh.observe(m, source) == true) 
     100        return true; 
     101    return false; 
     102  } 
    97103} 
  • src/java/com/omniti/reconnoiter/MessageHandler.java

    rcb6dac3 r789d4fb  
    44 
    55public interface MessageHandler { 
    6   public boolean observe(StratconMessage m); 
     6  public boolean observe(StratconMessage m, String source); 
    77} 
  • src/java/com/omniti/reconnoiter/event/NoitBundlev2.java

    r623c1ee rf7b7c1e  
    104104  public void handle(EventHandler eh) { 
    105105    for(NoitEvent e : items) { 
    106       e.handle(eh); 
     106      if (eh.stopProcessing(e, getPrefix()) == false) 
     107        e.handle(eh); 
    107108    } 
    108109  }