dhanji

@At("/person") @Async
public class PersonService {

  @Before
  void pre(Request request) {
    System.out.println("headers were: " + request.headers());
  }

  /**
   * Callback for request body. Can return a continuation, which will

dhanji

@At("/person/:name") @Async
public class PersonService {

  @Before
  void pre(Request request, @Named("name") String name) {
    System.out.println("headers were: " + request.headers());

    // We can either return a "Reply" here, or do nothing to continue processing
  }

dhanji

#!/bin/bash /usr/local/bin/coffee
-#
-# CLU by Dhanji R. Prasanna. Cluster Manager for EC2 processes.
-
-sys = require 'util'
-spawn = (require 'child_process').spawn
-
-
-# Cell descriptor
-cell =

dhanji

import com.google.common.collect.ImmutableMap;
import com.google.common.collect.MapMaker;
import com.google.inject.Inject;
import com.google.inject.Singleton;
import com.mongodb.BasicDBList;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.pastebo.data.User;
import com.pastebo.persist.MongoStore;

dhanji

package com.pastebo.web.auth;

import com.google.common.base.Preconditions;
import com.google.inject.Key;
import com.google.inject.OutOfScopeException;
import com.google.inject.Provider;
import com.google.inject.Scope;

/**
 * Special simulated proxy session scope for use with UserSession objects ONLY!

dhanji

package com.pastebo.web.auth;

import com.google.inject.Inject;
import com.google.inject.Singleton;

import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;

dhanji

package com.wideplay.mailsy.web.auth;

import com.wideplay.mailsy.data.index.Ids;

import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

/**
 * @author dhanji@gmail.com (Dhanji R. Prasanna)

dhanji

Scanning...
CacheStorage.java: [asl1.0: 52%, asl1.1: 66%]
ClassTemplateLoader.java: [asl1.0: 52%, asl1.1: 66%]
ConcurrentCacheStorage.java: []
ConcurrentMapFactory.java: []
FileTemplateLoader.java: [asl1.0: 52%, asl1.1: 66%]
MruCacheStorage.java: [asl1.0: 52%, asl1.1: 66%]
MultiTemplateLoader.java: [asl1.0: 52%, asl1.1: 66%]
NullCacheStorage.java: [asl1.0: 52%, asl1.1: 66%]

dhanji

Person p = query.topic(Person.class);

List<Person> results = query.from(p)
    .where(p.getName(), is("Jason"))
    .and(p.getAge(), greaterThan(10))
    .and(p.getCountry(), like("Canad*"))
    .or()
    .where(p.getName(), is("Dhanji"))
    .and(p.getCountry(), not("Canada"))
    .list();

dhanji

@At("/person") @Service
public class PersonService {

  @Get
  @As(Json.class) Reply<List<Person>> getRelatives(@As(Json.class) Person p) {
    return Reply.with(relativesOf(p));
  }
}