Skip to content

Instantly share code, notes, and snippets.

View mathieuancelin's full-sized avatar

Mathieu ANCELIN mathieuancelin

View GitHub Profile
import javax.enterprise.context.RequestScoped;
import javax.inject.Named;
import javax.inject.Inject;
@Named
@RequestScoped
public class MonControleur {
@Inject MonModele modele;
package controllers
import play.api._
import play.api.mvc._
import play.api.libs._
import play.api.libs.iteratee._
import play.api.libs.concurrent.Promise
import java.util.concurrent.TimeUnit
import scala.concurrent.stm._
@Path("index")
@Stateless
public class App {
@Inject IndexTemplate index;
@GET @Produces(MediaType.TEXT_HTML)
public IndexTemplate index() {
return index.title("Tasks").addTasks(Task.all);
}
flow {
println "\nTriggered by ${cause.build}\n"
a = build("Job1")
b = build("Job2", param1: "troulala", param2: "machin")
c = build("Job3")
println "\n${a.result()} ${b.result()} ${c.result()}\n"
par = parallel {
String myValue = "loser";
Field f = MyClass.class.getDeclaredField("jerem");
f.setAccessible(true);
f.set(null, myValue);
public static abstract class Option<T> implements Iterable<T>, Serializable {
public abstract boolean isDefined();
public abstract boolean isEmpty();
public abstract T get();
public Option<T> orElse(T value) {
return isEmpty() ? Option.maybe(value) : this;
public class AOPConfig {
public void configure(@Observes AOPConfigEvent config) {
config.add( intercept(Service.class).onAllMethodsReturning(String.class) );
}
}
public void intercept(@Observes @Return(String.class)
@MethodName("doSomething")
@MethodAnnotated(CutHere.class) Before before) {
public class Application extends Controller {
@Inject static MyBean myBean;
public static void index() {
myBean.currentUserId = session.get("id");
DataFromSomewhere data = myBean.getData();
render(data);
}
}
@Inject @To(actor=Master.class) ActorEvent<Calculate> master;
master.fire(new Calculate(4, 10000, 10000));
@ActorConfig("master") @ApplicationScoped
public static class Master extends CDIActor {
public void listenCalculate(@Observes Calculate message) {
...
}
val scn = scenario("Standard User").loop(
.exec(
http("Getting issues")
.get("https://github.com/excilys/gatling/issues")
.queryParam("milestone", "1")
.queryParam("state", "open")
)
).times(5).pause(0, 100, MILLISECONDS)
runSimulation(