Did I find the right examples for you? yes no

All Samples(34)  |  Call(30)  |  Derive(0)  |  Import(4)

src/t/r/treeherder-service-HEAD/vendor/mozillapulse/publishers.py   treeherder-service(Download)
from carrot.connection import BrokerConnection
from carrot.messaging import Publisher
 
from config import PulseConfiguration
from utils import *
    def __init__(self, **kwargs):
        super(PulseTestPublisher, self).__init__(PulseConfiguration(**kwargs), 'org.mozilla.exchange.pulse.test')
 
class PulseMetaPublisher(GenericPublisher):
 
    def __init__(self, **kwargs):
        super(PulseMetaPublisher, self).__init__(PulseConfiguration(**kwargs), 'org.mozilla.exchange.pulse')
    def __init__(self, **kwargs):
        super(BugzillaPublisher, self).__init__(PulseConfiguration(**kwargs), 'org.mozilla.exchange.bugzilla')
 
class CodePublisher(GenericPublisher):
 
    def __init__(self, **kwargs):
        super(CodePublisher, self).__init__(PulseConfiguration(**kwargs), 'org.mozilla.exchange.code')

src/m/o/MozillaPulse-0.91/mozillapulse/publishers.py   MozillaPulse(Download)
from pytz import timezone
 
from config import PulseConfiguration
from utils import *
 
    def __init__(self, **kwargs):
        super(PulseTestPublisher, self).__init__(PulseConfiguration(**kwargs), 'org.mozilla.exchange.pulse.test')
 
 
class PulseMetaPublisher(GenericPublisher):
 
    def __init__(self, **kwargs):
        super(PulseMetaPublisher, self).__init__(PulseConfiguration(**kwargs), 'org.mozilla.exchange.pulse')
    def __init__(self, **kwargs):
        super(BugzillaPublisher, self).__init__(PulseConfiguration(**kwargs), 'org.mozilla.exchange.bugzilla')
 
 
class SimpleBugzillaPublisher(GenericPublisher):
            exchange += '.dev'
        super(SimpleBugzillaPublisher, self).__init__(
            PulseConfiguration(**kwargs), exchange)
 
 

src/t/r/treeherder-service-HEAD/vendor/mozillapulse/consumers.py   treeherder-service(Download)
from carrot.connection import BrokerConnection
from carrot.messaging import Consumer
 
from config import PulseConfiguration
from utils import *
    def __init__(self, **kwargs):
        super(PulseTestConsumer, self).__init__(PulseConfiguration(**kwargs), 'org.mozilla.exchange.pulse.test', **kwargs)
 
class PulseMetaConsumer(GenericConsumer):
 
    def __init__(self, **kwargs):
        super(PulseMetaConsumer, self).__init__(PulseConfiguration(**kwargs), 'org.mozilla.exchange.pulse', **kwargs)
    def __init__(self, **kwargs):
        super(BugzillaConsumer, self).__init__(PulseConfiguration(**kwargs), 'org.mozilla.exchange.bugzilla', **kwargs)
 
class CodeConsumer(GenericConsumer):
 
    def __init__(self, **kwargs):
        super(CodeConsumer, self).__init__(PulseConfiguration(**kwargs), 'org.mozilla.exchange.code', **kwargs)

src/m/o/MozillaPulse-0.91/mozillapulse/consumers.py   MozillaPulse(Download)
from kombu import Connection, Exchange, Queue
 
from config import PulseConfiguration
from utils import *
 
    def __init__(self, **kwargs):
        super(PulseTestConsumer, self).__init__(PulseConfiguration(**kwargs), 'org.mozilla.exchange.pulse.test', **kwargs)
 
 
class PulseMetaConsumer(GenericConsumer):
 
    def __init__(self, **kwargs):
        super(PulseMetaConsumer, self).__init__(PulseConfiguration(**kwargs), 'org.mozilla.exchange.pulse', **kwargs)
    def __init__(self, **kwargs):
        super(BugzillaConsumer, self).__init__(PulseConfiguration(**kwargs), 'org.mozilla.exchange.bugzilla', **kwargs)
 
 
class SimpleBugzillaConsumer(GenericConsumer):
            exchange += '.dev'
        super(SimpleBugzillaConsumer, self).__init__(PulseConfiguration(
                **kwargs), exchange, **kwargs)