mattbennett

=INFO REPORT==== 18-Aug-2014::15:37:16 ===
Adding vhost 'nameko'

=INFO REPORT==== 18-Aug-2014::15:37:16 ===
Setting permissions for 'guest' in 'nameko' to '.*', '.*', '.*'

=INFO REPORT==== 18-Aug-2014::15:37:16 ===
accepting AMQP connection <0.9149.0> (127.0.0.1:41142 -> 127.0.0.1:5672)

=INFO REPORT==== 18-Aug-2014::15:37:16 ===

mattbennett

=INFO REPORT==== 18-Aug-2014::16:12:24 ===
Adding vhost 'nameko'

=INFO REPORT==== 18-Aug-2014::16:12:24 ===
Setting permissions for 'guest' in 'nameko' to '.*', '.*', '.*'

=INFO REPORT==== 18-Aug-2014::16:12:25 ===
accepting AMQP connection <0.2181.1> (127.0.0.1:43102 -> 127.0.0.1:5672)

=INFO REPORT==== 18-Aug-2014::16:12:25 ===

mattbennett

=INFO REPORT==== 18-Aug-2014::18:09:20 ===
Deleting vhost 'nameko'

=INFO REPORT==== 18-Aug-2014::18:09:21 ===
Adding vhost 'nameko'

=INFO REPORT==== 18-Aug-2014::18:09:21 ===
Setting permissions for 'guest' in 'nameko' to '.*', '.*', '.*'

=INFO REPORT==== 18-Aug-2014::18:09:21 ===

mattbennett

amqp://shrqdjyp:zIP80Nq3s2M2nwpbSej0YQGipMgMqZsw@lemur.cloudamqp.com/shrqdjyp

username: shrqdjyp
password: zIP80Nq3s2M2nwpbSej0YQGipMgMqZsw

--

mattbennett

import eventlet
eventlet.monkey_patch()

from eventlet.greenpool import GreenPile
from kombu.pools import producers
from kombu import Exchange, Queue

exchange = Exchange('exchange', type='direct')
queue = Queue('queue', exchange, routing_key='queue')

mattbennett

import eventlet
eventlet.monkey_patch()

from kombu import Exchange, Queue
from kombu.messaging import Consumer

exchange = Exchange('exchange', type='direct')
queue = Queue('queue', exchange, routing_key='queue')

if __name__ == '__main__':

mattbennett

def foo():
    print "foo"

def bar():
    print "bar"

mattbennett

import sys


def foo():
    bar()


def bar():
    baz()

mattbennett

from nameko.extensions import DependencyProvider

class Config(DependencyProvider):

    def get_dependency(self, worker_ctx):
        return self.container.config.copy()

mattbennett

[run]
branch = True
source = .