001 package com.hammurapi.eventbus.tests;
002
003 import java.util.concurrent.atomic.AtomicReference;
004
005 import com.hammurapi.common.Condition;
006 import com.hammurapi.eventbus.Handler;
007
008 public class HelperHandler {
009
010 private int worldCounter;
011 private boolean worldOk;
012
013 private int emCounter;
014 private boolean emOk;
015
016 public int getWorldCounter() {
017 return worldCounter;
018 }
019
020 public boolean isWorldOk() {
021 return worldOk;
022 }
023
024 public int getEmCounter() {
025 return emCounter;
026 }
027
028 public boolean isEmOk() {
029 return emOk;
030 }
031
032 @Handler("java(str)://str.get().equals(\"World\")")
033 public void handleWorld(AtomicReference<String> strRef) {
034 ++worldCounter;
035 worldOk = "World".equals(strRef.get());
036 }
037
038 @Handler //("\"!\".equals(args[0])")
039 public void handleEm(@Condition("\"!\".equals(strRef.get())") AtomicReference<String> strRef) {
040 ++emCounter;
041 emOk = "!".equals(strRef.get());
042 }
043 }