Git Product home page Git Product logo

eventmq's Introduction

EventMQ

CircleCI Coverage Status

Overview

EventMQ is a message passing system built on ZeroMQ

Installation

EventMQ is available on PyPi:

pip install eventmq

Support

Documenation

Documentation

Mailing Lists

User Support: http://lists.eventmq.io/mailman/listinfo/eventmq-users_lists.eventmq.io

Development Discussion: http://lists.eventmq.io/mailman/listinfo/eventmq-devel_lists.eventmq.io

IRC

#eventmq on irc.freenode.net

Quick Start

my_jerbs.py

# Note: this file needs to be importable, so you should put it in your python path somewhere.
from eventmq import job

@job
def say_hello():
    print 'hello'

Terminal 1:

% emq-router
eventmq.utils.settings  WARNING - Config file at /etc/eventmq.conf not found. Continuing with defaults.
eventmq.receiver  INFO - Receiver 83cdb797-8f99-4b06-862c-06f6b6f5f6f6: Listening on tcp://127.0.0.1:47291
eventmq.receiver  INFO - Receiver 8e9b3b83-711c-4736-8efc-2a870e800245: Listening on tcp://127.0.0.1:47290
eventmq.receiver  INFO - Receiver f67d673f-c44a-4380-b289-d88e264af5cd: Listening on tcp://127.0.0.1:47293
eventmq.router  INFO - Listening for requests on tcp://127.0.0.1:47291
eventmq.router  INFO - Listening for workers on tcp://127.0.0.1:47290
eventmq.router  INFO - Listening for administrative commands on tcp://127.0.0.1:47293

Terminal 2

% emq-jobmanager
eventmq.utils.settings  WARNING - Config file at /etc/eventmq.conf not found. Continuing with defaults.
eventmq.utils.settings  WARNING - Config file at /etc/eventmq.conf not found. Continuing with defaults.
eventmq.sender  DEBUG - Connecting to tcp://127.0.0.1:47290
eventmq.utils.classes  INFO - Received ACK for router (or client) 9c7c3d5f-80f6-454a-b308-3231d1ce93b2
eventmq.utils.classes  INFO - Starting event loop...

Terminal 3

% EMQ_BROKER_ADDR=tcp://127.0.0.1:47291 PYTHONPATH=`pwd` python
Python 2.7.12 (default, Sep 29 2016, 13:30:34)
[GCC 6.2.1 20160916 (Red Hat 6.2.1-2)] on linux2
Type "help", "copyright", "credits" or "license" for more information.
>>> from my_jerbs import say_hello
>>> say_hello.delay()
'a69cbbe5-589a-495a-b4bc-fe1645439d39'

You should see "hello" printed in Terminal 2

eventmq's People

Contributors

com4 avatar sideshowdave7 avatar synic avatar unaveed avatar

Watchers

 avatar

Recommend Projects

  • React photo React

    A declarative, efficient, and flexible JavaScript library for building user interfaces.

  • Vue.js photo Vue.js

    ๐Ÿ–– Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.

  • Typescript photo Typescript

    TypeScript is a superset of JavaScript that compiles to clean JavaScript output.

  • TensorFlow photo TensorFlow

    An Open Source Machine Learning Framework for Everyone

  • Django photo Django

    The Web framework for perfectionists with deadlines.

  • D3 photo D3

    Bring data to life with SVG, Canvas and HTML. ๐Ÿ“Š๐Ÿ“ˆ๐ŸŽ‰

Recommend Topics

  • javascript

    JavaScript (JS) is a lightweight interpreted programming language with first-class functions.

  • web

    Some thing interesting about web. New door for the world.

  • server

    A server is a program made to process requests and deliver data to clients.

  • Machine learning

    Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.

  • Game

    Some thing interesting about game, make everyone happy.

Recommend Org

  • Facebook photo Facebook

    We are working to build community through open source technology. NB: members must have two-factor auth.

  • Microsoft photo Microsoft

    Open source projects and samples from Microsoft.

  • Google photo Google

    Google โค๏ธ Open Source for everyone.

  • D3 photo D3

    Data-Driven Documents codes.