p-lewis

from __future__ import print_function
import sqlalchemy as sa
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker

engine = sa.create_engine('sqlite:///:memory:', echo=True)

Base = declarative_base()

p-lewis

from datetime import timedelta
from django.conf import settings
from django.db import models
from django.utils import timezone


class ActiveMessagesManager(models.Manager):
    use_for_related_fields = True

    def get_queryset(self):

p-lewis

var uuid  = require("node-uuid");

// Create a message to be consumed by the queuedemo.tasks.add Celery task
// will incorporate arguments x & y as part of `add(x,y)` message
function makeCeleryAddMessage(x, y){
  
  var msgId = uuid.v4();
  
  // This is the outer AMQP envelope
  var msgEnvelope = {