initial revision

.gitignore

+/build/
+/bin/
+.gradle/
+.settings
+.idea
+.lck
+.project
+.classpath
+gradle/

build.gradle

+group 'com.ipgallery'
+version '1.0.0'
+
+apply plugin: 'java'
+
+
+sourceCompatibility = 1.8
+
+repositories {
+    maven { url "http://mandubian-mvn.googlecode.com/svn/trunk/mandubian-mvn/repository" }
+    maven { url "http://172.16.1.132:8081/repository/internal" }
+}
+
+dependencies {
+    compile 'com.ipgallery:jinfra-utils:1.1.1'
+    compile 'com.ipgallery:jinfra-rabbitmq:1.0.0'
+    compile 'com.ipgallery:jinfra-grs:1.0.0'
+    compile 'com.ipgallery:jinfra-microservice:1.2.3'
+    compile 'com.ipgallery:jinfra-itc:1.0.0'
+    compile 'io.swagger:swagger-annotations:1.5.7'
+    compile 'org.slf4j:slf4j-simple:1.7.19'
+    compile 'com.javadocmd:simplelatlng:1.3.1'
+}
+
+jar {
+    manifest.attributes 'Main-Class': 'web.App'
+    from configurations.compile.collect { zipTree it }
+    // to remove "no manifiest section for signature"
+    exclude 'META-INF/*.RSA', 'META-INF/*.SF','META-INF/*.DSA'
+}

gradlew

