He-Pin

Step by step guide to setting up IDEA to write gatling simulations

Prerequisites:

Have [SBT plugin][sbt-plugin] installed

Begin

• [Create a new project][create-project] in IDEA ( File > New Project ...)
  • Make sure you select a maven module

He-Pin

import java.lang.Math.*;

public class Progressbar {
  private int max;
  private int current;
  private String name;
  private long start;
  private long lastUpdate;

  public Progressbar(int max, String name)

He-Pin

import sbt._
import Keys._

object Build extends sbt.Build {

    val unmanagedJars = TaskKey[Keys.Classpath]("unmanaged-jars")
    unmanagedJars := {
        Configuration.listUnmanaged( file(".").getAbsoluteFile )
    }

He-Pin

package app.actors

import akka.event.Logging
import akka.http.scaladsl._
import akka.http.scaladsl.model.HttpHeader.ParsingResult
import akka.http.scaladsl.model._
import akka.stream.ActorMaterializer
import akka.typed.ScalaDSL._
import akka.typed._
import argonaut.Argonaut._

He-Pin

package app.actors

import akka.actor.{Actor, ActorLogging}
import argonaut._, Argonaut._
import infrastructure.GCM
import launch.RTConfig
import spray.client.pipelining._
import spray.http._
import spray.httpx.marshalling.Marshaller

He-Pin

package us.sosia.net.udt;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Iterator;

He-Pin

package us.sosia.net.udt.channel;

import java.io.IOException;
import java.net.SocketAddress;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

He-Pin

  public void write(ByteBuffer data){
		if (data == null) {
			return;
		}
 		writeBuffers.offer(data);
		//start an notify
		writer.execute(new Runnable() {
			
			@Override
			public void run() {

He-Pin

package us.sosia.media.webcam;

import java.awt.image.BufferedImage;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

He-Pin

package us.sosia.media.ui;

import java.awt.BasicStroke;
import java.awt.Color;
import java.awt.FontMetrics;
import java.awt.Graphics;
import java.awt.Graphics2D;
import java.awt.RenderingHints;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;