carimura

var worker = require("iron_worker");

var client = new worker.Client({"project_id": "my project ID", "token": "my token"});

client.tasksCreate("myWorker", "payload", {"timeout": 60}, function(error, response) {
    // callback for when the task has been posted, with the response
});

carimura

{
  "production": {
    "token": "aaaaa",
    "project_id": "bbbbbb"
  },
  "staging": {
    "token": "ccccc",
    "project_id": "ddddd"
  },
  "development": {

carimura

require 'rest-client'
require 'json'
require 'iron_mq'

license_key = 'my_key'

queue = ironmq.queue("some_active_queue")

size = queue.size

carimura

require 'sinatra'
require 'iron_mq'

def get_client
  # Set these to your IronMQ credentials
  config = {
    token: '',
    project_id: ''
  }
  @ironmq = IronMQ::Client.new(token: config[:token], project_id: config[:project_id])

carimura

from celery import Celery
import iron_celery
 
celery = Celery('tasks', 
                broker='ironmq://{iron_project_id}:{iron_token}@'
                backend='ironcache://{iron_project_id}:{iron_token}@')
 
@celery.task
def add(x, y):
    return x + y

carimura

from celery import Celery
import iron_celery

celery = Celery('tasks', 
                broker='ironmq://{iron_project_id}:{iron_token}@')

@celery.task
def add(x, y):
    return x + y

carimura

from celery import Celery
import iron_celery

celery = Celery('tasks', broker='amqp://guest@localhost//')

@celery.task
def add(x, y):
    return x + y

carimura

from tasks import add
import time

start=time.time()
for i in range(1000):
  add.delay(1,i)
  print "queued job %x" % (i)

print "finished in %x seconds" % (time.time() - start)

carimura

puts "Starting HelloWorker at #{Time.now}"

puts `curl http://ec2-184-72-163-60.compute-1.amazonaws.com --connect-timeout 10`

puts "done"

carimura

# Scheduling a task to be queued at a specific time (eg. 1 hour from now)
schedule = client.schedules.create('MyWorker', payload,
                                   {:start_at => Time.now + 3600})

# Running a task repeatedly (eg. every hour)
schedule = client.schedules.create('MyWorker', payload, 
                                   {:run_every => 3600})

# Scheduling a task to run until a certain time (eg. run 3 hours then stop)
schedule = client.schedules.create('MyWorker', payload,