+#!/usr/bin/env bash
+
+##############################################################################
+##
+##  Gradle start up script for UN*X
+##
+##############################################################################
+
+# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+DEFAULT_JVM_OPTS=""
+
+APP_NAME="Gradle"
+APP_BASE_NAME=`basename "$0"`
+
+# Use the maximum available, or set MAX_FD != -1 to use that value.
+MAX_FD="maximum"
+
+warn ( ) {
+    echo "$*"
+}
+
+die ( ) {
+    echo
+    echo "$*"
+    echo
+    exit 1
+}
+
+# OS specific support (must be 'true' or 'false').
+cygwin=false
+msys=false
+darwin=false
+case "`uname`" in
+  CYGWIN* )
+    cygwin=true
+    ;;
+  Darwin* )
+    darwin=true
+    ;;
+  MINGW* )
+    msys=true
+    ;;
+esac
+
+# Attempt to set APP_HOME
+# Resolve links: $0 may be a link
+PRG="$0"
+# Need this for relative symlinks.
+while [ -h "$PRG" ] ; do
+    ls=`ls -ld "$PRG"`
+    link=`expr "$ls" : '.*-> \(.*\)$'`
+    if expr "$link" : '/.*' > /dev/null; then
+        PRG="$link"
+    else
+        PRG=`dirname "$PRG"`"/$link"
+    fi
+done
+SAVED="`pwd`"
+cd "`dirname \"$PRG\"`/" >/dev/null
+APP_HOME="`pwd -P`"
+cd "$SAVED" >/dev/null
+
+CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
+
+# Determine the Java command to use to start the JVM.
+if [ -n "$JAVA_HOME" ] ; then
+    if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+        # IBM's JDK on AIX uses strange locations for the executables
+        JAVACMD="$JAVA_HOME/jre/sh/java"
+    else
+        JAVACMD="$JAVA_HOME/bin/java"
+    fi
+    if [ ! -x "$JAVACMD" ] ; then
+        die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+else
+    JAVACMD="java"
+    which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+fi
+
+# Increase the maximum file descriptors if we can.
+if [ "$cygwin" = "false" -a "$darwin" = "false" ] ; then
+    MAX_FD_LIMIT=`ulimit -H -n`
+    if [ $? -eq 0 ] ; then
+        if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then
+            MAX_FD="$MAX_FD_LIMIT"
+        fi
+        ulimit -n $MAX_FD
+        if [ $? -ne 0 ] ; then
+            warn "Could not set maximum file descriptor limit: $MAX_FD"
+        fi
+    else
+        warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT"
+    fi
+fi
+
+# For Darwin, add options to specify how the application appears in the dock
+if $darwin; then
+    GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\""
+fi
+
+# For Cygwin, switch paths to Windows format before running java
+if $cygwin ; then
+    APP_HOME=`cygpath --path --mixed "$APP_HOME"`
+    CLASSPATH=`cygpath --path --mixed "$CLASSPATH"`
+    JAVACMD=`cygpath --unix "$JAVACMD"`
+
+    # We build the pattern for arguments to be converted via cygpath
+    ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null`
+    SEP=""
+    for dir in $ROOTDIRSRAW ; do
+        ROOTDIRS="$ROOTDIRS$SEP$dir"
+        SEP="|"
+    done
+    OURCYGPATTERN="(^($ROOTDIRS))"
+    # Add a user-defined pattern to the cygpath arguments
+    if [ "$GRADLE_CYGPATTERN" != "" ] ; then
+        OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)"
+    fi
+    # Now convert the arguments - kludge to limit ourselves to /bin/sh
+    i=0
+    for arg in "$@" ; do
+        CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -`
+        CHECK2=`echo "$arg"|egrep -c "^-"`                                 ### Determine if an option
+
+        if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then                    ### Added a condition
+            eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"`
+        else
+            eval `echo args$i`="\"$arg\""
+        fi
+        i=$((i+1))
+    done
+    case $i in
+        (0) set -- ;;
+        (1) set -- "$args0" ;;
+        (2) set -- "$args0" "$args1" ;;
+        (3) set -- "$args0" "$args1" "$args2" ;;
+        (4) set -- "$args0" "$args1" "$args2" "$args3" ;;
+        (5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;;
+        (6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;;
+        (7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;;
+        (8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;;
+        (9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;;
+    esac
+fi
+
+# Split up the JVM_OPTS And GRADLE_OPTS values into an array, following the shell quoting and substitution rules
+function splitJvmOpts() {
+    JVM_OPTS=("$@")
+}
+eval splitJvmOpts $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS
+JVM_OPTS[${#JVM_OPTS[*]}]="-Dorg.gradle.appname=$APP_BASE_NAME"
+
+exec "$JAVACMD" "${JVM_OPTS[@]}" -classpath "$CLASSPATH" org.gradle.wrapper.GradleWrapperMain "$@"

gradlew.bat

+@if "%DEBUG%" == "" @echo off
+@rem ##########################################################################
+@rem
+@rem  Gradle startup script for Windows
+@rem
+@rem ##########################################################################
+
+@rem Set local scope for the variables with windows NT shell
+if "%OS%"=="Windows_NT" setlocal
+
+@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+set DEFAULT_JVM_OPTS=
+
+set DIRNAME=%~dp0
+if "%DIRNAME%" == "" set DIRNAME=.
+set APP_BASE_NAME=%~n0
+set APP_HOME=%DIRNAME%
+
+@rem Find java.exe
+if defined JAVA_HOME goto findJavaFromJavaHome
+
+set JAVA_EXE=java.exe
+%JAVA_EXE% -version >NUL 2>&1
+if "%ERRORLEVEL%" == "0" goto init
+
+echo.
+echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:findJavaFromJavaHome
+set JAVA_HOME=%JAVA_HOME:"=%
+set JAVA_EXE=%JAVA_HOME%/bin/java.exe
+
+if exist "%JAVA_EXE%" goto init
+
+echo.
+echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME%
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:init
+@rem Get command-line arguments, handling Windowz variants
+
+if not "%OS%" == "Windows_NT" goto win9xME_args
+if "%@eval[2+2]" == "4" goto 4NT_args
+
+:win9xME_args
+@rem Slurp the command line arguments.
+set CMD_LINE_ARGS=
+set _SKIP=2
+
+:win9xME_args_slurp
+if "x%~1" == "x" goto execute
+
+set CMD_LINE_ARGS=%*
+goto execute
+
+:4NT_args
+@rem Get arguments from the 4NT Shell from JP Software
+set CMD_LINE_ARGS=%$
+
+:execute
+@rem Setup the command line
+
+set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
+
+@rem Execute Gradle
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %CMD_LINE_ARGS%
+
+:end
+@rem End local scope for the variables with windows NT shell
+if "%ERRORLEVEL%"=="0" goto mainEnd
+
+:fail
+rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
+rem the _cmd.exe /c_ return code!
+if  not "" == "%GRADLE_EXIT_CONSOLE%" exit 1
+exit /b 1
+
+:mainEnd
+if "%OS%"=="Windows_NT" endlocal
+
+:omega

settings.gradle

+rootProject.name = 'LocationService'
+

src/main/java/domain/EntitiesLocationRestResponse.java

+
+package domain;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.annotations.ApiModelProperty;
+
+
+@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaJerseyServerCodegen", date = "2016-03-31T07:24:28.094Z")
+public class EntitiesLocationRestResponse   {
+  
+  private Boolean success = null;
+  private String error = null;
+  private List<EntityLocation> objectNode = new ArrayList<EntityLocation>();
+
+  
+  /**
+   **/
+  public EntitiesLocationRestResponse success(Boolean success) {
+    this.success = success;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "")
+  @JsonProperty("success")
+  public Boolean getSuccess() {
+    return success;
+  }
+  public void setSuccess(Boolean success) {
+    this.success = success;
+  }
+
+  
+  /**
+   **/
+  public EntitiesLocationRestResponse error(String error) {
+    this.error = error;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "")
+  @JsonProperty("error")
+  public String getError() {
+    return error;
+  }
+  public void setError(String error) {
+    this.error = error;
+  }
+
+  
+  /**
+   **/
+  public EntitiesLocationRestResponse objectNode(List<EntityLocation> objectNode) {
+    this.objectNode = objectNode;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "")
+  @JsonProperty("objectNode")
+  public List<EntityLocation> getObjectNode() {
+    return objectNode;
+  }
+  public void setObjectNode(List<EntityLocation> objectNode) {
+    this.objectNode = objectNode;
+  }
+
+  
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (o == null || getClass() != o.getClass()) {
+      return false;
+    }
+    EntitiesLocationRestResponse entitiesLocationRestResponse = (EntitiesLocationRestResponse) o;
+    return Objects.equals(success, entitiesLocationRestResponse.success) &&
+        Objects.equals(error, entitiesLocationRestResponse.error) &&
+        Objects.equals(objectNode, entitiesLocationRestResponse.objectNode);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(success, error, objectNode);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder();
+    sb.append("class EntitiesLocationRestResponse {\n");
+    
+    sb.append("    success: ").append(toIndentedString(success)).append("\n");
+    sb.append("    error: ").append(toIndentedString(error)).append("\n");
+    sb.append("    objectNode: ").append(toIndentedString(objectNode)).append("\n");
+    sb.append("}");
+    return sb.toString();
+  }
+
+  /**
+   * Convert the given object to string with each line indented by 4 spaces
+   * (except the first line).
+   */
+  private String toIndentedString(Object o) {
+    if (o == null) {
+      return "null";
+    }
+    return o.toString().replace("\n", "\n    ");
+  }
+}
+

src/main/java/domain/EntityGeoLocation.java

+package domain;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Created by gil on 4/6/16.
+ */
+public class EntityGeoLocation extends  EntityLocation {
+    private List<Double> location = new ArrayList<Double>();
+
+    /**
+     * GeoJSON point format
+     **/
+    public EntityLocation location(List<Double> location) {
+        this.location = location;
+        return this;
+    }
+
+    public List<Double> getLocation() {
+        return location;
+    }
+    public void setLocation(List<Double> location) {
+        this.location = location;
+    }
+}

src/main/java/domain/EntityIdsRestResponse.java

+package domain;
+
+import java.util.Objects;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.annotations.ApiModelProperty;
+import java.util.ArrayList;
+import java.util.List;
+
+
+
+
+
+@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaJerseyServerCodegen", date = "2016-03-31T07:24:28.094Z")
+public class EntityIdsRestResponse   {
+  
+  private Boolean success = null;
+  private String error = null;
+  private List<String> objectNode = new ArrayList<String>();
+
+  
+  /**
+   **/
+  public EntityIdsRestResponse success(Boolean success) {
+    this.success = success;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "")
+  @JsonProperty("success")
+  public Boolean getSuccess() {
+    return success;
+  }
+  public void setSuccess(Boolean success) {
+    this.success = success;
+  }
+
+  
+  /**
+   **/
+  public EntityIdsRestResponse error(String error) {
+    this.error = error;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "")
+  @JsonProperty("error")
+  public String getError() {
+    return error;
+  }
+  public void setError(String error) {
+    this.error = error;
+  }
+
+  
+  /**
+   * array of entity id's
+   **/
+  public EntityIdsRestResponse objectNode(List<String> objectNode) {
+    this.objectNode = objectNode;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "array of entity id's")
+  @JsonProperty("objectNode")
+  public List<String> getObjectNode() {
+    return objectNode;
+  }
+  public void setObjectNode(List<String> objectNode) {
+    this.objectNode = objectNode;
+  }
+
+  
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (o == null || getClass() != o.getClass()) {
+      return false;
+    }
+    EntityIdsRestResponse entityIdsRestResponse = (EntityIdsRestResponse) o;
+    return Objects.equals(success, entityIdsRestResponse.success) &&
+        Objects.equals(error, entityIdsRestResponse.error) &&
+        Objects.equals(objectNode, entityIdsRestResponse.objectNode);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(success, error, objectNode);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder();
+    sb.append("class EntityIdsRestResponse {\n");
+    
+    sb.append("    success: ").append(toIndentedString(success)).append("\n");
+    sb.append("    error: ").append(toIndentedString(error)).append("\n");
+    sb.append("    objectNode: ").append(toIndentedString(objectNode)).append("\n");
+    sb.append("}");
+    return sb.toString();
+  }
+
+  /**
+   * Convert the given object to string with each line indented by 4 spaces
+   * (except the first line).
+   */
+  private String toIndentedString(Object o) {
+    if (o == null) {
+      return "null";
+    }
+    return o.toString().replace("\n", "\n    ");
+  }
+}
+

src/main/java/domain/EntityLatLonLocation.java

+package domain;
+
+/**
+ * Created by gil on 4/6/16.
+ */
+public class EntityLatLonLocation extends EntityLocation {
+    public String getLatLon() {
+        return latLon;
+    }
+
+    public void setLatLon(String latLon) {
+        this.latLon = latLon;
+    }
+
+    private String latLon;
+}

src/main/java/domain/EntityLocation.java

+package domain;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.annotations.ApiModelProperty;
+
+
+@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaJerseyServerCodegen", date = "2016-03-31T07:24:28.094Z")
+public class EntityLocation   {
+  
+  private String entity = null;
+
+  public EntityLocation entity(String entity) {
+    this.entity = entity;
+    return this;
+  }
+
+  @ApiModelProperty(value = "")
+  @JsonProperty("entity")
+  public String getEntity() {
+    return entity;
+  }
+  public void setEntity(String entity) {
+    this.entity = entity;
+  }
+
+}
+

src/main/java/domain/EntityLocationRestResponse.java

+package domain;
+
+import java.util.Objects;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.annotations.ApiModelProperty;
+
+
+
+
+
+@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaJerseyServerCodegen", date = "2016-03-31T07:24:28.094Z")
+public class EntityLocationRestResponse   {
+  
+  private Boolean success = null;
+  private String error = null;
+  private EntityLocation objectNode = null;
+
+  
+  /**
+   **/
+  public EntityLocationRestResponse success(Boolean success) {
+    this.success = success;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "")
+  @JsonProperty("success")
+  public Boolean getSuccess() {
+    return success;
+  }
+  public void setSuccess(Boolean success) {
+    this.success = success;
+  }
+
+  
+  /**
+   **/
+  public EntityLocationRestResponse error(String error) {
+    this.error = error;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "")
+  @JsonProperty("error")
+  public String getError() {
+    return error;
+  }
+  public void setError(String error) {
+    this.error = error;
+  }
+
+  
+  /**
+   **/
+  public EntityLocationRestResponse objectNode(EntityLocation objectNode) {
+    this.objectNode = objectNode;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "")
+  @JsonProperty("objectNode")
+  public EntityLocation getObjectNode() {
+    return objectNode;
+  }
+  public void setObjectNode(EntityLocation objectNode) {
+    this.objectNode = objectNode;
+  }
+
+  
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (o == null || getClass() != o.getClass()) {
+      return false;
+    }
+    EntityLocationRestResponse entityLocationRestResponse = (EntityLocationRestResponse) o;
+    return Objects.equals(success, entityLocationRestResponse.success) &&
+        Objects.equals(error, entityLocationRestResponse.error) &&
+        Objects.equals(objectNode, entityLocationRestResponse.objectNode);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(success, error, objectNode);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder();
+    sb.append("class EntityLocationRestResponse {\n");
+    
+    sb.append("    success: ").append(toIndentedString(success)).append("\n");
+    sb.append("    error: ").append(toIndentedString(error)).append("\n");
+    sb.append("    objectNode: ").append(toIndentedString(objectNode)).append("\n");
+    sb.append("}");
+    return sb.toString();
+  }
+
+  /**
+   * Convert the given object to string with each line indented by 4 spaces
+   * (except the first line).
+   */
+  private String toIndentedString(Object o) {
+    if (o == null) {
+      return "null";
+    }
+    return o.toString().replace("\n", "\n    ");
+  }
+}
+

src/main/java/domain/EntitySubscription.java

+package domain;
+
+import java.util.Objects;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonValue;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
+
+
+
+/**
+ * either 'near' object valid or 'box' , not both
+ **/
+
+@ApiModel(description = "either 'near' object valid or 'box' , not both")
+@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaJerseyServerCodegen", date = "2016-03-31T07:24:28.094Z")
+public class EntitySubscription   {
+  
+  private String callbackUrl = null;
+  private EntitySubscriptionNear near = null;
+  private List<List<Double>> box = new ArrayList<List<Double>>();
+  private BigDecimal expires = null;
+
+
+  public enum DirectionEnum {
+    IN("in"),
+    OUT("out");
+
+    private String value;
+
+    DirectionEnum(String value) {
+      this.value = value;
+    }
+
+    @Override
+    @JsonValue
+    public String toString() {
+      return value;
+    }
+  }
+
+  private DirectionEnum direction = null;
+
+  
+  /**
+   * the url to post the notification
+   **/
+  public EntitySubscription callbackUrl(String callbackUrl) {
+    this.callbackUrl = callbackUrl;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "the url to post the notification")
+  @JsonProperty("callback_url")
+  public String getCallbackUrl() {
+    return callbackUrl;
+  }
+  public void setCallbackUrl(String callbackUrl) {
+    this.callbackUrl = callbackUrl;
+  }
+
+  
+  /**
+   **/
+  public EntitySubscription near(EntitySubscriptionNear near) {
+    this.near = near;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "")
+  @JsonProperty("near")
+  public EntitySubscriptionNear getNear() {
+    return near;
+  }
+  public void setNear(EntitySubscriptionNear near) {
+    this.near = near;
+  }
+
+  
+  /**
+   * 2 geo points [[x1,y1],[x2,y2]] enclosing box
+   **/
+  public EntitySubscription box(List<List<Double>> box) {
+    this.box = box;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "2 geo points [[x1,y1],[x2,y2]] enclosing box")
+  @JsonProperty("box")
+  public List<List<Double>> getBox() {
+    return box;
+  }
+  public void setBox(List<List<Double>> box) {
+    this.box = box;
+  }
+
+  
+  /**
+   * expiration time in seconds
+   **/
+  public EntitySubscription expires(BigDecimal expires) {
+    this.expires = expires;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "expiration time in seconds")
+  @JsonProperty("expires")
+  public BigDecimal getExpires() {
+    return expires;
+  }
+  public void setExpires(BigDecimal expires) {
+    this.expires = expires;
+  }
+
+  
+  /**
+   * in/out entering or existing
+   **/
+  public EntitySubscription direction(DirectionEnum direction) {
+    this.direction = direction;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "in/out entering or existing")
+  @JsonProperty("direction")
+  public DirectionEnum getDirection() {
+    return direction;
+  }
+  public void setDirection(DirectionEnum direction) {
+    this.direction = direction;
+  }
+
+  
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (o == null || getClass() != o.getClass()) {
+      return false;
+    }
+    EntitySubscription entitySubscription = (EntitySubscription) o;
+    return Objects.equals(callbackUrl, entitySubscription.callbackUrl) &&
+        Objects.equals(near, entitySubscription.near) &&
+        Objects.equals(box, entitySubscription.box) &&
+        Objects.equals(expires, entitySubscription.expires) &&
+        Objects.equals(direction, entitySubscription.direction);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(callbackUrl, near, box, expires, direction);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder();
+    sb.append("class EntitySubscription {\n");
+    
+    sb.append("    callbackUrl: ").append(toIndentedString(callbackUrl)).append("\n");
+    sb.append("    near: ").append(toIndentedString(near)).append("\n");
+    sb.append("    box: ").append(toIndentedString(box)).append("\n");
+    sb.append("    expires: ").append(toIndentedString(expires)).append("\n");
+    sb.append("    direction: ").append(toIndentedString(direction)).append("\n");
+    sb.append("}");
+    return sb.toString();
+  }
+
+  /**
+   * Convert the given object to string with each line indented by 4 spaces
+   * (except the first line).
+   */
+  private String toIndentedString(Object o) {
+    if (o == null) {
+      return "null";
+    }
+    return o.toString().replace("\n", "\n    ");
+  }
+}
+

src/main/java/domain/EntitySubscriptionNear.java

+package domain;
+
+import java.util.Objects;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonValue;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
+
+
+
+/**
+ * near location subscription, radius from point
+ **/
+
+@ApiModel(description = "near location subscription, radius from point")
+@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaJerseyServerCodegen", date = "2016-03-31T07:24:28.094Z")
+public class EntitySubscriptionNear   {
+  
+  private BigDecimal distance = null;
+  private List<Double> location = new ArrayList<Double>();
+
+
+  public enum UnitsEnum {
+    MILE("mile"),
+    KM("km");
+
+    private String value;
+
+    UnitsEnum(String value) {
+      this.value = value;
+    }
+
+    @Override
+    @JsonValue
+    public String toString() {
+      return value;
+    }
+  }
+
+  private UnitsEnum units = UnitsEnum.MILE;
+
+  
+  /**
+   * distance from given location
+   **/
+  public EntitySubscriptionNear distance(BigDecimal distance) {
+    this.distance = distance;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "distance from given location")
+  @JsonProperty("distance")
+  public BigDecimal getDistance() {
+    return distance;
+  }
+  public void setDistance(BigDecimal distance) {
+    this.distance = distance;
+  }
+
+  
+  /**
+   * GeoJSON point format
+   **/
+  public EntitySubscriptionNear location(List<Double> location) {
+    this.location = location;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "GeoJSON point format")
+  @JsonProperty("location")
+  public List<Double> getLocation() {
+    return location;
+  }
+  public void setLocation(List<Double> location) {
+    this.location = location;
+  }
+
+  
+  /**
+   * units of distance
+   **/
+  public EntitySubscriptionNear units(UnitsEnum units) {
+    this.units = units;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "units of distance")
+  @JsonProperty("units")
+  public UnitsEnum getUnits() {
+    return units;
+  }
+  public void setUnits(UnitsEnum units) {
+    this.units = units;
+  }
+
+  
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (o == null || getClass() != o.getClass()) {
+      return false;
+    }
+    EntitySubscriptionNear entitySubscriptionNear = (EntitySubscriptionNear) o;
+    return Objects.equals(distance, entitySubscriptionNear.distance) &&
+        Objects.equals(location, entitySubscriptionNear.location) &&
+        Objects.equals(units, entitySubscriptionNear.units);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(distance, location, units);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder();
+    sb.append("class EntitySubscriptionNear {\n");
+    
+    sb.append("    distance: ").append(toIndentedString(distance)).append("\n");
+    sb.append("    location: ").append(toIndentedString(location)).append("\n");
+    sb.append("    units: ").append(toIndentedString(units)).append("\n");
+    sb.append("}");
+    return sb.toString();
+  }
+
+  /**
+   * Convert the given object to string with each line indented by 4 spaces
+   * (except the first line).
+   */
+  private String toIndentedString(Object o) {
+    if (o == null) {
+      return "null";
+    }
+    return o.toString().replace("\n", "\n    ");
+  }
+}
+

src/main/java/domain/EntitySubscriptionResponse.java

+package domain;
+
+import java.util.Objects;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.annotations.ApiModelProperty;
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
+
+
+
+
+
+@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaJerseyServerCodegen", date = "2016-03-31T07:24:28.094Z")
+public class EntitySubscriptionResponse extends EntitySubscription  {
+  
+  private String callbackUrl = null;
+  private EntitySubscriptionNear near = null;
+  private List<List<Double>> box = new ArrayList<List<Double>>();
+  private BigDecimal expires = null;
+  private String subId = null;
+
+  
+  /**
+   * the url to post the notification
+   **/
+  public EntitySubscriptionResponse callbackUrl(String callbackUrl) {
+    this.callbackUrl = callbackUrl;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "the url to post the notification")
+  @JsonProperty("callback_url")
+  public String getCallbackUrl() {
+    return callbackUrl;
+  }
+  public void setCallbackUrl(String callbackUrl) {
+    this.callbackUrl = callbackUrl;
+  }
+
+  
+  /**
+   **/
+  public EntitySubscriptionResponse near(EntitySubscriptionNear near) {
+    this.near = near;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "")
+  @JsonProperty("near")
+  public EntitySubscriptionNear getNear() {
+    return near;
+  }
+  public void setNear(EntitySubscriptionNear near) {
+    this.near = near;
+  }
+
+  
+  /**
+   * 2 geo points [[x1,y1],[x2,y2]] enclosing box
+   **/
+  public EntitySubscriptionResponse box(List<List<Double>> box) {
+    this.box = box;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "2 geo points [[x1,y1],[x2,y2]] enclosing box")
+  @JsonProperty("box")
+  public List<List<Double>> getBox() {
+    return box;
+  }
+  public void setBox(List<List<Double>> box) {
+    this.box = box;
+  }
+
+  
+  /**
+   * expiration time in seconds
+   **/
+  public EntitySubscriptionResponse expires(BigDecimal expires) {
+    this.expires = expires;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "expiration time in seconds")
+  @JsonProperty("expires")
+  public BigDecimal getExpires() {
+    return expires;
+  }
+  public void setExpires(BigDecimal expires) {
+    this.expires = expires;
+  }
+
+  
+  /**
+   * the subscription-id, generated by the service
+   **/
+  public EntitySubscriptionResponse subId(String subId) {
+    this.subId = subId;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "the subscription-id, generated by the service")
+  @JsonProperty("subId")
+  public String getSubId() {
+    return subId;
+  }
+  public void setSubId(String subId) {
+    this.subId = subId;
+  }
+
+  
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (o == null || getClass() != o.getClass()) {
+      return false;
+    }
+    EntitySubscriptionResponse entitySubscriptionResponse = (EntitySubscriptionResponse) o;
+    return Objects.equals(callbackUrl, entitySubscriptionResponse.callbackUrl) &&
+        Objects.equals(near, entitySubscriptionResponse.near) &&
+        Objects.equals(box, entitySubscriptionResponse.box) &&
+        Objects.equals(expires, entitySubscriptionResponse.expires) &&
+        Objects.equals(subId, entitySubscriptionResponse.subId);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(callbackUrl, near, box, expires, subId);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder();
+    sb.append("class EntitySubscriptionResponse {\n");
+    sb.append("    ").append(toIndentedString(super.toString())).append("\n");
+    sb.append("    callbackUrl: ").append(toIndentedString(callbackUrl)).append("\n");
+    sb.append("    near: ").append(toIndentedString(near)).append("\n");
+    sb.append("    box: ").append(toIndentedString(box)).append("\n");
+    sb.append("    expires: ").append(toIndentedString(expires)).append("\n");
+    sb.append("    subId: ").append(toIndentedString(subId)).append("\n");
+    sb.append("}");
+    return sb.toString();
+  }
+
+  /**
+   * Convert the given object to string with each line indented by 4 spaces
+   * (except the first line).
+   */
+  private String toIndentedString(Object o) {
+    if (o == null) {
+      return "null";
+    }
+    return o.toString().replace("\n", "\n    ");
+  }
+}
+

src/main/java/domain/EntitySubscriptionRestResponse.java

+package domain;
+
+import java.util.Objects;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.annotations.ApiModelProperty;
+import java.util.ArrayList;
+import java.util.List;
+
+
+
+
+
+@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaJerseyServerCodegen", date = "2016-03-31T07:24:28.094Z")
+public class EntitySubscriptionRestResponse   {
+  
+  private Boolean success = null;
+  private String error = null;
+  private List<EntitySubscriptionResponse> objectNode = new ArrayList<EntitySubscriptionResponse>();
+
+  
+  /**
+   **/
+  public EntitySubscriptionRestResponse success(Boolean success) {
+    this.success = success;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "")
+  @JsonProperty("success")
+  public Boolean getSuccess() {
+    return success;
+  }
+  public void setSuccess(Boolean success) {
+    this.success = success;
+  }
+
+  
+  /**
+   **/
+  public EntitySubscriptionRestResponse error(String error) {
+    this.error = error;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "")
+  @JsonProperty("error")
+  public String getError() {
+    return error;
+  }
+  public void setError(String error) {
+    this.error = error;
+  }
+
+  
+  /**
+   * array of entity id's
+   **/
+  public EntitySubscriptionRestResponse objectNode(List<EntitySubscriptionResponse> objectNode) {
+    this.objectNode = objectNode;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "array of entity id's")
+  @JsonProperty("objectNode")
+  public List<EntitySubscriptionResponse> getObjectNode() {
+    return objectNode;
+  }
+  public void setObjectNode(List<EntitySubscriptionResponse> objectNode) {
+    this.objectNode = objectNode;
+  }
+
+  
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (o == null || getClass() != o.getClass()) {
+      return false;
+    }
+    EntitySubscriptionRestResponse entitySubscriptionRestResponse = (EntitySubscriptionRestResponse) o;
+    return Objects.equals(success, entitySubscriptionRestResponse.success) &&
+        Objects.equals(error, entitySubscriptionRestResponse.error) &&
+        Objects.equals(objectNode, entitySubscriptionRestResponse.objectNode);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(success, error, objectNode);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder();
+    sb.append("class EntitySubscriptionRestResponse {\n");
+    
+    sb.append("    success: ").append(toIndentedString(success)).append("\n");
+    sb.append("    error: ").append(toIndentedString(error)).append("\n");
+    sb.append("    objectNode: ").append(toIndentedString(objectNode)).append("\n");
+    sb.append("}");
+    return sb.toString();
+  }
+
+  /**
+   * Convert the given object to string with each line indented by 4 spaces
+   * (except the first line).
+   */
+  private String toIndentedString(Object o) {
+    if (o == null) {
+      return "null";
+    }
+    return o.toString().replace("\n", "\n    ");
+  }
+}
+

