Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(18)  |  Call(5)  |  Derive(4)  |  Import(9)

src/c/i/circus-HEAD/examples/listener.py   circus(Download)
from circus.consumer import CircusConsumer
import json
 
 
ZMQ_ENDPOINT = 'tcp://127.0.0.1:5556'
topic = 'show:'
 
for message, message_topic in CircusConsumer(topic, endpoint=ZMQ_ENDPOINT):

src/c/i/circus-0.10.0/examples/listener.py   circus(Download)
from circus.consumer import CircusConsumer
import json
 
 
ZMQ_ENDPOINT = 'tcp://127.0.0.1:5556'
topic = 'show:'
 
for message, message_topic in CircusConsumer(topic, endpoint=ZMQ_ENDPOINT):

src/c/i/circus-HEAD/examples/webclient/bread.py   circus(Download)
import argparse
 
from circus.consumer import CircusConsumer
from flask import Flask, request, render_template
 
 
    topic = topic.encode('ascii')
    for message, message_topic in CircusConsumer(topic, endpoint=ZMQ_ENDPOINT):
        response = json.dumps(dict(message=message, topic=message_topic))
        ws.send(response)

src/c/i/circus-HEAD/circus/circusctl.py   circus(Download)
from circus.client import CircusClient
from circus.commands import get_commands
from circus.consumer import CircusConsumer
from circus.exc import CallError, ArgumentError
from circus.util import DEFAULT_ENDPOINT_SUB, DEFAULT_ENDPOINT_DEALER
    def handle_sub(self, command, opts, topics, endpoint, timeout, ssh_server,
                   ssh_keyfile):
        consumer = CircusConsumer(topics, endpoint=endpoint)
        for topic, msg in consumer:
            print("%s: %s" % (topic, msg))

src/c/i/circus-0.10.0/circus/circusctl.py   circus(Download)
from circus.client import CircusClient
from circus.commands import get_commands
from circus.consumer import CircusConsumer
from circus.exc import CallError, ArgumentError
from circus.util import DEFAULT_ENDPOINT_SUB, DEFAULT_ENDPOINT_DEALER
    def handle_sub(self, cmd, opts, topics, endpoint, timeout, ssh_server,
                   ssh_keyfile):
        consumer = CircusConsumer(topics, endpoint=endpoint)
        for topic, msg in consumer:
            print("%s: %s" % (topic, msg))

src/c/i/circus-HEAD/circus/stats/client.py   circus(Download)
import zmq.utils.jsonapi as json
 
from circus.consumer import CircusConsumer
from circus import __version__
from circus.util import DEFAULT_ENDPOINT_STATS
from circus.py3compat import s
 
 
class StatsClient(CircusConsumer):

src/c/i/circus-HEAD/circus/green/consumer.py   circus(Download)
from circus.consumer import CircusConsumer as _CircusConsumer
 
from zmq.green import Context, Poller, POLLIN
 
 
class CircusConsumer(_CircusConsumer):

src/c/i/circus-0.10.0/circus/stats/client.py   circus(Download)
from zmq.utils.strtypes import u
 
from circus.consumer import CircusConsumer
from circus import __version__
from circus.util import DEFAULT_ENDPOINT_STATS
 
 
class StatsClient(CircusConsumer):

src/c/i/circus-0.10.0/circus/green/consumer.py   circus(Download)
from circus.consumer import CircusConsumer as _CircusConsumer
 
from zmq.green import Context, Poller, POLLIN
 
 
class CircusConsumer(_CircusConsumer):