Hisham Mardam-Bey mardambey

## LimitedOutputStream.scala
import java.io.{FilterOutputStream, IOException, OutputStream}

class LimitedOutputStream(out: OutputStream , maxBytes: Long) extends FilterOutputStream(out) {

  private var bytesWritten: Long = 0L

  @throws(classOf[IOException])
  override def write(b: Int) {
    ensureCapacity(1)
    super.write(b)

## fb-upload.html

<html>
<head>
<script src="https://code.jquery.com/jquery-2.1.4.min.js"></script>
</head>
<body>
<form>
	<input type="file" accept="image/*" id="capture" capture="camera">
	<img id="blah" src="#" alt="your image"/>
</form>

## JedisSentinelPoolRunner.java
package redis.clients.jedis;

import java.util.HashSet;
import java.util.Set;
import java.util.logging.Logger;

public class JedisSentinelPoolRunner {

	private static Logger log = Logger.getLogger(JedisSentinelPoolRunner.class.getName());


## Crypto.scala
import javax.crypto.spec.SecretKeySpec
import javax.crypto.Cipher
import javax.crypto.spec.IvParameterSpec
import java.math.BigInteger
import javax.crypto.SecretKeyFactory
import java.security.MessageDigest
import javax.xml.bind.DatatypeConverter._

object Crypto extends App {


## mod_log_remote.erl
%%
%% mod_log_remote is a simple Ejabberd module and gen_server that
%% allow for remote logging. It uses the filter_packet hook to
%% intercept <message> stanzas addressed to logger@vhost. These
%% messages are beamed off to the configured Erland node / pid in
%% the form:
%%
%% {Type, LogTime, Payload}
%%
%% where Type and Payload are specified by the caller and LogTime is

## ConsistentHashRouter.scala

object ConsistentHashRouter {
  /**
   * Creates a new ConsistentHashRouter, routing to the specified routees
   */
  def apply(routees: Iterable[ActorRef]): ConsistentHashRouter =
    new ConsistentHashRouter(routees = routees map (_.path.toString))
}

case class ConsistentHashRouter(

## AsyncValue.scala
import scala.actors.Actor

case class Set(value:Any)
case class Get()
case class Destroy()

/*
 * An actor wrapping an object of type T providing async get/set
 * calls without blocking (sacrificing accuracy).
 *

## gist:2654382

/**
 * Notes: This code uses AsyncValue[T], a custom class that uses actors
 * to allow concurrent operations on the provided type. It can be replaced
 * by an Atomic object from the java.util.concurrent package or something
 * that provides similar functionality.
 */

/**
 * Resets the offsets for the given group / topic pair.

## KafkaEmbedded.scala
import java.util.Properties
import kafka.server.KafkaServer
import kafka.server.KafkaConfig
import kafka.producer.ProducerConfig
import kafka.producer.Producer
import kafka.message.Message
import kafka.producer.ProducerData
import kafka.consumer.ConsumerConfig
import kafka.consumer.Consumer
import kafka.utils.Utils

## AkkaKafkaMailboxTest.scala
import akka.actor.Actor
import akka.actor.ActorSystem
import akka.agent.Agent
import com.typesafe.config.ConfigFactory
import akka.event.Logging
import akka.actor.Props
import kafka.utils.Utils
import java.nio.ByteBuffer
	import java.io.{FilterOutputStream, IOException, OutputStream}

	class LimitedOutputStream(out: OutputStream , maxBytes: Long) extends FilterOutputStream(out) {

	private var bytesWritten: Long = 0L

	@throws(classOf[IOException])
	override def write(b: Int) {
	ensureCapacity(1)
	super.write(b)

	<html>
	<head>
	<script src="https://code.jquery.com/jquery-2.1.4.min.js"></script>
	</head>
	<body>
	<form>
	<input type="file" accept="image/*" id="capture" capture="camera">
	<img id="blah" src="#" alt="your image"/>
	</form>
	package redis.clients.jedis;

	import java.util.HashSet;
	import java.util.Set;
	import java.util.logging.Logger;

	public class JedisSentinelPoolRunner {

	private static Logger log = Logger.getLogger(JedisSentinelPoolRunner.class.getName());
	import javax.crypto.spec.SecretKeySpec
	import javax.crypto.Cipher
	import javax.crypto.spec.IvParameterSpec
	import java.math.BigInteger
	import javax.crypto.SecretKeyFactory
	import java.security.MessageDigest
	import javax.xml.bind.DatatypeConverter._

	object Crypto extends App {
	%%
	%% mod_log_remote is a simple Ejabberd module and gen_server that
	%% allow for remote logging. It uses the filter_packet hook to
	%% intercept <message> stanzas addressed to logger@vhost. These
	%% messages are beamed off to the configured Erland node / pid in
	%% the form:
	%%
	%% {Type, LogTime, Payload}
	%%
	%% where Type and Payload are specified by the caller and LogTime is

	object ConsistentHashRouter {
	/**
	* Creates a new ConsistentHashRouter, routing to the specified routees
	*/
	def apply(routees: Iterable[ActorRef]): ConsistentHashRouter =
	new ConsistentHashRouter(routees = routees map (_.path.toString))
	}

	case class ConsistentHashRouter(
	import scala.actors.Actor

	case class Set(value:Any)
	case class Get()
	case class Destroy()

	/*
	* An actor wrapping an object of type T providing async get/set
	* calls without blocking (sacrificing accuracy).
	*

	/**
	* Notes: This code uses AsyncValue[T], a custom class that uses actors
	* to allow concurrent operations on the provided type. It can be replaced
	* by an Atomic object from the java.util.concurrent package or something
	* that provides similar functionality.
	*/

	/**
	* Resets the offsets for the given group / topic pair.
	import java.util.Properties
	import kafka.server.KafkaServer
	import kafka.server.KafkaConfig
	import kafka.producer.ProducerConfig
	import kafka.producer.Producer
	import kafka.message.Message
	import kafka.producer.ProducerData
	import kafka.consumer.ConsumerConfig
	import kafka.consumer.Consumer
	import kafka.utils.Utils
	import akka.actor.Actor
	import akka.actor.ActorSystem
	import akka.agent.Agent
	import com.typesafe.config.ConfigFactory
	import akka.event.Logging
	import akka.actor.Props
	import kafka.utils.Utils
	import java.nio.ByteBuffer