src/main/java/domain/EntitySubscriptionsRestResponse.java

+package domain;
+
+import java.util.Objects;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.annotations.ApiModelProperty;
+import java.util.ArrayList;
+import java.util.List;
+
+
+
+
+
+@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaJerseyServerCodegen", date = "2016-03-31T07:24:28.094Z")
+public class EntitySubscriptionsRestResponse   {
+  
+  private Boolean success = null;
+  private String error = null;
+  private List<EntitySubscription> objectNode = new ArrayList<EntitySubscription>();
+
+  
+  /**
+   **/
+  public EntitySubscriptionsRestResponse success(Boolean success) {
+    this.success = success;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "")
+  @JsonProperty("success")
+  public Boolean getSuccess() {
+    return success;
+  }
+  public void setSuccess(Boolean success) {
+    this.success = success;
+  }
+
+  
+  /**
+   **/
+  public EntitySubscriptionsRestResponse error(String error) {
+    this.error = error;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "")
+  @JsonProperty("error")
+  public String getError() {
+    return error;
+  }
+  public void setError(String error) {
+    this.error = error;
+  }
+
+  
+  /**
+   * array of entity id's
+   **/
+  public EntitySubscriptionsRestResponse objectNode(List<EntitySubscription> objectNode) {
+    this.objectNode = objectNode;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "array of entity id's")
+  @JsonProperty("objectNode")
+  public List<EntitySubscription> getObjectNode() {
+    return objectNode;
+  }
+  public void setObjectNode(List<EntitySubscription> objectNode) {
+    this.objectNode = objectNode;
+  }
+
+  
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (o == null || getClass() != o.getClass()) {
+      return false;
+    }
+    EntitySubscriptionsRestResponse entitySubscriptionsRestResponse = (EntitySubscriptionsRestResponse) o;
+    return Objects.equals(success, entitySubscriptionsRestResponse.success) &&
+        Objects.equals(error, entitySubscriptionsRestResponse.error) &&
+        Objects.equals(objectNode, entitySubscriptionsRestResponse.objectNode);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(success, error, objectNode);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder();
+    sb.append("class EntitySubscriptionsRestResponse {\n");
+    
+    sb.append("    success: ").append(toIndentedString(success)).append("\n");
+    sb.append("    error: ").append(toIndentedString(error)).append("\n");
+    sb.append("    objectNode: ").append(toIndentedString(objectNode)).append("\n");
+    sb.append("}");
+    return sb.toString();
+  }
+
+  /**
+   * Convert the given object to string with each line indented by 4 spaces
+   * (except the first line).
+   */
+  private String toIndentedString(Object o) {
+    if (o == null) {
+      return "null";
+    }
+    return o.toString().replace("\n", "\n    ");
+  }
+}
+

