Changeset 789d4fb4503e5fe8076ac65ee389bd2185523d37

Show
Ignore:
Timestamp:
05/14/12 15:22:48 (1 year ago)
Author:
Philip Maddox <pmaddox@circonus.com>
git-committer:
Philip Maddox <pmaddox@circonus.com> 1337008968 -0400
git-parent:

[345f8ea3641b557edd023cc6833271d59bc40d45]

git-author:
Philip Maddox <pmaddox@circonus.com> 1337008968 -0400
Message:

Added source parameter to observe

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

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

    r345f8ea r789d4fb  
    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(); 
    …… 
    9797  public boolean stopProcessing(StratconMessage m, String source) { 
    9898    for ( MessageHandler mh : alternates ) 
    99       if(mh.observe(m) == false) 
     99      if(mh.observe(m, source) == false) 
    100100        return false; 
    101101    return true; 

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

    r345f8ea r789d4fb  
    44 
    55public interface MessageHandler { 
    6   public boolean observe(StratconMessage m); 
     6  public boolean observe(StratconMessage m, String source); 
    77}