mreiferson

def send_ready(reader, conn, count):
    if (reader.total_ready_count + count) > reader.max_in_flight:
        return
    
    conn.send_ready(count)
    conn.rdy_count = count
    reader.total_ready_count += count

mreiferson

{
    "max_rdy_count": 2500,
    "version": "0.2.20-alpha"
}

mreiferson

{
    "short_id": "app01",
    "long_id": "app01.bitly.net",
    "heartbeat_interval": 30000,
    "feature_negotiation": true
}

mreiferson

{
    "status_code": 200,
    "status_txt": "OK",
    "data": {
        "channels": ["archive", "science", "metrics"],
        "producers": [
            {
                "broadcast_address": "clicksapi01.routable.domain.net", 
                "hostname": "clicksapi01.domain.net",
                "tcp_port": 4150,

mreiferson

function j {
    local project=$1
    cd `find ~/dev/src -type d -mindepth 3 -maxdepth 3 -name $project`
}

mreiferson

const (
	ModeAll = iota
	ModeRoundRobin
)

type Publisher interface {
	Publish(string, []byte) error
}

type PublishHandler struct {

mreiferson

import nsq

buf = []

def process_message(message):
    global buf
    message.enable_async()
    buf.append(message)
    if len(buf) >= 3:
        for msg in buf:

mreiferson

import nsq

def task1(message):
    print message
    return True

def task2(message):
    print message
    return True