src/main/java/domain/Latlon.java

+package domain;
+
+import java.util.Objects;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.annotations.ApiModelProperty;
+
+
+
+
+
+@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaJerseyServerCodegen", date = "2016-03-31T07:24:28.094Z")
+public class Latlon   {
+  
+  private Double lat = null;
+  private Double lon = null;
+
+  
+  /**
+   * latitude in double
+   **/
+  public Latlon lat(Double lat) {
+    this.lat = lat;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "latitude in double")
+  @JsonProperty("lat")
+  public Double getLat() {
+    return lat;
+  }
+  public void setLat(Double lat) {
+    this.lat = lat;
+  }
+
+  
+  /**
+   * longtitude in double
+   **/
+  public Latlon lon(Double lon) {
+    this.lon = lon;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "longtitude in double")
+  @JsonProperty("lon")
+  public Double getLon() {
+    return lon;
+  }
+  public void setLon(Double lon) {
+    this.lon = lon;
+  }
+
+  
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (o == null || getClass() != o.getClass()) {
+      return false;
+    }
+    Latlon latlon = (Latlon) o;
+    return Objects.equals(lat, latlon.lat) &&
+        Objects.equals(lon, latlon.lon);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(lat, lon);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder();
+    sb.append("class Latlon {\n");
+    
+    sb.append("    lat: ").append(toIndentedString(lat)).append("\n");
+    sb.append("    lon: ").append(toIndentedString(lon)).append("\n");
+    sb.append("}");
+    return sb.toString();
+  }
+
+  /**
+   * Convert the given object to string with each line indented by 4 spaces
+   * (except the first line).
+   */
+  private String toIndentedString(Object o) {
+    if (o == null) {
+      return "null";
+    }
+    return o.toString().replace("\n", "\n    ");
+  }
+}
+

src/main/java/domain/RestResponse.java

+package domain;
+
+import java.util.Objects;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.annotations.ApiModelProperty;
+
+
+
+
+
+@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaJerseyServerCodegen", date = "2016-03-31T07:24:28.094Z")
+public class RestResponse   {
+  
+  private Boolean success = null;
+  private String error = null;
+  private String objectNode = null;
+
+  
+  /**
+   **/
+  public RestResponse success(Boolean success) {
+    this.success = success;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "")
+  @JsonProperty("success")
+  public Boolean getSuccess() {
+    return success;
+  }
+  public void setSuccess(Boolean success) {
+    this.success = success;
+  }
+
+  
+  /**
+   **/
+  public RestResponse error(String error) {
+    this.error = error;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "")
+  @JsonProperty("error")
+  public String getError() {
+    return error;
+  }
+  public void setError(String error) {
+    this.error = error;
+  }
+
+  
+  /**
+   * object/s in json format
+   **/
+  public RestResponse objectNode(String objectNode) {
+    this.objectNode = objectNode;
+    return this;
+  }
+
+  
+  @ApiModelProperty(value = "object/s in json format")
+  @JsonProperty("objectNode")
+  public String getObjectNode() {
+    return objectNode;
+  }
+  public void setObjectNode(String objectNode) {
+    this.objectNode = objectNode;
+  }
+
+  
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (o == null || getClass() != o.getClass()) {
+      return false;
+    }
+    RestResponse restResponse = (RestResponse) o;
+    return Objects.equals(success, restResponse.success) &&
+        Objects.equals(error, restResponse.error) &&
+        Objects.equals(objectNode, restResponse.objectNode);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(success, error, objectNode);
+  }
+
+  @Override
+  public String toString() {
+    StringBuilder sb = new StringBuilder();
+    sb.append("class RestResponse {\n");
+    
+    sb.append("    success: ").append(toIndentedString(success)).append("\n");
+    sb.append("    error: ").append(toIndentedString(error)).append("\n");
+    sb.append("    objectNode: ").append(toIndentedString(objectNode)).append("\n");
+    sb.append("}");
+    return sb.toString();
+  }
+
+  /**
+   * Convert the given object to string with each line indented by 4 spaces
+   * (except the first line).
+   */
+  private String toIndentedString(Object o) {
+    if (o == null) {
+      return "null";
+    }
+    return o.toString().replace("\n", "\n    ");
+  }
+}
+

src/main/java/logic/LatLonPubSub.java

+package logic;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.javadocmd.simplelatlng.LatLng;
+import com.javadocmd.simplelatlng.window.CircularWindow;
+import com.javadocmd.simplelatlng.window.RectangularWindow;
+import domain.EntitySubscription;
+import domain.EntitySubscriptionNear;
+import utils.common.CacheClient;
+import utils.common.RedisCacheClient;
+import java.io.IOException;
+import java.util.List;
+
+import static com.javadocmd.simplelatlng.util.LengthUnit.KILOMETER;
+import static com.javadocmd.simplelatlng.util.LengthUnit.MILE;
+
+/**
+ * Created by gil on 4/13/16.
+ */
+
+public class LatLonPubSub implements Runnable{
+
+    private String idType;
+    private String geoLocation;
+    private String oldGeoLocation;
+    private CacheClient rcc = null;
+    private LocationServiceManager locationServiceManager = null;
+
+    public LatLonPubSub(String idType, String geoLocation, String oldGeoLocation, LocationServiceManager locationServiceManager) {
+        this.idType = idType;
+        this.geoLocation = geoLocation;
+        this.oldGeoLocation = oldGeoLocation;
+        this.rcc = new RedisCacheClient();
+        this.locationServiceManager = locationServiceManager;
+    }
+    @Override
+	public void run()
+	{
+        readFromCacheClient();
+	}
+
+    private void readFromCacheClient()  {
+        ObjectMapper mapper = new ObjectMapper();
+        String pattern = idType + "*";
+        String[] keys = rcc.getByPattern(pattern);
+        for(String key : keys) {
+            String value = rcc.get(key);
+            try {
+                EntitySubscription es = mapper.readValue(value, EntitySubscription.class);
+                String url = checkLatLonInRange(es);
+                if(url != null)
+                    this.locationServiceManager.sendUrl(url,value);
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+
+    }
+
+    private String checkLatLonInRange(EntitySubscription es) {
+        String url = null;
+        Double lat = null;
+        Double lng = null;
+        Double oldLat = null;
+        Double oldLng = null;
+        EntitySubscription.DirectionEnum direction;
+
+        ObjectMapper mapper = new ObjectMapper();
+        JsonNode content = null;
+        try {
+            content = mapper.readTree(geoLocation);
+            lat  = content.get("lat").asDouble();
+            lng  = content.get("lon").asDouble();
+            content = mapper.readTree(oldGeoLocation);
+            oldLat = content.get("lat").asDouble();
+            oldLng = content.get("lon").asDouble();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        direction = es.getDirection();
+        if(es.getBox() != null) {
+            List<List<Double>> coordinates = es.getBox();
+            List<Double> coordinate1 = coordinates.get(0);
+            Double x1 = coordinate1.get(0);
+            Double y1 = coordinate1.get(1);
+            List<Double> coordinate2 = coordinates.get(1);
+            Double x2 = coordinate2.get(0);
+            Double y2 = coordinate2.get(1);
+            RectangularWindow recWindow = new RectangularWindow(new LatLng(x1,y1),new LatLng(x2,y2));
+            if(direction != null && direction.equals(EntitySubscription.DirectionEnum.IN)) {
+                if (!recWindow.contains(new LatLng(oldLat, oldLng)) &&
+                        recWindow.contains(new LatLng(lat, lng)))
+                    url = es.getCallbackUrl();
+            }
+            if(direction != null && direction.equals(EntitySubscription.DirectionEnum.OUT)) {
+                if (recWindow.contains(new LatLng(oldLat, oldLng)) &&
+                        !recWindow.contains(new LatLng(lat, lng)))
+                    url = es.getCallbackUrl();
+            }
+        }
+        else if(es.getNear() != null) {
+            EntitySubscriptionNear esn = es.getNear();
+            List<Double> location = esn.getLocation();
+            Double x = location.get(0);
+            Double y = location.get(1);
+            Double distance = esn.getDistance().doubleValue();
+            EntitySubscriptionNear.UnitsEnum units = esn.getUnits();
+            CircularWindow circWindow;
+            if(units.equals(EntitySubscriptionNear.UnitsEnum.KM))
+                circWindow = new CircularWindow(new LatLng(x,y),distance,KILOMETER);
+            else
+                circWindow = new CircularWindow(new LatLng(x,y),distance,MILE);
+
+            if(direction != null && direction.equals(EntitySubscription.DirectionEnum.IN)) {
+                if( !circWindow.contains(new LatLng(oldLat,oldLng)) &&
+                        circWindow.contains(new LatLng(lat,lng)))
+                    url = es.getCallbackUrl();
+            }
+            if(direction != null && direction.equals(EntitySubscription.DirectionEnum.OUT)) {
+                if( circWindow.contains(new LatLng(oldLat,oldLng)) &&
+                        !circWindow.contains(new LatLng(lat,lng)))
+                    url = es.getCallbackUrl();
+            }
+        }
+        return url;
+    }
+
+}

src/main/java/logic/LocationServiceManager.java

+package logic;
+
+import grs.BaseRestResponse;
+import microservice.MicroserviceClient;
+import microservice.io.iface.ILogger;
+import microservice.params.CommandParams;
+import microservice.params.RestClientParams;
+import util.CallBackHttpRequest;
+import utils.http.simpleHttpClient.SimpleHttpClient;
+import utils.http.simpleHttpClient.SimpleHttpResponse;
+import utils.mtqm.MultiThreadQueueManager;
+
+import java.io.UnsupportedEncodingException;
+import java.util.Base64;
+
+/**
+ * Created by gil on 3/31/16.
+ */
+
+public class LocationServiceManager {
+    private static final String DS_IP_ADDRESS = System.getProperty("ds.IpAddress", "localhost:8080");
+    private  static final String CONST_TENANT = "MCX";
+    private  static final String CONST_ENTITIES = "entities";
+    private  static final String CONST_ENTITY = "entity";
+
+    private MicroserviceClient restClient = null;
+    private SimpleHttpClient httpClient = null;
+    private RestClientParams params = null;
+    private ILogger logger = null;
+    private int currentNumber = 0;
+    private final static String THREAD_MANAGER_THREADS;
+    private final static String THREAD_MANAGER_QUEUE_SIZE;
+
+    static
+    {
+        THREAD_MANAGER_THREADS = (System.getProperty("config.thread.manager.threads") != null)? System.getProperty("config.offline.task.threads") : "7";
+        THREAD_MANAGER_QUEUE_SIZE = (System.getProperty("config.thread.manager.queue.size") != null)? System.getProperty("config.offline.task.queue.size") : "100";
+
+    }
+
+    private static MultiThreadQueueManager threadManager = null;
+
+    public LocationServiceManager(ILogger logger) {
+        synchronized(this)
+        {
+            if (threadManager == null)
+            {
+                threadManager = new MultiThreadQueueManager();
+                threadManager.startManager(Integer.parseInt(THREAD_MANAGER_THREADS), Integer.parseInt(THREAD_MANAGER_QUEUE_SIZE));
+            }
+        }
+        try{
+            this.logger = logger;
+            params = new RestClientParams("ds",true,0, DS_IP_ADDRESS, 100);
+            restClient = new MicroserviceClient(MicroserviceClient.EnumRestClientType.E_HTTP, params);
+            httpClient = new SimpleHttpClient();
+            httpClient.Initialize(100);
+        }
+        catch(Exception e){
+            restClient= null;
+        }
+    }
+
+    public BaseRestResponse updateEntityLocation(String entityId, String entityType , String geoLocation) {
+        logger.debug("calling updateEntityLocation");
+        String oldGeoLocation = null;
+        String id = new String(Base64.getDecoder().decode(entityId));
+        String type = new String(Base64.getDecoder().decode(entityType));
+        String idType = id + ":" + type;
+        String[] params = new String[4];
+        params[0] = CONST_TENANT;
+        params[1] = CONST_ENTITY;
+        params[2] = entityId;
+        params[3] = entityType;
+        String requestParams = "returnType=before";
+        BaseRestResponse resp = null;
+        CommandParams cmdParams = new CommandParams("entities", params, requestParams,geoLocation, null);
+        resp = restClient.update(cmdParams);
+        oldGeoLocation = resp.objectNode.toString();
+        currentNumber = threadManager.getNextQueueNumber(currentNumber);
+        threadManager.sendJob(1,
+                new LatLonPubSub(idType,geoLocation,oldGeoLocation,this),
+                null,
+                currentNumber,
+                LocationServiceManager.class.getName());
+        return resp;
+    }
+
+    public BaseRestResponse getEntityLocation(String entityId, String entityType) {
+        logger.debug("calling getEntityLocation");
+        String[] params = new String[4];
+        params[0] = CONST_TENANT;
+        params[1] = CONST_ENTITY;
+        params[2] = entityId;
+        params[3] = entityType;
+        BaseRestResponse resp = null;
+        CommandParams cmdParams = new CommandParams("entities", params, null,null, null);
+        resp = restClient.read(cmdParams);
+        return resp;
+    }
+
+    public BaseRestResponse getEntitiesLocation(String str) {
+        logger.debug("calling getEntitiesLocation");
+        String[] params = new String[2];
+        params[0] = CONST_TENANT;
+        params[1] = CONST_ENTITIES;
+        BaseRestResponse resp = null;
+        CommandParams cmdParams = new CommandParams("entities", params, str,null, null);
+        resp = restClient.read(cmdParams);
+        return resp;
+    }
+
+    public BaseRestResponse sendUrl(String url,String content) {
+
+        BaseRestResponse brr = new BaseRestResponse(true,null);
+        CallBackHttpRequest request = new CallBackHttpRequest(url, content );
+        try {
+            SimpleHttpResponse resp = httpClient.processRequest(request);
+            if (resp.getStatusCode() != 200) {
+                brr.success = false;
+                brr.setError("failed to send callback");
+            }
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        }
+        return brr;
+    }
+}

src/main/java/util/CallBackHttpRequest.java

+package util;
+
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.client.methods.HttpUriRequest;
+import org.apache.http.entity.StringEntity;
+import utils.http.simpleHttpClient.SimpleHttpRequest;
+
+import java.io.UnsupportedEncodingException;
+import java.util.Map;
+
+/**
+ * Created by gil on 4/17/16.
+ */
+public class CallBackHttpRequest extends SimpleHttpRequest {
+
+    String callbackUrl = null;
+    String content = null;
+
+
+    public CallBackHttpRequest(String callbackUrl, String content) {
+        this.callbackUrl = callbackUrl;
+        this.content = content;
+        setMethod(Method.POST);
+        addHeader("Content-Type", "application/json");
+    }
+
+    protected HttpUriRequest buildPostRequest() {
+        HttpPost postRequest = new HttpPost(callbackUrl);
+
+        // add headers
+        for(Map.Entry<String, String> hdr : headers.entrySet()) {
+            postRequest.addHeader(hdr.getKey(), hdr.getValue());
+        }
+
+        // add content
+        if (content != null) {
+            try {
+                StringEntity contentEntity =  new StringEntity(content,"UTF-8");
+                contentEntity.setContentType(contentType);
+                postRequest.setEntity(contentEntity);
+            } catch (UnsupportedEncodingException e) {
+                e.printStackTrace();
+            }
+        }
+
+        return postRequest;
+    }
+}

src/main/java/util/Enums.java

+package util;
+
+/**
+ * Created by gil on 3/31/16.
+ */
+
+
+public class Enums {
+    public enum EnumRestCommands {
+        E_LOCATION_ENTITY_API("entity"),
+        E_LOCATION_ENTITIES_API("entities"),
+        E_LOCATION_SUBSCRIPTION_API("subscription"),
+        E_LOCATION_ENTITIES_NEAR_LOCATION_API("entitiesNearLocation"),
+        E_LOCATION_ENTITIES_WITHIN_BOX_API("entitiesWithinBox");
+
+        private String str;
+
+        private EnumRestCommands(String strCommand)	{
+            this.str = strCommand;
+        }
+        public String getStrCommand() {
+            return str;
+        }
+        public static EnumRestCommands resolveCommand(String strCommand) {
+            for (EnumRestCommands command : EnumRestCommands.values()) {
+                if ( command != null &&
+                        command.getStrCommand() != null &&
+                        command.getStrCommand().equals(strCommand) ) {
+                    return command;
+                }
+            }
+            return null;
+        }
+    }
+}
+

src/main/java/web/App.java

+package web;
+
+/**
+ * Created by gil on 3/31/16.
+ */
+
+import utils.common.ConfigProperties;
+import handlers.LocationServiceHandler;
+import microservice.MicroserviceApp;
+import microservice.io.iface.ILogger;
+import microservice.params.RestServerParams;
+
+
+public class App {
+
+    public App() {
+        // TODO Auto-generated constructor stub
+    }
+
+    public static void main(String[] args) {
+
+        ConfigProperties.getInstance().loadProperties();
+
+        // load rest server parameters
+        Long port = (Long) ConfigProperties.getInstance().addConfigurationPropertyToHash("server.port","9090", ConfigProperties.EnumPropertyType.E_LONG);
+        String host = (String) ConfigProperties.getInstance().addConfigurationPropertyToHash("server.host","localhost", ConfigProperties.EnumPropertyType.E_STRING);
+        Long workerThreadsNum = (Long) ConfigProperties.getInstance().addConfigurationPropertyToHash("server.worker.threads","8", ConfigProperties.EnumPropertyType.E_LONG);
+        RestServerParams rsParams = new RestServerParams(port.intValue(), host, workerThreadsNum.intValue());
+        rsParams.setPubSubServerPort(0);
+
+        MicroserviceApp msApp = new MicroserviceApp(rsParams, null, "LocationService");
+        ILogger logger = msApp.getLogger();
+        LocationServiceHandler locationServiceHandler = new LocationServiceHandler(logger);
+        msApp.addHandler("/LocationService/api/v1", locationServiceHandler);
+
+        if (!msApp.startApp())
+            System.out.println("failed starting... check logs");
+
+    }
+
+}

src/test/java/TestLatLonPackge.java

+import com.javadocmd.simplelatlng.LatLng;
+import com.javadocmd.simplelatlng.window.CircularWindow;
+import com.javadocmd.simplelatlng.window.RectangularWindow;
+import org.junit.Test;
+
+import static com.javadocmd.simplelatlng.util.LengthUnit.KILOMETER;
+import static junit.framework.TestCase.assertEquals;
+
+/**
+ * Created by gil on 4/13/16.
+ */
+public class TestLatLonPackge {
+    @Test
+    public void testBox(){
+        System.out.print("testBox\n");
+
+        RectangularWindow w = new RectangularWindow(new LatLng(45, -67.5),new LatLng(20,-80));
+        CircularWindow c = new CircularWindow(new LatLng(10, 0), 40,KILOMETER);
+
+        assertEquals(w.contains(new LatLng(40,-70)),true);
+//        assertEquals(w.contains(new LatLng(40,70)),true);
+        assertEquals(c.contains(new LatLng(10.1,0.1)),true);
+
+        System.out.print(w);
+    }
+}