aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat
-rw-r--r--_sources/client/jobs.txt3
-rw-r--r--_sources/settings_file.txt6
-rw-r--r--_sources/using.txt6
-rw-r--r--api.html9
-rw-r--r--client.html6
-rw-r--r--client/jobs.html287
-rw-r--r--client/messages.html9
-rw-r--r--contributing.html4
-rw-r--r--exceptions.html8
-rw-r--r--genindex.html36
-rw-r--r--index.html7
-rw-r--r--jobmanager.html4
-rw-r--r--objects.invbin1437 -> 1468 bytes
-rw-r--r--poller.html4
-rw-r--r--protocol.html4
-rw-r--r--py-modindex.html9
-rw-r--r--receiver.html4
-rw-r--r--router.html4
-rw-r--r--search.html4
-rw-r--r--searchindex.js2
-rw-r--r--sender.html4
-rw-r--r--settings_file.html15
-rw-r--r--using.html17
-rw-r--r--utils/classes.html4
-rw-r--r--utils/devices.html4
-rw-r--r--utils/index.html4
-rw-r--r--utils/messages.html4
-rw-r--r--utils/settings.html4
-rw-r--r--utils/timeutils.html4
29 files changed, 404 insertions, 72 deletions
diff --git a/_sources/client/jobs.txt b/_sources/client/jobs.txt
new file mode 100644
index 0000000..a4acb3b
--- /dev/null
+++ b/_sources/client/jobs.txt
@@ -0,0 +1,3 @@
1.. automodule:: eventmq.client.jobs
2 :members:
3 :special-members:
diff --git a/_sources/settings_file.txt b/_sources/settings_file.txt
index b0bc36c..cd37b6a 100644
--- a/_sources/settings_file.txt
+++ b/_sources/settings_file.txt
@@ -1,6 +1,6 @@
1######## 1##############################
2Settings 2Server Settings (eventmq.conf)
3######## 3##############################
4EventMQ uses a standard INI style config file found at ``/etc/eventmq.conf``. 4EventMQ uses a standard INI style config file found at ``/etc/eventmq.conf``.
5 5
6****** 6******
diff --git a/_sources/using.txt b/_sources/using.txt
index 3c6a517..4e5ee10 100644
--- a/_sources/using.txt
+++ b/_sources/using.txt
@@ -6,3 +6,9 @@ Using EventMQ
6 :maxdepth: 2 6 :maxdepth: 2
7 7
8 settings_file 8 settings_file
9
10****************************
11Client Environment Variables
12****************************
13
14``EMQ_BROKER_ADDR`` is the address a client should use to connect to the broker. The client can be any application using EventMQ.
diff --git a/api.html b/api.html
index 073f1a6..f7e62d8 100644
--- a/api.html
+++ b/api.html
@@ -32,7 +32,7 @@
32 32
33 <link rel="top" title="EventMQ 0 documentation" href="index.html"/> 33 <link rel="top" title="EventMQ 0 documentation" href="index.html"/>
34 <link rel="next" title="client – Client Utilities" href="client.html"/> 34 <link rel="next" title="client – Client Utilities" href="client.html"/>
35 <link rel="prev" title="Settings" href="settings_file.html"/> 35 <link rel="prev" title="Server Settings (eventmq.conf)" href="settings_file.html"/>
36 36
37 37
38 <script src="_static/js/modernizr.min.js"></script> 38 <script src="_static/js/modernizr.min.js"></script>
@@ -60,7 +60,7 @@
60 60
61 61
62 <div class="version"> 62 <div class="version">
63 0.2.7 63 0.2.7.1
64 </div> 64 </div>
65 65
66 66
@@ -145,6 +145,7 @@
145<ul> 145<ul>
146<li class="toctree-l1"><a class="reference internal" href="client.html"><code class="docutils literal"><span class="pre">client</span></code> &#8211; Client Utilities</a><ul> 146<li class="toctree-l1"><a class="reference internal" href="client.html"><code class="docutils literal"><span class="pre">client</span></code> &#8211; Client Utilities</a><ul>
147<li class="toctree-l2"><a class="reference internal" href="client/messages.html"><code class="docutils literal"><span class="pre">messages</span></code> &#8211; Client Messaging</a></li> 147<li class="toctree-l2"><a class="reference internal" href="client/messages.html"><code class="docutils literal"><span class="pre">messages</span></code> &#8211; Client Messaging</a></li>
148<li class="toctree-l2"><a class="reference internal" href="client/jobs.html"><code class="docutils literal"><span class="pre">jobs</span></code> &#8211; Client Job Helpers</a></li>
148</ul> 149</ul>
149</li> 150</li>
150<li class="toctree-l1"><a class="reference internal" href="exceptions.html"><code class="docutils literal"><span class="pre">exceptions</span></code> &#8211; Exceptions</a></li> 151<li class="toctree-l1"><a class="reference internal" href="exceptions.html"><code class="docutils literal"><span class="pre">exceptions</span></code> &#8211; Exceptions</a></li>
@@ -175,7 +176,7 @@
175 <a href="client.html" class="btn btn-neutral float-right" title="client – Client Utilities" accesskey="n">Next <span class="fa fa-arrow-circle-right"></span></a> 176 <a href="client.html" class="btn btn-neutral float-right" title="client – Client Utilities" accesskey="n">Next <span class="fa fa-arrow-circle-right"></span></a>
176 177
177 178
178 <a href="settings_file.html" class="btn btn-neutral" title="Settings" accesskey="p"><span class="fa fa-arrow-circle-left"></span> Previous</a> 179 <a href="settings_file.html" class="btn btn-neutral" title="Server Settings (eventmq.conf)" accesskey="p"><span class="fa fa-arrow-circle-left"></span> Previous</a>
179 180
180 </div> 181 </div>
181 182
@@ -184,7 +185,7 @@
184 185
185 <div role="contentinfo"> 186 <div role="contentinfo">
186 <p> 187 <p>
187 &copy; Copyright 2016, eventboard.io. 188 &copy; Copyright 2016, EventMQ Contributors.
188 189
189 </p> 190 </p>
190 </div> 191 </div>
diff --git a/client.html b/client.html
index aef623b..0a1b7c2 100644
--- a/client.html
+++ b/client.html
@@ -61,7 +61,7 @@
61 61
62 62
63 <div class="version"> 63 <div class="version">
64 0.2.7 64 0.2.7.1
65 </div> 65 </div>
66 66
67 67
@@ -87,6 +87,7 @@
87<li class="toctree-l1 current"><a class="reference internal" href="api.html">API Documentation</a><ul class="current"> 87<li class="toctree-l1 current"><a class="reference internal" href="api.html">API Documentation</a><ul class="current">
88<li class="toctree-l2 current"><a class="current reference internal" href=""><code class="docutils literal"><span class="pre">client</span></code> &#8211; Client Utilities</a><ul> 88<li class="toctree-l2 current"><a class="current reference internal" href=""><code class="docutils literal"><span class="pre">client</span></code> &#8211; Client Utilities</a><ul>
89<li class="toctree-l3"><a class="reference internal" href="client/messages.html"><code class="docutils literal"><span class="pre">messages</span></code> &#8211; Client Messaging</a></li> 89<li class="toctree-l3"><a class="reference internal" href="client/messages.html"><code class="docutils literal"><span class="pre">messages</span></code> &#8211; Client Messaging</a></li>
90<li class="toctree-l3"><a class="reference internal" href="client/jobs.html"><code class="docutils literal"><span class="pre">jobs</span></code> &#8211; Client Job Helpers</a></li>
90</ul> 91</ul>
91</li> 92</li>
92<li class="toctree-l2"><a class="reference internal" href="exceptions.html"><code class="docutils literal"><span class="pre">exceptions</span></code> &#8211; Exceptions</a></li> 93<li class="toctree-l2"><a class="reference internal" href="exceptions.html"><code class="docutils literal"><span class="pre">exceptions</span></code> &#8211; Exceptions</a></li>
@@ -152,6 +153,7 @@ eventmq. (e.g. one who requests jobs)</p>
152<div class="toctree-wrapper compound"> 153<div class="toctree-wrapper compound">
153<ul> 154<ul>
154<li class="toctree-l1"><a class="reference internal" href="client/messages.html"><code class="docutils literal"><span class="pre">messages</span></code> &#8211; Client Messaging</a></li> 155<li class="toctree-l1"><a class="reference internal" href="client/messages.html"><code class="docutils literal"><span class="pre">messages</span></code> &#8211; Client Messaging</a></li>
156<li class="toctree-l1"><a class="reference internal" href="client/jobs.html"><code class="docutils literal"><span class="pre">jobs</span></code> &#8211; Client Job Helpers</a></li>
155</ul> 157</ul>
156</div> 158</div>
157</div> 159</div>
@@ -175,7 +177,7 @@ eventmq. (e.g. one who requests jobs)</p>
175 177
176 <div role="contentinfo"> 178 <div role="contentinfo">
177 <p> 179 <p>
178 &copy; Copyright 2016, eventboard.io. 180 &copy; Copyright 2016, EventMQ Contributors.
179 181
180 </p> 182 </p>
181 </div> 183 </div>
diff --git a/client/jobs.html b/client/jobs.html
new file mode 100644
index 0000000..1cf76bf
--- /dev/null
+++ b/client/jobs.html
@@ -0,0 +1,287 @@
1
2
3<!DOCTYPE html>
4<!--[if IE 8]><html class="no-js lt-ie9" lang="en" > <![endif]-->
5<!--[if gt IE 8]><!--> <html class="no-js" lang="en" > <!--<![endif]-->
6<head>
7 <meta charset="utf-8">
8
9 <meta name="viewport" content="width=device-width, initial-scale=1.0">
10
11 <title>jobs – Client Job Helpers &mdash; EventMQ 0 documentation</title>
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27 <link rel="stylesheet" href="../_static/css/theme.css" type="text/css" />
28
29
30
31
32
33 <link rel="top" title="EventMQ 0 documentation" href="../index.html"/>
34 <link rel="up" title="client – Client Utilities" href="../client.html"/>
35 <link rel="next" title="exceptions – Exceptions" href="../exceptions.html"/>
36 <link rel="prev" title="messages – Client Messaging" href="messages.html"/>
37
38
39 <script src="../_static/js/modernizr.min.js"></script>
40
41</head>
42
43<body class="wy-body-for-nav" role="document">
44
45 <div class="wy-grid-for-nav">
46
47
48 <nav data-toggle="wy-nav-shift" class="wy-nav-side">
49 <div class="wy-side-scroll">
50 <div class="wy-side-nav-search">
51
52
53
54 <a href="../index.html" class="icon icon-home"> EventMQ
55
56
57
58 </a>
59
60
61
62
63 <div class="version">
64 0.2.7.1
65 </div>
66
67
68
69
70<div role="search">
71 <form id="rtd-search-form" class="wy-form" action="../search.html" method="get">
72 <input type="text" name="q" placeholder="Search docs" />
73 <input type="hidden" name="check_keywords" value="yes" />
74 <input type="hidden" name="area" value="default" />
75 </form>
76</div>
77
78
79 </div>
80
81 <div class="wy-menu wy-menu-vertical" data-spy="affix" role="navigation" aria-label="main navigation">
82
83
84
85 <ul class="current">
86<li class="toctree-l1"><a class="reference internal" href="../using.html">Using EventMQ</a></li>
87<li class="toctree-l1 current"><a class="reference internal" href="../api.html">API Documentation</a><ul class="current">
88<li class="toctree-l2 current"><a class="reference internal" href="../client.html"><code class="docutils literal"><span class="pre">client</span></code> &#8211; Client Utilities</a><ul class="current">
89<li class="toctree-l3"><a class="reference internal" href="messages.html"><code class="docutils literal"><span class="pre">messages</span></code> &#8211; Client Messaging</a></li>
90<li class="toctree-l3 current"><a class="current reference internal" href=""><code class="docutils literal"><span class="pre">jobs</span></code> &#8211; Client Job Helpers</a></li>
91</ul>
92</li>
93<li class="toctree-l2"><a class="reference internal" href="../exceptions.html"><code class="docutils literal"><span class="pre">exceptions</span></code> &#8211; Exceptions</a></li>
94<li class="toctree-l2"><a class="reference internal" href="../jobmanager.html"><code class="docutils literal"><span class="pre">jobmanager</span></code> &#8211; Job Manager</a></li>
95<li class="toctree-l2"><a class="reference internal" href="../poller.html"><code class="docutils literal"><span class="pre">poller</span></code> &#8211; Poller</a></li>
96<li class="toctree-l2"><a class="reference internal" href="../receiver.html"><code class="docutils literal"><span class="pre">receiver</span></code> &#8211; Receiver</a></li>
97<li class="toctree-l2"><a class="reference internal" href="../router.html"><code class="docutils literal"><span class="pre">router</span></code> &#8211; Router</a></li>
98<li class="toctree-l2"><a class="reference internal" href="../sender.html"><code class="docutils literal"><span class="pre">sender</span></code> &#8211; Sender</a></li>
99<li class="toctree-l2"><a class="reference internal" href="../utils/index.html"><code class="docutils literal"><span class="pre">utils</span></code> &#8211; Utilities</a></li>
100</ul>
101</li>
102<li class="toctree-l1"><a class="reference internal" href="../contributing.html">Contributing to EventMQ</a></li>
103</ul>
104
105
106
107 </div>
108 </div>
109 </nav>
110
111 <section data-toggle="wy-nav-shift" class="wy-nav-content-wrap">
112
113
114 <nav class="wy-nav-top" role="navigation" aria-label="top navigation">
115 <i data-toggle="wy-nav-top" class="fa fa-bars"></i>
116 <a href="../index.html">EventMQ</a>
117 </nav>
118
119
120
121 <div class="wy-nav-content">
122 <div class="rst-content">
123
124
125
126
127
128
129<div role="navigation" aria-label="breadcrumbs navigation">
130 <ul class="wy-breadcrumbs">
131 <li><a href="../index.html">Docs</a> &raquo;</li>
132
133 <li><a href="../api.html">API Documentation</a> &raquo;</li>
134
135 <li><a href="../client.html"><code class="docutils literal"><span class="pre">client</span></code> &#8211; Client Utilities</a> &raquo;</li>
136
137 <li><code class="docutils literal"><span class="pre">jobs</span></code> &#8211; Client Job Helpers</li>
138 <li class="wy-breadcrumbs-aside">
139
140
141 <a href="../_sources/client/jobs.txt" rel="nofollow"> View page source</a>
142
143
144 </li>
145 </ul>
146 <hr/>
147</div>
148 <div role="main" class="document" itemscope="itemscope" itemtype="http://schema.org/Article">
149 <div itemprop="articleBody">
150
151 <span class="target" id="module-eventmq.client.jobs"></span><div class="section" id="jobs-client-job-helpers">
152<h1><code class="xref py py-mod docutils literal"><span class="pre">jobs</span></code> &#8211; Client Job Helpers<a class="headerlink" href="#jobs-client-job-helpers" title="Permalink to this headline">¶</a></h1>
153<dl class="class">
154<dt id="eventmq.client.jobs.Job">
155<em class="property">class </em><code class="descclassname">eventmq.client.jobs.</code><code class="descname">Job</code><span class="sig-paren">(</span><em>broker_addr=None</em>, <em>queue=None</em>, <em>async=True</em>, <em>*args</em>, <em>**kwargs</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.client.jobs.Job" title="Permalink to this definition">¶</a></dt>
156<dd><p>Defines a deferred EventMQ job.</p>
157<p>Usage:</p>
158<div class="highlight-python"><div class="highlight"><pre><span></span><span class="kn">from</span> <span class="nn">eventmq</span> <span class="kn">import</span> <span class="n">job</span>
159
160<span class="nd">@job</span><span class="p">(</span><span class="n">queue</span><span class="o">=</span><span class="s1">&#39;messaging&#39;</span><span class="p">)</span>
161<span class="k">def</span> <span class="nf">send_email</span><span class="p">(</span><span class="n">recipient</span><span class="p">,</span> <span class="n">subject</span><span class="p">,</span> <span class="n">message</span><span class="p">):</span>
162 <span class="kn">from</span> <span class="nn">email.mime.text</span> <span class="kn">import</span> <span class="n">MIMEText</span>
163 <span class="kn">import</span> <span class="nn">smtplib</span>
164
165 <span class="n">msg</span> <span class="o">=</span> <span class="n">MIMEText</span><span class="p">(</span><span class="n">message</span><span class="p">)</span>
166 <span class="n">msg</span><span class="p">[</span><span class="s1">&#39;Subject&#39;</span><span class="p">]</span> <span class="o">=</span> <span class="n">subject</span>
167 <span class="n">msg</span><span class="p">[</span><span class="s1">&#39;From&#39;</span><span class="p">]</span> <span class="o">=</span> <span class="s1">&#39;no-reply@foobar.io&#39;</span>
168 <span class="n">msg</span><span class="p">[</span><span class="s1">&#39;To&#39;</span><span class="p">]</span> <span class="o">=</span> <span class="n">recipient</span>
169
170 <span class="n">s</span> <span class="o">=</span> <span class="n">smtplib</span><span class="o">.</span><span class="n">SMTP</span><span class="p">(</span><span class="s1">&#39;smtp.gmail.com&#39;</span><span class="p">)</span>
171
172 <span class="n">s</span><span class="o">.</span><span class="n">login</span><span class="p">(</span><span class="s1">&#39;me@gmail.com&#39;</span><span class="p">,</span> <span class="s1">&#39;my-app-password&#39;</span><span class="p">)</span>
173
174 <span class="n">s</span><span class="o">.</span><span class="n">sendmail</span><span class="p">(</span><span class="s1">&#39;me@gmail.com&#39;</span><span class="p">,</span> <span class="p">[</span><span class="n">recipient</span><span class="p">,],</span> <span class="n">msg</span><span class="o">.</span><span class="n">as_string</span><span class="p">())</span>
175 <span class="n">s</span><span class="o">.</span><span class="n">quit</span><span class="p">()</span>
176</pre></div>
177</div>
178<dl class="method">
179<dt id="eventmq.client.jobs.Job.__init__">
180<code class="descname">__init__</code><span class="sig-paren">(</span><em>broker_addr=None</em>, <em>queue=None</em>, <em>async=True</em>, <em>*args</em>, <em>**kwargs</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.client.jobs.Job.__init__" title="Permalink to this definition">¶</a></dt>
181<dd><table class="docutils field-list" frame="void" rules="none">
182<col class="field-name" />
183<col class="field-body" />
184<tbody valign="top">
185<tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple">
186<li><strong>queue</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) &#8211; Name of the queue this function should be executed
187in. If no queue provided <code class="docutils literal"><span class="pre">default</span></code> is used.</li>
188<li><strong>broker_addr</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) &#8211; Address of the broker to send the job to. If no
189address is given then the value of the environment variable
190<code class="docutils literal"><span class="pre">EMQ_BROKER_ADDR</span></code> will be used, If that is undefined a
191warning will be emitted and the job will be run synchronously.</li>
192<li><strong>async</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#bool" title="(in Python v2.7)"><em>bool</em></a>) &#8211; If you want to run all executions of a particular job
193synchronously but still decorate it with the job decorator you
194can set this to False. This is useful for unit tests.</li>
195</ul>
196</td>
197</tr>
198</tbody>
199</table>
200</dd></dl>
201
202<dl class="attribute">
203<dt id="eventmq.client.jobs.Job.__weakref__">
204<code class="descname">__weakref__</code><a class="headerlink" href="#eventmq.client.jobs.Job.__weakref__" title="Permalink to this definition">¶</a></dt>
205<dd><p>list of weak references to the object (if defined)</p>
206</dd></dl>
207
208</dd></dl>
209
210<dl class="function">
211<dt id="eventmq.client.jobs.job">
212<code class="descclassname">eventmq.client.jobs.</code><code class="descname">job</code><span class="sig-paren">(</span><em>func</em>, <em>broker_addr=None</em>, <em>queue=None</em>, <em>async=True</em>, <em>*args</em>, <em>**kwargs</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.client.jobs.job" title="Permalink to this definition">¶</a></dt>
213<dd><p>Functional decorator helper for creating a deferred eventmq job. See
214<a class="reference internal" href="#eventmq.client.jobs.Job" title="eventmq.client.jobs.Job"><code class="xref py py-class docutils literal"><span class="pre">Job</span></code></a> for more information.</p>
215</dd></dl>
216
217</div>
218
219
220 </div>
221 </div>
222 <footer>
223
224 <div class="rst-footer-buttons" role="navigation" aria-label="footer navigation">
225
226 <a href="../exceptions.html" class="btn btn-neutral float-right" title="exceptions – Exceptions" accesskey="n">Next <span class="fa fa-arrow-circle-right"></span></a>
227
228
229 <a href="messages.html" class="btn btn-neutral" title="messages – Client Messaging" accesskey="p"><span class="fa fa-arrow-circle-left"></span> Previous</a>
230
231 </div>
232
233
234 <hr/>
235
236 <div role="contentinfo">
237 <p>
238 &copy; Copyright 2016, EventMQ Contributors.
239
240 </p>
241 </div>
242 Built with <a href="http://sphinx-doc.org/">Sphinx</a> using a <a href="https://github.com/snide/sphinx_rtd_theme">theme</a> provided by <a href="https://readthedocs.org">Read the Docs</a>.
243
244</footer>
245
246 </div>
247 </div>
248
249 </section>
250
251 </div>
252
253
254
255
256
257 <script type="text/javascript">
258 var DOCUMENTATION_OPTIONS = {
259 URL_ROOT:'../',
260 VERSION:'0',
261 COLLAPSE_INDEX:false,
262 FILE_SUFFIX:'.html',
263 HAS_SOURCE: true
264 };
265 </script>
266 <script type="text/javascript" src="../_static/jquery.js"></script>
267 <script type="text/javascript" src="../_static/underscore.js"></script>
268 <script type="text/javascript" src="../_static/doctools.js"></script>
269
270
271
272
273
274 <script type="text/javascript" src="../_static/js/theme.js"></script>
275
276
277
278
279 <script type="text/javascript">
280 jQuery(function () {
281 SphinxRtdTheme.StickyNav.enable();
282 });
283 </script>
284
285
286</body>
287</html> \ No newline at end of file
diff --git a/client/messages.html b/client/messages.html
index d0cbb95..78b4424 100644
--- a/client/messages.html
+++ b/client/messages.html
@@ -32,7 +32,7 @@
32 32
33 <link rel="top" title="EventMQ 0 documentation" href="../index.html"/> 33 <link rel="top" title="EventMQ 0 documentation" href="../index.html"/>
34 <link rel="up" title="client – Client Utilities" href="../client.html"/> 34 <link rel="up" title="client – Client Utilities" href="../client.html"/>
35 <link rel="next" title="exceptions – Exceptions" href="../exceptions.html"/> 35 <link rel="next" title="jobs – Client Job Helpers" href="jobs.html"/>
36 <link rel="prev" title="client – Client Utilities" href="../client.html"/> 36 <link rel="prev" title="client – Client Utilities" href="../client.html"/>
37 37
38 38
@@ -61,7 +61,7 @@
61 61
62 62
63 <div class="version"> 63 <div class="version">
64 0.2.7 64 0.2.7.1
65 </div> 65 </div>
66 66
67 67
@@ -87,6 +87,7 @@
87<li class="toctree-l1 current"><a class="reference internal" href="../api.html">API Documentation</a><ul class="current"> 87<li class="toctree-l1 current"><a class="reference internal" href="../api.html">API Documentation</a><ul class="current">
88<li class="toctree-l2 current"><a class="reference internal" href="../client.html"><code class="docutils literal"><span class="pre">client</span></code> &#8211; Client Utilities</a><ul class="current"> 88<li class="toctree-l2 current"><a class="reference internal" href="../client.html"><code class="docutils literal"><span class="pre">client</span></code> &#8211; Client Utilities</a><ul class="current">
89<li class="toctree-l3 current"><a class="current reference internal" href=""><code class="docutils literal"><span class="pre">messages</span></code> &#8211; Client Messaging</a></li> 89<li class="toctree-l3 current"><a class="current reference internal" href=""><code class="docutils literal"><span class="pre">messages</span></code> &#8211; Client Messaging</a></li>
90<li class="toctree-l3"><a class="reference internal" href="jobs.html"><code class="docutils literal"><span class="pre">jobs</span></code> &#8211; Client Job Helpers</a></li>
90</ul> 91</ul>
91</li> 92</li>
92<li class="toctree-l2"><a class="reference internal" href="../exceptions.html"><code class="docutils literal"><span class="pre">exceptions</span></code> &#8211; Exceptions</a></li> 93<li class="toctree-l2"><a class="reference internal" href="../exceptions.html"><code class="docutils literal"><span class="pre">exceptions</span></code> &#8211; Exceptions</a></li>
@@ -348,7 +349,7 @@ interval for the scheduler.</p>
348 349
349 <div class="rst-footer-buttons" role="navigation" aria-label="footer navigation"> 350 <div class="rst-footer-buttons" role="navigation" aria-label="footer navigation">
350 351
351 <a href="../exceptions.html" class="btn btn-neutral float-right" title="exceptions – Exceptions" accesskey="n">Next <span class="fa fa-arrow-circle-right"></span></a> 352 <a href="jobs.html" class="btn btn-neutral float-right" title="jobs – Client Job Helpers" accesskey="n">Next <span class="fa fa-arrow-circle-right"></span></a>
352 353
353 354
354 <a href="../client.html" class="btn btn-neutral" title="client – Client Utilities" accesskey="p"><span class="fa fa-arrow-circle-left"></span> Previous</a> 355 <a href="../client.html" class="btn btn-neutral" title="client – Client Utilities" accesskey="p"><span class="fa fa-arrow-circle-left"></span> Previous</a>
@@ -360,7 +361,7 @@ interval for the scheduler.</p>
360 361
361 <div role="contentinfo"> 362 <div role="contentinfo">
362 <p> 363 <p>
363 &copy; Copyright 2016, eventboard.io. 364 &copy; Copyright 2016, EventMQ Contributors.
364 365
365 </p> 366 </p>
366 </div> 367 </div>
diff --git a/contributing.html b/contributing.html
index 954d1b3..cda4d9f 100644
--- a/contributing.html
+++ b/contributing.html
@@ -60,7 +60,7 @@
60 60
61 61
62 <div class="version"> 62 <div class="version">
63 0.2.7 63 0.2.7.1
64 </div> 64 </div>
65 65
66 66
@@ -170,7 +170,7 @@
170 170
171 <div role="contentinfo"> 171 <div role="contentinfo">
172 <p> 172 <p>
173 &copy; Copyright 2016, eventboard.io. 173 &copy; Copyright 2016, EventMQ Contributors.
174 174
175 </p> 175 </p>
176 </div> 176 </div>
diff --git a/exceptions.html b/exceptions.html
index 7893844..9ced5ed 100644
--- a/exceptions.html
+++ b/exceptions.html
@@ -33,7 +33,7 @@
33 <link rel="top" title="EventMQ 0 documentation" href="index.html"/> 33 <link rel="top" title="EventMQ 0 documentation" href="index.html"/>
34 <link rel="up" title="API Documentation" href="api.html"/> 34 <link rel="up" title="API Documentation" href="api.html"/>
35 <link rel="next" title="jobmanager – Job Manager" href="jobmanager.html"/> 35 <link rel="next" title="jobmanager – Job Manager" href="jobmanager.html"/>
36 <link rel="prev" title="messages – Client Messaging" href="client/messages.html"/> 36 <link rel="prev" title="jobs – Client Job Helpers" href="client/jobs.html"/>
37 37
38 38
39 <script src="_static/js/modernizr.min.js"></script> 39 <script src="_static/js/modernizr.min.js"></script>
@@ -61,7 +61,7 @@
61 61
62 62
63 <div class="version"> 63 <div class="version">
64 0.2.7 64 0.2.7.1
65 </div> 65 </div>
66 66
67 67
@@ -201,7 +201,7 @@ sending a message to it)</p>
201 <a href="jobmanager.html" class="btn btn-neutral float-right" title="jobmanager – Job Manager" accesskey="n">Next <span class="fa fa-arrow-circle-right"></span></a> 201 <a href="jobmanager.html" class="btn btn-neutral float-right" title="jobmanager – Job Manager" accesskey="n">Next <span class="fa fa-arrow-circle-right"></span></a>
202 202
203 203
204 <a href="client/messages.html" class="btn btn-neutral" title="messages – Client Messaging" accesskey="p"><span class="fa fa-arrow-circle-left"></span> Previous</a> 204 <a href="client/jobs.html" class="btn btn-neutral" title="jobs – Client Job Helpers" accesskey="p"><span class="fa fa-arrow-circle-left"></span> Previous</a>
205 205
206 </div> 206 </div>
207 207
@@ -210,7 +210,7 @@ sending a message to it)</p>
210 210
211 <div role="contentinfo"> 211 <div role="contentinfo">
212 <p> 212 <p>
213 &copy; Copyright 2016, eventboard.io. 213 &copy; Copyright 2016, EventMQ Contributors.
214 214
215 </p> 215 </p>
216 </div> 216 </div>
diff --git a/genindex.html b/genindex.html
index fbd6f40..5576f73 100644
--- a/genindex.html
+++ b/genindex.html
@@ -59,7 +59,7 @@
59 59
60 60
61 <div class="version"> 61 <div class="version">
62 0.2.7 62 0.2.7.1
63 </div> 63 </div>
64 64
65 65
@@ -158,11 +158,15 @@
158<table style="width: 100%" class="indextable genindextable"><tr> 158<table style="width: 100%" class="indextable genindextable"><tr>
159 <td style="width: 33%" valign="top"><dl> 159 <td style="width: 33%" valign="top"><dl>
160 160
161 <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager.__init__">__init__() (eventmq.jobmanager.JobManager method)</a> 161 <dt><a href="client/jobs.html#eventmq.client.jobs.Job.__init__">__init__() (eventmq.client.jobs.Job method)</a>
162 </dt> 162 </dt>
163 163
164 <dd><dl> 164 <dd><dl>
165 165
166 <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager.__init__">(eventmq.jobmanager.JobManager method)</a>
167 </dt>
168
169
166 <dt><a href="poller.html#eventmq.poller.Poller.__init__">(eventmq.poller.Poller method)</a> 170 <dt><a href="poller.html#eventmq.poller.Poller.__init__">(eventmq.poller.Poller method)</a>
167 </dt> 171 </dt>
168 172
@@ -190,7 +194,7 @@
190 </dl></td> 194 </dl></td>
191 <td style="width: 33%" valign="top"><dl> 195 <td style="width: 33%" valign="top"><dl>
192 196
193 <dt><a href="utils/classes.html#eventmq.utils.classes.EMQdeque.__weakref__">__weakref__ (eventmq.utils.classes.EMQdeque attribute)</a> 197 <dt><a href="client/jobs.html#eventmq.client.jobs.Job.__weakref__">__weakref__ (eventmq.client.jobs.Job attribute)</a>
194 </dt> 198 </dt>
195 199
196 <dd><dl> 200 <dd><dl>
@@ -199,6 +203,10 @@
199 </dt> 203 </dt>
200 204
201 205
206 <dt><a href="utils/classes.html#eventmq.utils.classes.EMQdeque.__weakref__">(eventmq.utils.classes.EMQdeque attribute)</a>
207 </dt>
208
209
202 <dt><a href="utils/classes.html#eventmq.utils.classes.HeartbeatMixin.__weakref__">(eventmq.utils.classes.HeartbeatMixin attribute)</a> 210 <dt><a href="utils/classes.html#eventmq.utils.classes.HeartbeatMixin.__weakref__">(eventmq.utils.classes.HeartbeatMixin attribute)</a>
203 </dt> 211 </dt>
204 212
@@ -302,6 +310,10 @@
302 </dt> 310 </dt>
303 311
304 312
313 <dt><a href="client/jobs.html#module-eventmq.client.jobs">eventmq.client.jobs (module)</a>
314 </dt>
315
316
305 <dt><a href="client/messages.html#module-eventmq.client.messages">eventmq.client.messages (module)</a> 317 <dt><a href="client/messages.html#module-eventmq.client.messages">eventmq.client.messages (module)</a>
306 </dt> 318 </dt>
307 319
@@ -325,12 +337,12 @@
325 <dt><a href="router.html#module-eventmq.router">eventmq.router (module)</a> 337 <dt><a href="router.html#module-eventmq.router">eventmq.router (module)</a>
326 </dt> 338 </dt>
327 339
340 </dl></td>
341 <td style="width: 33%" valign="top"><dl>
328 342
329 <dt><a href="sender.html#module-eventmq.sender">eventmq.sender (module)</a> 343 <dt><a href="sender.html#module-eventmq.sender">eventmq.sender (module)</a>
330 </dt> 344 </dt>
331 345
332 </dl></td>
333 <td style="width: 33%" valign="top"><dl>
334 346
335 <dt><a href="utils/index.html#module-eventmq.utils">eventmq.utils (module)</a> 347 <dt><a href="utils/index.html#module-eventmq.utils">eventmq.utils (module)</a>
336 </dt> 348 </dt>
@@ -458,16 +470,24 @@
458<table style="width: 100%" class="indextable genindextable"><tr> 470<table style="width: 100%" class="indextable genindextable"><tr>
459 <td style="width: 33%" valign="top"><dl> 471 <td style="width: 33%" valign="top"><dl>
460 472
461 <dt><a href="router.html#eventmq.router.Router.job_latencies">job_latencies (eventmq.router.Router attribute)</a> 473 <dt><a href="client/jobs.html#eventmq.client.jobs.Job">Job (class in eventmq.client.jobs)</a>
462 </dt> 474 </dt>
463 475
464 476
465 <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager">JobManager (class in eventmq.jobmanager)</a> 477 <dt><a href="client/jobs.html#eventmq.client.jobs.job">job() (in module eventmq.client.jobs)</a>
478 </dt>
479
480
481 <dt><a href="router.html#eventmq.router.Router.job_latencies">job_latencies (eventmq.router.Router attribute)</a>
466 </dt> 482 </dt>
467 483
468 </dl></td> 484 </dl></td>
469 <td style="width: 33%" valign="top"><dl> 485 <td style="width: 33%" valign="top"><dl>
470 486
487 <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager">JobManager (class in eventmq.jobmanager)</a>
488 </dt>
489
490
471 <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager.jobmanager_main">jobmanager_main() (eventmq.jobmanager.JobManager method)</a> 491 <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager.jobmanager_main">jobmanager_main() (eventmq.jobmanager.JobManager method)</a>
472 </dt> 492 </dt>
473 493
@@ -949,7 +969,7 @@
949 969
950 <div role="contentinfo"> 970 <div role="contentinfo">
951 <p> 971 <p>
952 &copy; Copyright 2016, eventboard.io. 972 &copy; Copyright 2016, EventMQ Contributors.
953 973
954 </p> 974 </p>
955 </div> 975 </div>
diff --git a/index.html b/index.html
index b2d1c08..7b7bdd4 100644
--- a/index.html
+++ b/index.html
@@ -59,7 +59,7 @@
59 59
60 60
61 <div class="version"> 61 <div class="version">
62 0.2.7 62 0.2.7.1
63 </div> 63 </div>
64 64
65 65
@@ -133,7 +133,8 @@
133<div class="toctree-wrapper compound"> 133<div class="toctree-wrapper compound">
134<ul> 134<ul>
135<li class="toctree-l1"><a class="reference internal" href="using.html">Using EventMQ</a><ul> 135<li class="toctree-l1"><a class="reference internal" href="using.html">Using EventMQ</a><ul>
136<li class="toctree-l2"><a class="reference internal" href="settings_file.html">Settings</a></li> 136<li class="toctree-l2"><a class="reference internal" href="settings_file.html">Server Settings (eventmq.conf)</a></li>
137<li class="toctree-l2"><a class="reference internal" href="using.html#client-environment-variables">Client Environment Variables</a></li>
137</ul> 138</ul>
138</li> 139</li>
139<li class="toctree-l1"><a class="reference internal" href="api.html">API Documentation</a><ul> 140<li class="toctree-l1"><a class="reference internal" href="api.html">API Documentation</a><ul>
@@ -182,7 +183,7 @@
182 183
183 <div role="contentinfo"> 184 <div role="contentinfo">
184 <p> 185 <p>
185 &copy; Copyright 2016, eventboard.io. 186 &copy; Copyright 2016, EventMQ Contributors.
186 187
187 </p> 188 </p>
188 </div> 189 </div>
diff --git a/jobmanager.html b/jobmanager.html
index f6bc0a8..840922d 100644
--- a/jobmanager.html
+++ b/jobmanager.html
@@ -61,7 +61,7 @@
61 61
62 62
63 <div class="version"> 63 <div class="version">
64 0.2.7 64 0.2.7.1
65 </div> 65 </div>
66 66
67 67
@@ -314,7 +314,7 @@ processes will never be delivered.</p>
314 314
315 <div role="contentinfo"> 315 <div role="contentinfo">
316 <p> 316 <p>
317 &copy; Copyright 2016, eventboard.io. 317 &copy; Copyright 2016, EventMQ Contributors.
318 318
319 </p> 319 </p>
320 </div> 320 </div>
diff --git a/objects.inv b/objects.inv
index 7d0d75e..db575b0 100644
--- a/objects.inv
+++ b/objects.inv
Binary files differ
diff --git a/poller.html b/poller.html
index ab58f21..4357018 100644
--- a/poller.html
+++ b/poller.html
@@ -61,7 +61,7 @@
61 61
62 62
63 <div class="version"> 63 <div class="version">
64 0.2.7 64 0.2.7.1
65 </div> 65 </div>
66 66
67 67
@@ -234,7 +234,7 @@ socket remains unregistered.</li>
234 234
235 <div role="contentinfo"> 235 <div role="contentinfo">
236 <p> 236 <p>
237 &copy; Copyright 2016, eventboard.io. 237 &copy; Copyright 2016, EventMQ Contributors.
238 238
239 </p> 239 </p>
240 </div> 240 </div>
diff --git a/protocol.html b/protocol.html
index ea5405d..56d4ea0 100644
--- a/protocol.html
+++ b/protocol.html
@@ -60,7 +60,7 @@
60 60
61 61
62 <div class="version"> 62 <div class="version">
63 0.2.7 63 0.2.7.1
64 </div> 64 </div>
65 65
66 66
@@ -779,7 +779,7 @@
779 779
780 <div role="contentinfo"> 780 <div role="contentinfo">
781 <p> 781 <p>
782 &copy; Copyright 2016, eventboard.io. 782 &copy; Copyright 2016, EventMQ Contributors.
783 783
784 </p> 784 </p>
785 </div> 785 </div>
diff --git a/py-modindex.html b/py-modindex.html
index d1f8956..4909bf9 100644
--- a/py-modindex.html
+++ b/py-modindex.html
@@ -61,7 +61,7 @@
61 61
62 62
63 <div class="version"> 63 <div class="version">
64 0.2.7 64 0.2.7.1
65 </div> 65 </div>
66 66
67 67
@@ -153,6 +153,11 @@
153 <tr class="cg-1"> 153 <tr class="cg-1">
154 <td></td> 154 <td></td>
155 <td>&nbsp;&nbsp;&nbsp; 155 <td>&nbsp;&nbsp;&nbsp;
156 <a href="client/jobs.html#module-eventmq.client.jobs"><code class="xref">eventmq.client.jobs</code></a></td><td>
157 <em></em></td></tr>
158 <tr class="cg-1">
159 <td></td>
160 <td>&nbsp;&nbsp;&nbsp;
156 <a href="client/messages.html#module-eventmq.client.messages"><code class="xref">eventmq.client.messages</code></a></td><td> 161 <a href="client/messages.html#module-eventmq.client.messages"><code class="xref">eventmq.client.messages</code></a></td><td>
157 <em></em></td></tr> 162 <em></em></td></tr>
158 <tr class="cg-1"> 163 <tr class="cg-1">
@@ -227,7 +232,7 @@
227 232
228 <div role="contentinfo"> 233 <div role="contentinfo">
229 <p> 234 <p>
230 &copy; Copyright 2016, eventboard.io. 235 &copy; Copyright 2016, EventMQ Contributors.
231 236
232 </p> 237 </p>
233 </div> 238 </div>
diff --git a/receiver.html b/receiver.html
index 5997c86..6e13f51 100644
--- a/receiver.html
+++ b/receiver.html
@@ -61,7 +61,7 @@
61 61
62 62
63 <div class="version"> 63 <div class="version">
64 0.2.7 64 0.2.7.1
65 </div> 65 </div>
66 66
67 67
@@ -289,7 +289,7 @@ False</td>
289 289
290 <div role="contentinfo"> 290 <div role="contentinfo">
291 <p> 291 <p>
292 &copy; Copyright 2016, eventboard.io. 292 &copy; Copyright 2016, EventMQ Contributors.
293 293
294 </p> 294 </p>
295 </div> 295 </div>
diff --git a/router.html b/router.html
index cc9802a..805edec 100644
--- a/router.html
+++ b/router.html
@@ -61,7 +61,7 @@
61 61
62 62
63 <div class="version"> 63 <div class="version">
64 0.2.7 64 0.2.7.1
65 </div> 65 </div>
66 66
67 67
@@ -579,7 +579,7 @@ process.</li>
579 579
580 <div role="contentinfo"> 580 <div role="contentinfo">
581 <p> 581 <p>
582 &copy; Copyright 2016, eventboard.io. 582 &copy; Copyright 2016, EventMQ Contributors.
583 583
584 </p> 584 </p>
585 </div> 585 </div>
diff --git a/search.html b/search.html
index ca6c474..b9b5a01 100644
--- a/search.html
+++ b/search.html
@@ -58,7 +58,7 @@
58 58
59 59
60 <div class="version"> 60 <div class="version">
61 0.2.7 61 0.2.7.1
62 </div> 62 </div>
63 63
64 64
@@ -146,7 +146,7 @@
146 146
147 <div role="contentinfo"> 147 <div role="contentinfo">
148 <p> 148 <p>
149 &copy; Copyright 2016, eventboard.io. 149 &copy; Copyright 2016, EventMQ Contributors.
150 150
151 </p> 151 </p>
152 </div> 152 </div>
diff --git a/searchindex.js b/searchindex.js
index 41efe4e..da74dc4 100644
--- a/searchindex.js
+++ b/searchindex.js
@@ -1 +1 @@
Search.setIndex({envversion:46,filenames:["api","client","client/messages","contributing","exceptions","index","jobmanager","poller","protocol","receiver","router","sender","settings_file","using","utils/classes","utils/devices","utils/index","utils/messages","utils/settings","utils/timeutils"],objects:{"eventmq.client":{messages:[2,0,0,"-"]},"eventmq.client.messages":{defer_job:[2,3,1,""],schedule:[2,3,1,""],send_request:[2,3,1,""],send_schedule_request:[2,3,1,""]},"eventmq.exceptions":{CallableFromPathError:[4,5,1,""],EventMQError:[4,5,1,""],InvalidMessageError:[4,5,1,""],MessageError:[4,5,1,""],NoAvailableWorkerSlotsError:[4,5,1,""],PeerGoneAwayError:[4,5,1,""],UnknownQueueError:[4,5,1,""]},"eventmq.jobmanager":{JobManager:[6,4,1,""],mp_init:[6,3,1,""]},"eventmq.jobmanager.JobManager":{"__init__":[6,2,1,""],concurrent_jobs:[6,1,1,""],jobmanager_main:[6,2,1,""],name:[6,1,1,""],on_heartbeat:[6,2,1,""],on_request:[6,2,1,""],outgoing:[6,1,1,""],queues:[6,1,1,""],send_ready:[6,2,1,""],send_reply:[6,2,1,""]},"eventmq.poller":{Poller:[7,4,1,""]},"eventmq.poller.Poller":{"__init__":[7,2,1,""],poll:[7,2,1,""],register:[7,2,1,""],unregister:[7,2,1,""]},"eventmq.receiver":{Receiver:[9,4,1,""]},"eventmq.receiver.Receiver":{"__init__":[9,2,1,""],connect:[9,2,1,""],listen:[9,2,1,""],name:[9,1,1,""],ready:[9,1,1,""],unbind:[9,2,1,""],zcontext:[9,1,1,""],zsocket:[9,1,1,""]},"eventmq.router":{Router:[10,4,1,""]},"eventmq.router.Router":{add_scheduler:[10,2,1,""],add_worker:[10,2,1,""],clean_up_dead_schedulers:[10,2,1,""],clean_up_dead_workers:[10,2,1,""],executed_functions:[10,1,1,""],get_available_worker:[10,2,1,""],get_status:[10,2,1,""],job_latencies:[10,1,1,""],on_disconnect:[10,2,1,""],on_heartbeat:[10,2,1,""],on_inform:[10,2,1,""],on_ready:[10,2,1,""],on_reply:[10,2,1,""],on_request:[10,2,1,""],prioritize_queue_list:[10,6,1,""],process_client_message:[10,2,1,""],process_worker_message:[10,2,1,""],queues:[10,1,1,""],received_disconnect:[10,1,1,""],requeue_worker:[10,2,1,""],reset_heartbeat_counters:[10,2,1,""],router_main:[10,2,1,""],scheduler_queue:[10,1,1,""],schedulers:[10,1,1,""],send_ack:[10,2,1,""],send_heartbeat:[10,2,1,""],send_schedulers_heartbeats:[10,2,1,""],send_workers_heartbeats:[10,2,1,""],sighup_handler:[10,2,1,""],start:[10,2,1,""],waiting_messages:[10,1,1,""],workers:[10,1,1,""]},"eventmq.sender":{Sender:[11,4,1,""]},"eventmq.sender.Sender":{"__init__":[11,2,1,""],connect:[11,2,1,""],listen:[11,2,1,""],name:[11,1,1,""],ready:[11,1,1,""],rebuild:[11,2,1,""],unbind:[11,2,1,""],zcontext:[11,1,1,""],zsocket:[11,1,1,""]},"eventmq.utils":{classes:[14,0,0,"-"],devices:[15,0,0,"-"],messages:[17,0,0,"-"],random_characters:[16,3,1,""],settings:[18,0,0,"-"],timeutils:[19,0,0,"-"],tuplify:[16,3,1,""],zero_index_cmp:[16,3,1,""]},"eventmq.utils.classes":{EMQPService:[14,4,1,""],EMQdeque:[14,4,1,""],HeartbeatMixin:[14,4,1,""],ZMQReceiveMixin:[14,4,1,""],ZMQSendMixin:[14,4,1,""]},"eventmq.utils.classes.EMQPService":{"__weakref__":[14,1,1,""],is_heartbeat_enabled:[14,1,1,""],on_ack:[14,2,1,""],process_message:[14,2,1,""],reset:[14,2,1,""],send_inform:[14,2,1,""],start:[14,2,1,""]},"eventmq.utils.classes.EMQdeque":{"__init__":[14,2,1,""],"__weakref__":[14,1,1,""],append:[14,2,1,""],appendleft:[14,2,1,""],extend:[14,2,1,""],is_empty:[14,2,1,""],is_full:[14,2,1,""],is_pfull:[14,2,1,""],peek:[14,2,1,""],peekleft:[14,2,1,""],pop:[14,2,1,""],popleft:[14,2,1,""],remove:[14,2,1,""]},"eventmq.utils.classes.HeartbeatMixin":{"__init__":[14,2,1,""],"__weakref__":[14,1,1,""],is_dead:[14,2,1,""],reset_heartbeat_counters:[14,2,1,""],send_heartbeat:[14,2,1,""]},"eventmq.utils.classes.ZMQReceiveMixin":{"__weakref__":[14,1,1,""],recv:[14,2,1,""],recv_multipart:[14,2,1,""]},"eventmq.utils.classes.ZMQSendMixin":{"__weakref__":[14,1,1,""],send:[14,2,1,""],send_multipart:[14,2,1,""]},"eventmq.utils.devices":{generate_device_name:[15,3,1,""]},"eventmq.utils.messages":{fwd_emqp_router_message:[17,3,1,""],generate_msgid:[17,3,1,""],parse_message:[17,3,1,""],parse_router_message:[17,3,1,""],send_emqp_message:[17,3,1,""],send_emqp_router_message:[17,3,1,""]},"eventmq.utils.settings":{import_settings:[18,3,1,""]},"eventmq.utils.timeutils":{IntervalIter:[19,4,1,""],monotonic:[19,3,1,""],seconds_until:[19,3,1,""],timestamp:[19,3,1,""]},"eventmq.utils.timeutils.IntervalIter":{"__init__":[19,2,1,""],"__weakref__":[19,1,1,""]},eventmq:{client:[1,0,0,"-"],exceptions:[4,0,0,"-"],jobmanager:[6,0,0,"-"],poller:[7,0,0,"-"],receiver:[9,0,0,"-"],router:[10,0,0,"-"],sender:[11,0,0,"-"],utils:[16,0,0,"-"]}},objnames:{"0":["py","module","Python module"],"1":["py","attribute","Python attribute"],"2":["py","method","Python method"],"3":["py","function","Python function"],"4":["py","class","Python class"],"5":["py","exception","Python exception"],"6":["py","classmethod","Python class method"]},objtypes:{"0":"py:module","1":"py:attribute","2":"py:method","3":"py:function","4":"py:class","5":"py:exception","6":"py:classmethod"},terms:{"0mq":[8,14],"5min":19,"__init__":[6,7,9,11,14,19],"__weakref__":[14,19],"_empty_":8,"_headers_":8,"_msg_":8,"_msgid_":8,"_queue_name_":8,"_queues_":8,"_recipient_id":14,"_topic_name_":8,"_unix_ts_":8,"abstract":8,"boolean":14,"case":[8,14,19],"class":[],"default":[2,6,8,9,10,11,12,14],"float":[14,19],"function":[2,6,10],"import":[2,3,6,10,12,18],"int":[2,7,8,10,14,19],"long":[7,14],"new":[6,10,14],"public":8,"return":[2,3,7,9,10,11,14,15,16,17,19],"short":10,"true":[8,9,10,11,14],"while":8,abl:[10,12],about:[6,8,10],absolut:3,accept:[8,12,14],account:[10,17],ack:[6,8,10],ackd_msgid:14,acknowledg:[6,8,10],across:8,act:[1,8],actual:[6,10],add:10,add_schedul:10,add_work:10,addr:[9,11,14],address:[],administrative_addr:10,after:8,agre:8,all:[2,4,6,8,9,10,11,14],allow:8,alpha:8,alreadi:10,also:14,alwai:2,and_data:17,ani:[2,8,10,16],announc:10,anoth:[6,10,12],anyth:12,app:14,appear:7,append:14,appendleft:14,appened:10,appli:18,applic:[2,8],arg2:2,arg3:2,arg:[2,6,7,9,10,11,14],argument:14,arithmet:19,arrai:8,ascii:15,assign:12,assum:19,attempt:[4,10],attr:7,automat:14,avail:[4,10],available_slot:10,awaiting_ack:14,back:[8,10,14],backend_addr:10,backward:14,base:[4,7,12,14],basi:8,becaus:[10,14],becom:12,been:[2,10,14],befor:[2,7,8],begin:[10,12,14,19],belong:10,below:8,best:2,between:[2,8,19],block:12,bool:[2,6,9,11,14],boot:19,both:[7,8],box:12,broadcast:8,broker:[6,8,14],broker_addr:6,buffer:10,build:[10,11],built:8,bulid:9,calabl:2,calcul:19,call:[2,7,10,14],callabl:[2,4,6,9],callable_nam:4,callablefrompatherror:4,callback:14,can:[1,2,6,8,10,14,15,17],captur:14,care:15,caus:15,certain:14,chang:8,charact:16,check:[9,11,14],child:6,choos:12,circuit:10,class_arg:[2,6],class_kwarg:[2,6],classmethod:10,clean:8,clean_up_dead_schedul:10,clean_up_dead_work:10,clear:10,cli:10,client:[],clock:19,close:[14,19],cmp:16,code:[3,5,14],collect:14,colon:[2,12],come:[2,10],comma:8,command:[2,6,8,10,14,17],compar:16,compat:14,complet:8,compon:8,concurr:12,concurrent_job:[],conf:12,config:12,configur:[2,10,18],connction:[9,11],connect:[6,8,9,10,11,14,17],consist:8,construct:4,contact:4,contain:[1,8,10,14,16],context:[6,9,11],control:12,contruct:14,convers:8,convert:16,convienc:[7,14],copi:6,core:12,count:[6,8,10,19],counter:[10,14],cpu:12,creat:[10,11,16],cron:2,csv:8,current:[9,10,11,14],custom:10,cycl:12,data:[10,17],data_process:12,deal:16,dealer:11,death:14,debounc:2,debounce_deferred_job:2,debounce_sec:2,debug:8,decsend:10,defeat:8,defer:2,defer_job:2,defin:[2,6,8,9,11,14,19],deliv:[6,8],denot:2,depth:10,dequ:14,describ:8,descript:8,detail:8,detect:8,determin:8,devic:[],dialog:8,dict:[2,6,7],dictionari:[7,8,10],die:10,differ:3,directli:[7,14],disabl:2,distribut:8,doe:14,doesn:7,don:[6,8],dot:2,down:[12,19],dst:19,duplic:10,dure:11,each:10,effici:12,effort:2,either:[8,14],elaps:8,element:[10,14],els:[3,8],email:[8,12],empti:[8,17],emq:10,emqdequ:14,emqpservic:14,enabl:[2,14],encod:15,encount:[2,4],end:[2,14],ensur:[2,6,8,14],entri:10,equal:12,error:[2,14,15],etc:[10,12],evalu:2,even:8,event:[7,14],eventmq:[],eventmqerror:4,everi:[2,6],everyth:15,exampl:[10,12,14,19],excecut:10,except:[],exectu:10,execut:[2,8,12,19],executed_funct:10,exist:[4,6],explicitli:[12,14],expos:6,extend:14,extra:8,fail:[2,4,8],failur:2,fair:8,fals:[2,8,9,11,14],featur:15,few:3,field:8,file:12,find:14,finish:[8,10],first:[8,10,14,17],fit:8,flag:[2,7],follow:[2,8,14],fork:6,form:14,format:[2,6,8,10,17],forward:[10,14,17],found:[4,10,12],foundat:8,free:8,from:[4,6,7,8,9,10,11,14,19],frontend_addr:10,fuction:2,full:14,func:[2,6,14],function_nam:10,fwd_emqp_router_messag:17,gener:[6,7,8,9,11,17],generate_device_nam:15,generate_msgid:17,get:10,get_available_work:10,get_statu:10,give:2,given:10,gnu:8,good:14,gotten:19,group:12,guarante:[2,8],guarente:2,hand:16,handl:[6,8,10,14],handler:6,happen:[2,7,10,11],hard:14,hasn:10,have:[2,12,14,17],haven:10,header:[],heartbeat:[],heartbeat_timeout:10,heartbeati:14,heartbeatmixin:14,heavi:8,help:12,helper:14,here:[8,10],highest:12,hit:14,hope:8,how:[2,7],html:8,http:8,ident:[8,15],identifi:10,ietf:8,ignor:[8,14],immedi:[2,8],immediatli:2,implement:[8,14],impli:8,import_set:18,includ:[2,8,14],index:[5,10,16],indexerror:10,indiviud:12,infinit:2,inform:[2,6,8,10,14],inherit:4,ini:[12,18],initi:[2,14],insert:[8,14],instal:3,instanc:6,instanti:[2,6],instead:8,integ:10,intens:12,interest:16,intern:4,interpret:8,interv:[2,8,19],interval_sec:[2,19],intervalit:19,invalidmessageerror:[4,10],is_dead:14,is_empti:14,is_ful:14,is_heartbeat_en:14,is_pful:14,isn:[10,14],issu:[3,5,8],item:14,iter:[7,10,14],iterat:14,itself:10,job:[],job_lat:10,job_schedul:2,jobmanag:[],jobmanager_main:6,json:2,keep:[6,10],kei:[7,8,10],kick:[6,10],kill:[2,8],know:[2,6,10],kwarg2:2,kwarg:[2,6,7,9,10,11,14],larg:12,larger:12,largest:10,last:[2,10,14],last_recv_heartbeat:10,lataneci:10,latenc:10,later:8,least:[8,14],leav:[8,12],left:14,length:[14,16],lesser:8,let:8,like:[6,14,16],limit:14,list:[2,4,6,8,10,12,14,16,19],listen:[6,9,10,11,12,14],load:12,local:12,locat:2,log:[2,6,10],logic:[6,10],longer:[4,12],look:14,loop:[7,10,14],lot:12,lower:10,mai:[8,10,14],main:6,make:16,malform:4,manag:[],mani:[2,8,11],manual:8,master:8,match:14,mean:2,measur:10,member:10,memebership:10,merchant:8,mess:19,messag:[],message_bodi:17,message_id:17,messageerror:4,met:14,meta:[10,17],method:[2,6,7,10,14],minut:2,model:12,modifi:8,modul:[1,5,6,16],monoton:[10,14,19],more:[2,8,14,16],most:14,mp_init:6,msg:[6,8,10,14,17],msgid:[6,10,14],multipart:[8,14],multiprocess:[6,12],must:[2,8,14],name:[2,6,8,9,10,11,12,18],need:[6,10,11],never:[6,8,19],next:[7,10,12,19],noavailableworkerslotserror:[4,10],nohast:8,none:[2,6,9,10,11,14,15,17],noop:6,normal:14,note:[6,9,11],notifi:14,now:14,number:[2,10,12,19],numer:19,obj:10,object:[7,14,16,19],occur:14,off:[6,10],on_ack:14,on_command:[10,14],on_disconnect:10,on_emqp_command:14,on_ful:14,on_heartbeat:[6,10],on_inform:10,on_readi:10,on_recv:9,on_repli:10,on_request:[6,10],on_schedul:14,onc:8,onlin:[10,14],option:[2,6,8,9,11,17],order:10,org:8,orient:8,origin:8,original_msg:10,other:[2,8,12],otherwis:[6,9,11,14],out:[6,8,14],outgo:[6,14],own:14,page:5,param:2,paramet:[2,6,7,9,10,11,14,15,16,17,18,19],pars:[10,14,17],parse_messag:17,parse_router_messag:17,part:[8,17],particular:[8,11],pass:[2,8,9,14],path:[2,4,6],payload:17,peek:14,peekleft:14,peer:[4,8,14],peergoneawayerror:[4,10],pend:8,per:10,pfull:14,pictur:8,placehold:[6,10],point:12,poll:7,poller:[],pollin:7,pollout:7,pool:[8,10],pop:[10,14],popleft:14,port:10,portion:6,possibl:3,practic:14,prefix:[15,17],prepar:10,prepend:8,pretti:[8,12],priorit:10,prioriti:10,prioritiess:10,prioritize_queue_list:10,problem:4,process:[6,8,10,11,12,14],process_client_messag:10,process_messag:[6,14],process_worker_messag:10,programm:14,proper:14,properti:[9,11,14],protocol:[],protocol_vers:14,provid:[10,14],pub:8,publish:8,purpos:8,push_notif:14,py2:19,py3:19,python3:15,python:[6,14],queue:[],queue_nam:10,rais:[2,4,9,10,11,14,17],random:[16,17],random_charact:16,raw:14,readi:[6,8,9,10,11,12,14],rebind:10,rebuild:11,rebuilt:6,receiv:[],received_disconnect:10,recent:[8,10],recipi:[6,10,14,17],recipient_id:17,recommend:[8,12,14],reconnect:11,recurs:[10,16],recus:10,recv:14,recv_multipart:14,redistribut:8,refer:[6,8,14,19],regist:[6,7,10],regular:8,reject:14,rel:3,reliabl:8,reload:10,remain:7,remot:14,remov:[8,10,14],reopen:14,rep:9,repli:[2,6,8,10,17],reply_request:2,repres:19,req:11,request:[1,2,6,8,10,14],requeue_work:10,requir:8,reset:[10,14],reset_heartbeat_count:[10,14],resourc:[6,8],respond:[8,10,14],respons:[6,9,10,11],restart:[8,11],retri:[2,8,10],retry_count:2,rfc2119:8,rfc:8,right:14,robin:8,roughli:11,round:8,rout:[8,10],router:[],router_main:10,run:[2,6,8,10,12,14],safe:12,sake:19,same:[11,16],schedul:[],scheduler_id:10,scheduler_queu:10,scheduler_zmq_id:10,search:5,sec:2,second:[2,8,19],seconds_until:19,section:18,see:[2,7,8,10,14],self:[6,10,11,14],semi:12,send:[2,4,6,8,10,11,14,17],send_ack:10,send_emqp_messag:17,send_emqp_router_messag:17,send_heartbeat:[10,14],send_inform:14,send_multipart:14,send_readi:6,send_repli:6,send_request:2,send_schedule_request:2,send_schedulers_heartbeat:10,send_workers_heartbeat:10,sender:[],sender_id:17,sent:[2,6,8,10,12,14],seper:[2,8,12],serial:10,serializ:2,serv:8,server:[6,8,12],servic:[8,14],service_typ:14,set:[],shall:8,should:[2,4,7,8,9,10,11,12,14,17],shown:8,sighup:10,sighup_handl:10,signal:6,signum:10,similar:12,simpl:[10,16],sinc:19,singl:[8,14],size:14,skip:[11,14],skip_sign:6,skip_zmqstream:11,slot:10,slow:12,smaller:12,socket:[2,6,7,8,9,10,11,14,15,17],softwar:8,some:[2,6,12,14,16,17],someon:8,someth:[2,11,12,14,19],somewher:3,sort:16,sourc:[3,5],spawn:6,specif:[],specifi:[8,14,16],standard:12,start:[6,9,10,11,12,14,19],start_valu:19,state:[10,14],statu:8,still:[10,12],stop:8,store:10,str:[2,6,9,10,11,14,15,16,17,18],string:[2,8,9,10,11,14,15,17],structur:4,style:12,sub:8,subclass:4,subcmd:6,subcommand:[2,6],subject:8,subset:8,subtract:19,success:8,successfulli:14,support:14,system:[3,10],take:[10,11,14,15,17],task:[2,6],tcp:10,tell:6,term:8,termin:6,test:6,thei:[2,14],them:9,thi:[1,2,4,6,7,8,9,10,11,12,14,15,16,17,19],thier:12,thing:[2,6,11,12,14,16,17],those:6,thread:12,threshold:14,through:[8,10],time:[],timeout:[2,7,8],timestamp:[8,10,19],timeutil:[],tip:3,tool:8,topic:8,trace:8,track:[6,10,14],tri:2,tune:12,tupl:[6,7,10,14,16,17],tuplifi:16,type:[2,8,9,10,11,14,16,17],type_:14,typecast:7,typeerror:[2,9],unabl:10,unbind:[9,11],undefin:7,under:8,unicod:15,uniqu:[6,8,10],unit:6,unix:8,unknownqueueerror:[4,10],unless:[6,9,11],unprioritized_iter:10,unregist:7,unschedul:[2,8],until:[12,19],untouch:[10,17],unus:8,updat:14,upon:8,upstream:6,usag:19,usual:[14,19],util:[],utilit:[],utlitii:14,uuid:[6,9,10,11],valid:8,valu:[2,7,8,10,14,16,17,19],valueerror:14,variabl:14,version:[3,8,14],via:[2,19],wait:[2,7,12],waiting_messag:10,walk:6,want:[8,12,14],warn:10,warranti:8,weak:[14,19],web:8,weight:[8,12,14],well:8,when:[1,2,3,4,6,8,9,10,11,14,15,16],where:[2,8,10,14,19],which:[2,8,10,14,15],who:[1,10],wish:17,without:[6,8,11],word:8,work:[3,6,14],worker:[],worker_id:10,worri:8,would:[12,14,19],wrap:2,wrapper:2,you:[3,8,10,11,12,14,17],your:[2,8,12,14],zcontext:[9,11],zero_index_cmp:16,zeromq:8,zmq:[7,8,9,10,11,14,15,17],zmqreceivemixin:14,zmqsendmixin:14,zmqstream:11,zsocket:[9,11]},titles:["API Documentation","<code class=\"docutils literal\"><span class=\"pre\">client</span></code> &#8211; Client Utilities","<code class=\"docutils literal\"><span class=\"pre\">messages</span></code> &#8211; Client Messaging","Contributing to EventMQ","<code class=\"docutils literal\"><span class=\"pre\">exceptions</span></code> &#8211; Exceptions","EventMQ Documentation","<code class=\"docutils literal\"><span class=\"pre\">jobmanager</span></code> &#8211; Job Manager","<code class=\"docutils literal\"><span class=\"pre\">poller</span></code> &#8211; Poller","EventMQ Protocol Specification","<code class=\"docutils literal\"><span class=\"pre\">receiver</span></code> &#8211; Receiver","<code class=\"docutils literal\"><span class=\"pre\">router</span></code> &#8211; Router","<code class=\"docutils literal\"><span class=\"pre\">sender</span></code> &#8211; Sender","Settings","Using EventMQ","<code class=\"docutils literal\"><span class=\"pre\">classes</span></code> &#8211; Utility Classes","<code class=\"docutils literal\"><span class=\"pre\">devices</span></code> &#8211; Device Utilities","<code class=\"docutils literal\"><span class=\"pre\">utils</span></code> &#8211; Utilities","<code class=\"docutils literal\"><span class=\"pre\">messages</span></code> &#8211; Message Utilities","<code class=\"docutils literal\"><span class=\"pre\">settings</span></code> &#8211; Settings Utilities","<code class=\"docutils literal\"><span class=\"pre\">timeutils</span></code> &#8211; Time Utilites"],titleterms:{"class":14,address:8,api:0,architectur:8,client:[1,2,8],concurrent_job:12,contribut:3,devic:15,disconnect:8,document:[0,5],emqp:8,eventmq:[3,5,8,13],except:4,frame:8,global:8,goal:8,header:8,heartbeat:8,indic:5,job:[6,12],jobmanag:6,kbai:8,languag:8,licens:8,manag:[6,12],messag:[2,17],poller:7,protocol:8,queue:12,receiv:9,router:[8,10,12],schedul:[8,12],sender:11,set:[12,18],specif:8,tabl:5,time:19,timeutil:19,topolog:8,util:[1,14,15,16,17,18],utilit:19,worker:8}}) \ No newline at end of file Search.setIndex({envversion:46,filenames:["api","client","client/jobs","client/messages","contributing","exceptions","index","jobmanager","poller","protocol","receiver","router","sender","settings_file","using","utils/classes","utils/devices","utils/index","utils/messages","utils/settings","utils/timeutils"],objects:{"eventmq.client":{jobs:[2,0,0,"-"],messages:[3,0,0,"-"]},"eventmq.client.jobs":{Job:[2,4,1,""],job:[2,3,1,""]},"eventmq.client.jobs.Job":{"__init__":[2,2,1,""],"__weakref__":[2,1,1,""]},"eventmq.client.messages":{defer_job:[3,3,1,""],schedule:[3,3,1,""],send_request:[3,3,1,""],send_schedule_request:[3,3,1,""]},"eventmq.exceptions":{CallableFromPathError:[5,5,1,""],EventMQError:[5,5,1,""],InvalidMessageError:[5,5,1,""],MessageError:[5,5,1,""],NoAvailableWorkerSlotsError:[5,5,1,""],PeerGoneAwayError:[5,5,1,""],UnknownQueueError:[5,5,1,""]},"eventmq.jobmanager":{JobManager:[7,4,1,""],mp_init:[7,3,1,""]},"eventmq.jobmanager.JobManager":{"__init__":[7,2,1,""],concurrent_jobs:[7,1,1,""],jobmanager_main:[7,2,1,""],name:[7,1,1,""],on_heartbeat:[7,2,1,""],on_request:[7,2,1,""],outgoing:[7,1,1,""],queues:[7,1,1,""],send_ready:[7,2,1,""],send_reply:[7,2,1,""]},"eventmq.poller":{Poller:[8,4,1,""]},"eventmq.poller.Poller":{"__init__":[8,2,1,""],poll:[8,2,1,""],register:[8,2,1,""],unregister:[8,2,1,""]},"eventmq.receiver":{Receiver:[10,4,1,""]},"eventmq.receiver.Receiver":{"__init__":[10,2,1,""],connect:[10,2,1,""],listen:[10,2,1,""],name:[10,1,1,""],ready:[10,1,1,""],unbind:[10,2,1,""],zcontext:[10,1,1,""],zsocket:[10,1,1,""]},"eventmq.router":{Router:[11,4,1,""]},"eventmq.router.Router":{add_scheduler:[11,2,1,""],add_worker:[11,2,1,""],clean_up_dead_schedulers:[11,2,1,""],clean_up_dead_workers:[11,2,1,""],executed_functions:[11,1,1,""],get_available_worker:[11,2,1,""],get_status:[11,2,1,""],job_latencies:[11,1,1,""],on_disconnect:[11,2,1,""],on_heartbeat:[11,2,1,""],on_inform:[11,2,1,""],on_ready:[11,2,1,""],on_reply:[11,2,1,""],on_request:[11,2,1,""],prioritize_queue_list:[11,6,1,""],process_client_message:[11,2,1,""],process_worker_message:[11,2,1,""],queues:[11,1,1,""],received_disconnect:[11,1,1,""],requeue_worker:[11,2,1,""],reset_heartbeat_counters:[11,2,1,""],router_main:[11,2,1,""],scheduler_queue:[11,1,1,""],schedulers:[11,1,1,""],send_ack:[11,2,1,""],send_heartbeat:[11,2,1,""],send_schedulers_heartbeats:[11,2,1,""],send_workers_heartbeats:[11,2,1,""],sighup_handler:[11,2,1,""],start:[11,2,1,""],waiting_messages:[11,1,1,""],workers:[11,1,1,""]},"eventmq.sender":{Sender:[12,4,1,""]},"eventmq.sender.Sender":{"__init__":[12,2,1,""],connect:[12,2,1,""],listen:[12,2,1,""],name:[12,1,1,""],ready:[12,1,1,""],rebuild:[12,2,1,""],unbind:[12,2,1,""],zcontext:[12,1,1,""],zsocket:[12,1,1,""]},"eventmq.utils":{classes:[15,0,0,"-"],devices:[16,0,0,"-"],messages:[18,0,0,"-"],random_characters:[17,3,1,""],settings:[19,0,0,"-"],timeutils:[20,0,0,"-"],tuplify:[17,3,1,""],zero_index_cmp:[17,3,1,""]},"eventmq.utils.classes":{EMQPService:[15,4,1,""],EMQdeque:[15,4,1,""],HeartbeatMixin:[15,4,1,""],ZMQReceiveMixin:[15,4,1,""],ZMQSendMixin:[15,4,1,""]},"eventmq.utils.classes.EMQPService":{"__weakref__":[15,1,1,""],is_heartbeat_enabled:[15,1,1,""],on_ack:[15,2,1,""],process_message:[15,2,1,""],reset:[15,2,1,""],send_inform:[15,2,1,""],start:[15,2,1,""]},"eventmq.utils.classes.EMQdeque":{"__init__":[15,2,1,""],"__weakref__":[15,1,1,""],append:[15,2,1,""],appendleft:[15,2,1,""],extend:[15,2,1,""],is_empty:[15,2,1,""],is_full:[15,2,1,""],is_pfull:[15,2,1,""],peek:[15,2,1,""],peekleft:[15,2,1,""],pop:[15,2,1,""],popleft:[15,2,1,""],remove:[15,2,1,""]},"eventmq.utils.classes.HeartbeatMixin":{"__init__":[15,2,1,""],"__weakref__":[15,1,1,""],is_dead:[15,2,1,""],reset_heartbeat_counters:[15,2,1,""],send_heartbeat:[15,2,1,""]},"eventmq.utils.classes.ZMQReceiveMixin":{"__weakref__":[15,1,1,""],recv:[15,2,1,""],recv_multipart:[15,2,1,""]},"eventmq.utils.classes.ZMQSendMixin":{"__weakref__":[15,1,1,""],send:[15,2,1,""],send_multipart:[15,2,1,""]},"eventmq.utils.devices":{generate_device_name:[16,3,1,""]},"eventmq.utils.messages":{fwd_emqp_router_message:[18,3,1,""],generate_msgid:[18,3,1,""],parse_message:[18,3,1,""],parse_router_message:[18,3,1,""],send_emqp_message:[18,3,1,""],send_emqp_router_message:[18,3,1,""]},"eventmq.utils.settings":{import_settings:[19,3,1,""]},"eventmq.utils.timeutils":{IntervalIter:[20,4,1,""],monotonic:[20,3,1,""],seconds_until:[20,3,1,""],timestamp:[20,3,1,""]},"eventmq.utils.timeutils.IntervalIter":{"__init__":[20,2,1,""],"__weakref__":[20,1,1,""]},eventmq:{client:[1,0,0,"-"],exceptions:[5,0,0,"-"],jobmanager:[7,0,0,"-"],poller:[8,0,0,"-"],receiver:[10,0,0,"-"],router:[11,0,0,"-"],sender:[12,0,0,"-"],utils:[17,0,0,"-"]}},objnames:{"0":["py","module","Python module"],"1":["py","attribute","Python attribute"],"2":["py","method","Python method"],"3":["py","function","Python function"],"4":["py","class","Python class"],"5":["py","exception","Python exception"],"6":["py","classmethod","Python class method"]},objtypes:{"0":"py:module","1":"py:attribute","2":"py:method","3":"py:function","4":"py:class","5":"py:exception","6":"py:classmethod"},terms:{"0mq":[9,15],"5min":20,"__init__":[2,7,8,10,12,15,20],"__weakref__":[2,15,20],"_empty_":9,"_headers_":9,"_msg_":9,"_msgid_":9,"_queue_name_":9,"_queues_":9,"_recipient_id":15,"_topic_name_":9,"_unix_ts_":9,"abstract":9,"boolean":15,"case":[9,15,20],"class":[],"default":[2,3,7,9,10,11,12,13,15],"float":[15,20],"function":[2,3,7,11],"import":[2,3,4,7,11,13,19],"int":[3,8,9,11,15,20],"long":[8,15],"new":[7,11,15],"public":9,"return":[3,4,8,10,11,12,15,16,17,18,20],"short":11,"true":[2,9,10,11,12,15],"while":9,abl:[11,13],about:[7,9,11],absolut:4,accept:[9,13,15],account:[11,18],ack:[7,9,11],ackd_msgid:15,acknowledg:[7,9,11],across:9,act:[1,9],actual:[7,11],add:11,add_schedul:11,add_work:11,addr:[10,12,15],address:[],administrative_addr:11,after:9,agre:9,all:[2,3,5,7,9,10,11,12,15],allow:9,alpha:9,alreadi:11,also:15,alwai:3,and_data:18,ani:[3,9,11,14,17],announc:11,anoth:[7,11,13],anyth:13,app:[2,15],appear:8,append:15,appendleft:15,appened:11,appli:19,applic:[3,9,14],arg2:3,arg3:3,arg:[2,3,7,8,10,11,12,15],argument:15,arithmet:20,arrai:9,as_str:2,ascii:16,assign:13,assum:20,async:2,attempt:[5,11],attr:8,automat:15,avail:[5,11],available_slot:11,awaiting_ack:15,back:[9,11,15],backend_addr:11,backward:15,base:[5,8,13,15],basi:9,becaus:[11,15],becom:13,been:[3,11,15],befor:[3,8,9],begin:[11,13,15,20],belong:11,below:9,best:3,between:[3,9,20],block:13,bool:[2,3,7,10,12,15],boot:20,both:[8,9],box:13,broadcast:9,broker:[2,7,9,14,15],broker_addr:[2,7],buffer:11,build:[11,12],built:9,bulid:10,calabl:3,calcul:20,call:[3,8,11,15],callabl:[3,5,7,10],callable_nam:5,callablefrompatherror:5,callback:15,can:[1,2,3,7,9,11,14,15,16,18],captur:15,care:16,caus:16,certain:15,chang:9,charact:17,check:[10,12,15],child:7,choos:13,circuit:11,class_arg:[3,7],class_kwarg:[3,7],classmethod:11,clean:9,clean_up_dead_schedul:11,clean_up_dead_work:11,clear:11,cli:11,client:[],clock:20,close:[15,20],cmp:17,code:[4,6,15],collect:15,colon:[3,13],com:2,come:[3,11],comma:9,command:[3,7,9,11,15,18],compar:17,compat:15,complet:9,compon:9,concurr:13,concurrent_job:[],conf:[],config:13,configur:[3,11,19],connction:[10,12],connect:[7,9,10,11,12,14,15,18],consist:9,construct:5,contact:5,contain:[1,9,11,15,17],context:[7,10,12],control:13,contruct:15,convers:9,convert:17,convienc:[8,15],copi:7,core:13,count:[7,9,11,20],counter:[11,15],cpu:13,creat:[2,11,12,17],cron:3,csv:9,current:[10,11,12,15],custom:11,cycl:13,data:[11,18],data_process:13,deal:17,dealer:12,death:15,debounc:3,debounce_deferred_job:3,debounce_sec:3,debug:9,decor:2,decsend:11,def:2,defeat:9,defer:[2,3],defer_job:3,defin:[2,3,7,9,10,12,15,20],deliv:[7,9],denot:3,depth:11,dequ:15,describ:9,descript:9,detail:9,detect:9,determin:9,devic:[],dialog:9,dict:[3,7,8],dictionari:[8,9,11],die:11,differ:4,directli:[8,15],disabl:3,distribut:9,doe:15,doesn:8,don:[7,9],dot:3,down:[13,20],dst:20,duplic:11,dure:12,each:11,effici:13,effort:3,either:[9,15],elaps:9,element:[11,15],els:[4,9],email:[2,9,13],emit:2,empti:[9,18],emq:11,emq_broker_addr:[2,14],emqdequ:15,emqpservic:15,enabl:[3,15],encod:16,encount:[3,5],end:[3,15],ensur:[3,7,9,15],entri:11,environ:[],equal:13,error:[3,15,16],etc:[11,13],evalu:3,even:9,event:[8,15],eventmq:[],eventmqerror:5,everi:[3,7],everyth:16,exampl:[11,13,15,20],excecut:11,except:[],exectu:11,execut:[2,3,9,13,20],executed_funct:11,exist:[5,7],explicitli:[13,15],expos:7,extend:15,extra:9,fail:[3,5,9],failur:3,fair:9,fals:[2,3,9,10,12,15],featur:16,few:4,field:9,file:13,find:15,finish:[9,11],first:[9,11,15,18],fit:9,flag:[3,8],follow:[3,9,15],foobar:2,fork:7,form:15,format:[3,7,9,11,18],forward:[11,15,18],found:[5,11,13],foundat:9,free:9,from:[2,5,7,8,9,10,11,12,15,20],frontend_addr:11,fuction:3,full:15,func:[2,3,7,15],function_nam:11,fwd_emqp_router_messag:18,gener:[7,8,9,10,12,18],generate_device_nam:16,generate_msgid:18,get:11,get_available_work:11,get_statu:11,give:3,given:[2,11],gmail:2,gnu:9,good:15,gotten:20,group:13,guarante:[3,9],guarente:3,hand:17,handl:[7,9,11,15],handler:7,happen:[3,8,11,12],hard:15,hasn:11,have:[3,13,15,18],haven:11,header:[],heartbeat:[],heartbeat_timeout:11,heartbeati:15,heartbeatmixin:15,heavi:9,help:13,helper:[],here:[9,11],highest:13,hit:15,hope:9,how:[3,8],html:9,http:9,ident:[9,16],identifi:11,ietf:9,ignor:[9,15],immedi:[3,9],immediatli:3,implement:[9,15],impli:9,import_set:19,includ:[3,9,15],index:[6,11,17],indexerror:11,indiviud:13,infinit:3,inform:[2,3,7,9,11,15],inherit:5,ini:[13,19],initi:[3,15],insert:[9,15],instal:4,instanc:7,instanti:[3,7],instead:9,integ:11,intens:13,interest:17,intern:5,interpret:9,interv:[3,9,20],interval_sec:[3,20],intervalit:20,invalidmessageerror:[5,11],is_dead:15,is_empti:15,is_ful:15,is_heartbeat_en:15,is_pful:15,isn:[11,15],issu:[4,6,9],item:15,iter:[8,11,15],iterat:15,itself:11,job:[],job_lat:11,job_schedul:3,jobmanag:[],jobmanager_main:7,json:3,keep:[7,11],kei:[8,9,11],kick:[7,11],kill:[3,9],know:[3,7,11],kwarg2:3,kwarg:[2,3,7,8,10,11,12,15],larg:13,larger:13,largest:11,last:[3,11,15],last_recv_heartbeat:11,lataneci:11,latenc:11,later:9,least:[9,15],leav:[9,13],left:15,length:[15,17],lesser:9,let:9,like:[7,15,17],limit:15,list:[2,3,5,7,9,11,13,15,17,20],listen:[7,10,11,12,13,15],load:13,local:13,locat:3,log:[3,7,11],logic:[7,11],login:2,longer:[5,13],look:15,loop:[8,11,15],lot:13,lower:11,mai:[9,11,15],main:7,make:17,malform:5,manag:[],mani:[3,9,12],manual:9,master:9,match:15,mean:3,measur:11,member:11,memebership:11,merchant:9,mess:20,messag:[],message_bodi:18,message_id:18,messageerror:5,met:15,meta:[11,18],method:[3,7,8,11,15],mime:2,mimetext:2,minut:3,model:13,modifi:9,modul:[1,6,7,17],monoton:[11,15,20],more:[2,3,9,15,17],most:15,mp_init:7,msg:[2,7,9,11,15,18],msgid:[7,11,15],multipart:[9,15],multiprocess:[7,13],must:[3,9,15],name:[2,3,7,9,10,11,12,13,19],need:[7,11,12],never:[7,9,20],next:[8,11,13,20],noavailableworkerslotserror:[5,11],nohast:9,none:[2,3,7,10,11,12,15,16,18],noop:7,normal:15,note:[7,10,12],notifi:15,now:15,number:[3,11,13,20],numer:20,obj:11,object:[2,8,15,17,20],occur:15,off:[7,11],on_ack:15,on_command:[11,15],on_disconnect:11,on_emqp_command:15,on_ful:15,on_heartbeat:[7,11],on_inform:11,on_readi:11,on_recv:10,on_repli:11,on_request:[7,11],on_schedul:15,onc:9,onlin:[11,15],option:[3,7,9,10,12,18],order:11,org:9,orient:9,origin:9,original_msg:11,other:[3,9,13],otherwis:[7,10,12,15],out:[7,9,15],outgo:[7,15],own:15,page:6,param:3,paramet:[2,3,7,8,10,11,12,15,16,17,18,19,20],pars:[11,15,18],parse_messag:18,parse_router_messag:18,part:[9,18],particular:[2,9,12],pass:[3,9,10,15],password:2,path:[3,5,7],payload:18,peek:15,peekleft:15,peer:[5,9,15],peergoneawayerror:[5,11],pend:9,per:11,pfull:15,pictur:9,placehold:[7,11],point:13,poll:8,poller:[],pollin:8,pollout:8,pool:[9,11],pop:[11,15],popleft:15,port:11,portion:7,possibl:4,practic:15,prefix:[16,18],prepar:11,prepend:9,pretti:[9,13],priorit:11,prioriti:11,prioritiess:11,prioritize_queue_list:11,problem:5,process:[7,9,11,12,13,15],process_client_messag:11,process_messag:[7,15],process_worker_messag:11,programm:15,proper:15,properti:[10,12,15],protocol:[],protocol_vers:15,provid:[2,11,15],pub:9,publish:9,purpos:9,push_notif:15,py2:20,py3:20,python3:16,python:[7,15],queue:[],queue_nam:11,quit:2,rais:[3,5,10,11,12,15,18],random:[17,18],random_charact:17,raw:15,readi:[7,9,10,11,12,13,15],rebind:11,rebuild:12,rebuilt:7,receiv:[],received_disconnect:11,recent:[9,11],recipi:[2,7,11,15,18],recipient_id:18,recommend:[9,13,15],reconnect:12,recurs:[11,17],recus:11,recv:15,recv_multipart:15,redistribut:9,refer:[2,7,9,15,20],regist:[7,8,11],regular:9,reject:15,rel:4,reliabl:9,reload:11,remain:8,remot:15,remov:[9,11,15],reopen:15,rep:10,repli:[2,3,7,9,11,18],reply_request:3,repres:20,req:12,request:[1,3,7,9,11,15],requeue_work:11,requir:9,reset:[11,15],reset_heartbeat_count:[11,15],resourc:[7,9],respond:[9,11,15],respons:[7,10,11,12],restart:[9,12],retri:[3,9,11],retry_count:3,rfc2119:9,rfc:9,right:15,robin:9,roughli:12,round:9,rout:[9,11],router:[],router_main:11,run:[2,3,7,9,11,13,15],safe:13,sake:20,same:[12,17],schedul:[],scheduler_id:11,scheduler_queu:11,scheduler_zmq_id:11,search:6,sec:3,second:[3,9,20],seconds_until:20,section:19,see:[2,3,8,9,11,15],self:[7,11,12,15],semi:13,send:[2,3,5,7,9,11,12,15,18],send_ack:11,send_email:2,send_emqp_messag:18,send_emqp_router_messag:18,send_heartbeat:[11,15],send_inform:15,send_multipart:15,send_readi:7,send_repli:7,send_request:3,send_schedule_request:3,send_schedulers_heartbeat:11,send_workers_heartbeat:11,sender:[],sender_id:18,sendmail:2,sent:[3,7,9,11,13,15],seper:[3,9,13],serial:11,serializ:3,serv:9,server:[],servic:[9,15],service_typ:15,set:[],shall:9,should:[2,3,5,8,9,10,11,12,13,14,15,18],shown:9,sighup:11,sighup_handl:11,signal:7,signum:11,similar:13,simpl:[11,17],sinc:20,singl:[9,15],size:15,skip:[12,15],skip_sign:7,skip_zmqstream:12,slot:11,slow:13,smaller:13,smtp:2,smtplib:2,socket:[3,7,8,9,10,11,12,15,16,18],softwar:9,some:[3,7,13,15,17,18],someon:9,someth:[3,12,13,15,20],somewher:4,sort:17,sourc:[4,6],spawn:7,specif:[],specifi:[9,15,17],standard:13,start:[7,10,11,12,13,15,20],start_valu:20,state:[11,15],statu:9,still:[2,11,13],stop:9,store:11,str:[2,3,7,10,11,12,15,16,17,18,19],string:[3,9,10,11,12,15,16,18],structur:5,style:13,sub:9,subclass:5,subcmd:7,subcommand:[3,7],subject:[2,9],subset:9,subtract:20,success:9,successfulli:15,support:15,synchron:2,system:[4,11],take:[11,12,15,16,18],task:[3,7],tcp:11,tell:7,term:9,termin:7,test:[2,7],text:2,thei:[3,15],them:10,thi:[1,2,3,5,7,8,9,10,11,12,13,15,16,17,18,20],thier:13,thing:[3,7,12,13,15,17,18],those:7,thread:13,threshold:15,through:[9,11],time:[],timeout:[3,8,9],timestamp:[9,11,20],timeutil:[],tip:4,tool:9,topic:9,trace:9,track:[7,11,15],tri:3,tune:13,tupl:[7,8,11,15,17,18],tuplifi:17,type:[3,9,10,11,12,15,17,18],type_:15,typecast:8,typeerror:[3,10],unabl:11,unbind:[10,12],undefin:[2,8],under:9,unicod:16,uniqu:[7,9,11],unit:[2,7],unix:9,unknownqueueerror:[5,11],unless:[7,10,12],unprioritized_iter:11,unregist:8,unschedul:[3,9],until:[13,20],untouch:[11,18],unus:9,updat:15,upon:9,upstream:7,usag:[2,20],usual:[15,20],util:[],utilit:[],utlitii:15,uuid:[7,10,11,12],valid:9,valu:[2,3,8,9,11,15,17,18,20],valueerror:15,variabl:[],version:[4,9,15],via:[3,20],wait:[3,8,13],waiting_messag:11,walk:7,want:[2,9,13,15],warn:[2,11],warranti:9,weak:[2,15,20],web:9,weight:[9,13,15],well:9,when:[1,3,4,5,7,9,10,11,12,15,16,17],where:[3,9,11,15,20],which:[3,9,11,15,16],who:[1,11],wish:18,without:[7,9,12],word:9,work:[4,7,15],worker:[],worker_id:11,worri:9,would:[13,15,20],wrap:3,wrapper:3,you:[2,4,9,11,12,13,15,18],your:[3,9,13,15],zcontext:[10,12],zero_index_cmp:17,zeromq:9,zmq:[8,9,10,11,12,15,16,18],zmqreceivemixin:15,zmqsendmixin:15,zmqstream:12,zsocket:[10,12]},titles:["API Documentation","<code class=\"docutils literal\"><span class=\"pre\">client</span></code> &#8211; Client Utilities","<code class=\"docutils literal\"><span class=\"pre\">jobs</span></code> &#8211; Client Job Helpers","<code class=\"docutils literal\"><span class=\"pre\">messages</span></code> &#8211; Client Messaging","Contributing to EventMQ","<code class=\"docutils literal\"><span class=\"pre\">exceptions</span></code> &#8211; Exceptions","EventMQ Documentation","<code class=\"docutils literal\"><span class=\"pre\">jobmanager</span></code> &#8211; Job Manager","<code class=\"docutils literal\"><span class=\"pre\">poller</span></code> &#8211; Poller","EventMQ Protocol Specification","<code class=\"docutils literal\"><span class=\"pre\">receiver</span></code> &#8211; Receiver","<code class=\"docutils literal\"><span class=\"pre\">router</span></code> &#8211; Router","<code class=\"docutils literal\"><span class=\"pre\">sender</span></code> &#8211; Sender","Server Settings (eventmq.conf)","Using EventMQ","<code class=\"docutils literal\"><span class=\"pre\">classes</span></code> &#8211; Utility Classes","<code class=\"docutils literal\"><span class=\"pre\">devices</span></code> &#8211; Device Utilities","<code class=\"docutils literal\"><span class=\"pre\">utils</span></code> &#8211; Utilities","<code class=\"docutils literal\"><span class=\"pre\">messages</span></code> &#8211; Message Utilities","<code class=\"docutils literal\"><span class=\"pre\">settings</span></code> &#8211; Settings Utilities","<code class=\"docutils literal\"><span class=\"pre\">timeutils</span></code> &#8211; Time Utilites"],titleterms:{"class":15,address:9,api:0,architectur:9,client:[1,2,3,9,14],concurrent_job:13,conf:13,contribut:4,devic:16,disconnect:9,document:[0,6],emqp:9,environ:14,eventmq:[4,6,9,13,14],except:5,frame:9,global:9,goal:9,header:9,heartbeat:9,helper:2,indic:6,job:[2,7,13],jobmanag:7,kbai:9,languag:9,licens:9,manag:[7,13],messag:[3,18],poller:8,protocol:9,queue:13,receiv:10,router:[9,11,13],schedul:[9,13],sender:12,server:13,set:[13,19],specif:9,tabl:6,time:20,timeutil:20,topolog:9,util:[1,15,16,17,18,19],utilit:20,variabl:14,worker:9}}) \ No newline at end of file
diff --git a/sender.html b/sender.html
index 9ab4d42..7d0f5d1 100644
--- a/sender.html
+++ b/sender.html
@@ -61,7 +61,7 @@
61 61
62 62
63 <div class="version"> 63 <div class="version">
64 0.2.7 64 0.2.7.1
65 </div> 65 </div>
66 66
67 67
@@ -310,7 +310,7 @@ socket</li>
310 310
311 <div role="contentinfo"> 311 <div role="contentinfo">
312 <p> 312 <p>
313 &copy; Copyright 2016, eventboard.io. 313 &copy; Copyright 2016, EventMQ Contributors.
314 314
315 </p> 315 </p>
316 </div> 316 </div>
diff --git a/settings_file.html b/settings_file.html
index 673302d..591bc6a 100644
--- a/settings_file.html
+++ b/settings_file.html
@@ -8,7 +8,7 @@
8 8
9 <meta name="viewport" content="width=device-width, initial-scale=1.0"> 9 <meta name="viewport" content="width=device-width, initial-scale=1.0">
10 10
11 <title>Settings &mdash; EventMQ 0 documentation</title> 11 <title>Server Settings (eventmq.conf) &mdash; EventMQ 0 documentation</title>
12 12
13 13
14 14
@@ -61,7 +61,7 @@
61 61
62 62
63 <div class="version"> 63 <div class="version">
64 0.2.7 64 0.2.7.1
65 </div> 65 </div>
66 66
67 67
@@ -84,7 +84,7 @@
84 84
85 <ul class="current"> 85 <ul class="current">
86<li class="toctree-l1 current"><a class="reference internal" href="using.html">Using EventMQ</a><ul class="current"> 86<li class="toctree-l1 current"><a class="reference internal" href="using.html">Using EventMQ</a><ul class="current">
87<li class="toctree-l2 current"><a class="current reference internal" href="">Settings</a><ul> 87<li class="toctree-l2 current"><a class="current reference internal" href="">Server Settings (eventmq.conf)</a><ul>
88<li class="toctree-l3"><a class="reference internal" href="#router">Router</a></li> 88<li class="toctree-l3"><a class="reference internal" href="#router">Router</a></li>
89<li class="toctree-l3"><a class="reference internal" href="#scheduler">Scheduler</a></li> 89<li class="toctree-l3"><a class="reference internal" href="#scheduler">Scheduler</a></li>
90<li class="toctree-l3"><a class="reference internal" href="#job-manager">Job Manager</a><ul> 90<li class="toctree-l3"><a class="reference internal" href="#job-manager">Job Manager</a><ul>
@@ -94,6 +94,7 @@
94</li> 94</li>
95</ul> 95</ul>
96</li> 96</li>
97<li class="toctree-l2"><a class="reference internal" href="using.html#client-environment-variables">Client Environment Variables</a></li>
97</ul> 98</ul>
98</li> 99</li>
99<li class="toctree-l1"><a class="reference internal" href="api.html">API Documentation</a></li> 100<li class="toctree-l1"><a class="reference internal" href="api.html">API Documentation</a></li>
@@ -130,7 +131,7 @@
130 131
131 <li><a href="using.html">Using EventMQ</a> &raquo;</li> 132 <li><a href="using.html">Using EventMQ</a> &raquo;</li>
132 133
133 <li>Settings</li> 134 <li>Server Settings (eventmq.conf)</li>
134 <li class="wy-breadcrumbs-aside"> 135 <li class="wy-breadcrumbs-aside">
135 136
136 137
@@ -144,8 +145,8 @@
144 <div role="main" class="document" itemscope="itemscope" itemtype="http://schema.org/Article"> 145 <div role="main" class="document" itemscope="itemscope" itemtype="http://schema.org/Article">
145 <div itemprop="articleBody"> 146 <div itemprop="articleBody">
146 147
147 <div class="section" id="settings"> 148 <div class="section" id="server-settings-eventmq-conf">
148<h1>Settings<a class="headerlink" href="#settings" title="Permalink to this headline">¶</a></h1> 149<h1>Server Settings (eventmq.conf)<a class="headerlink" href="#server-settings-eventmq-conf" title="Permalink to this headline">¶</a></h1>
149<p>EventMQ uses a standard INI style config file found at <code class="docutils literal"><span class="pre">/etc/eventmq.conf</span></code>.</p> 150<p>EventMQ uses a standard INI style config file found at <code class="docutils literal"><span class="pre">/etc/eventmq.conf</span></code>.</p>
150<div class="section" id="router"> 151<div class="section" id="router">
151<h2>Router<a class="headerlink" href="#router" title="Permalink to this headline">¶</a></h2> 152<h2>Router<a class="headerlink" href="#router" title="Permalink to this headline">¶</a></h2>
@@ -209,7 +210,7 @@ run.</p>
209 210
210 <div role="contentinfo"> 211 <div role="contentinfo">
211 <p> 212 <p>
212 &copy; Copyright 2016, eventboard.io. 213 &copy; Copyright 2016, EventMQ Contributors.
213 214
214 </p> 215 </p>
215 </div> 216 </div>
diff --git a/using.html b/using.html
index 770465d..05a7c90 100644
--- a/using.html
+++ b/using.html
@@ -31,7 +31,7 @@
31 31
32 32
33 <link rel="top" title="EventMQ 0 documentation" href="index.html"/> 33 <link rel="top" title="EventMQ 0 documentation" href="index.html"/>
34 <link rel="next" title="Settings" href="settings_file.html"/> 34 <link rel="next" title="Server Settings (eventmq.conf)" href="settings_file.html"/>
35 <link rel="prev" title="EventMQ Documentation" href="index.html"/> 35 <link rel="prev" title="EventMQ Documentation" href="index.html"/>
36 36
37 37
@@ -60,7 +60,7 @@
60 60
61 61
62 <div class="version"> 62 <div class="version">
63 0.2.7 63 0.2.7.1
64 </div> 64 </div>
65 65
66 66
@@ -83,7 +83,8 @@
83 83
84 <ul class="current"> 84 <ul class="current">
85<li class="toctree-l1 current"><a class="current reference internal" href="">Using EventMQ</a><ul> 85<li class="toctree-l1 current"><a class="current reference internal" href="">Using EventMQ</a><ul>
86<li class="toctree-l2"><a class="reference internal" href="settings_file.html">Settings</a></li> 86<li class="toctree-l2"><a class="reference internal" href="settings_file.html">Server Settings (eventmq.conf)</a></li>
87<li class="toctree-l2"><a class="reference internal" href="#client-environment-variables">Client Environment Variables</a></li>
87</ul> 88</ul>
88</li> 89</li>
89<li class="toctree-l1"><a class="reference internal" href="api.html">API Documentation</a></li> 90<li class="toctree-l1"><a class="reference internal" href="api.html">API Documentation</a></li>
@@ -136,7 +137,7 @@
136<h1>Using EventMQ<a class="headerlink" href="#using-eventmq" title="Permalink to this headline">¶</a></h1> 137<h1>Using EventMQ<a class="headerlink" href="#using-eventmq" title="Permalink to this headline">¶</a></h1>
137<div class="toctree-wrapper compound"> 138<div class="toctree-wrapper compound">
138<ul> 139<ul>
139<li class="toctree-l1"><a class="reference internal" href="settings_file.html">Settings</a><ul> 140<li class="toctree-l1"><a class="reference internal" href="settings_file.html">Server Settings (eventmq.conf)</a><ul>
140<li class="toctree-l2"><a class="reference internal" href="settings_file.html#router">Router</a></li> 141<li class="toctree-l2"><a class="reference internal" href="settings_file.html#router">Router</a></li>
141<li class="toctree-l2"><a class="reference internal" href="settings_file.html#scheduler">Scheduler</a></li> 142<li class="toctree-l2"><a class="reference internal" href="settings_file.html#scheduler">Scheduler</a></li>
142<li class="toctree-l2"><a class="reference internal" href="settings_file.html#job-manager">Job Manager</a></li> 143<li class="toctree-l2"><a class="reference internal" href="settings_file.html#job-manager">Job Manager</a></li>
@@ -144,6 +145,10 @@
144</li> 145</li>
145</ul> 146</ul>
146</div> 147</div>
148<div class="section" id="client-environment-variables">
149<h2>Client Environment Variables<a class="headerlink" href="#client-environment-variables" title="Permalink to this headline">¶</a></h2>
150<p><code class="docutils literal"><span class="pre">EMQ_BROKER_ADDR</span></code> is the address a client should use to connect to the broker. The client can be any application using EventMQ.</p>
151</div>
147</div> 152</div>
148 153
149 154
@@ -153,7 +158,7 @@
153 158
154 <div class="rst-footer-buttons" role="navigation" aria-label="footer navigation"> 159 <div class="rst-footer-buttons" role="navigation" aria-label="footer navigation">
155 160
156 <a href="settings_file.html" class="btn btn-neutral float-right" title="Settings" accesskey="n">Next <span class="fa fa-arrow-circle-right"></span></a> 161 <a href="settings_file.html" class="btn btn-neutral float-right" title="Server Settings (eventmq.conf)" accesskey="n">Next <span class="fa fa-arrow-circle-right"></span></a>
157 162
158 163
159 <a href="index.html" class="btn btn-neutral" title="EventMQ Documentation" accesskey="p"><span class="fa fa-arrow-circle-left"></span> Previous</a> 164 <a href="index.html" class="btn btn-neutral" title="EventMQ Documentation" accesskey="p"><span class="fa fa-arrow-circle-left"></span> Previous</a>
@@ -165,7 +170,7 @@
165 170
166 <div role="contentinfo"> 171 <div role="contentinfo">
167 <p> 172 <p>
168 &copy; Copyright 2016, eventboard.io. 173 &copy; Copyright 2016, EventMQ Contributors.
169 174
170 </p> 175 </p>
171 </div> 176 </div>
diff --git a/utils/classes.html b/utils/classes.html
index d03614e..830f787 100644
--- a/utils/classes.html
+++ b/utils/classes.html
@@ -61,7 +61,7 @@
61 61
62 62
63 <div class="version"> 63 <div class="version">
64 0.2.7 64 0.2.7.1
65 </div> 65 </div>
66 66
67 67
@@ -679,7 +679,7 @@ specify the the recipient id of the remote socket</li>
679 679
680 <div role="contentinfo"> 680 <div role="contentinfo">
681 <p> 681 <p>
682 &copy; Copyright 2016, eventboard.io. 682 &copy; Copyright 2016, EventMQ Contributors.
683 683
684 </p> 684 </p>
685 </div> 685 </div>
diff --git a/utils/devices.html b/utils/devices.html
index 93d3de0..c377682 100644
--- a/utils/devices.html
+++ b/utils/devices.html
@@ -61,7 +61,7 @@
61 61
62 62
63 <div class="version"> 63 <div class="version">
64 0.2.7 64 0.2.7.1
65 </div> 65 </div>
66 66
67 67
@@ -193,7 +193,7 @@ causes errors when setting the IDENTITY of the ZMQ socket.</p>
193 193
194 <div role="contentinfo"> 194 <div role="contentinfo">
195 <p> 195 <p>
196 &copy; Copyright 2016, eventboard.io. 196 &copy; Copyright 2016, EventMQ Contributors.
197 197
198 </p> 198 </p>
199 </div> 199 </div>
diff --git a/utils/index.html b/utils/index.html
index 2369eb1..8214412 100644
--- a/utils/index.html
+++ b/utils/index.html
@@ -61,7 +61,7 @@
61 61
62 62
63 <div class="version"> 63 <div class="version">
64 0.2.7 64 0.2.7.1
65 </div> 65 </div>
66 66
67 67
@@ -219,7 +219,7 @@ when sorting the values in <code class="xref py py-attr docutils literal"><span
219 219
220 <div role="contentinfo"> 220 <div role="contentinfo">
221 <p> 221 <p>
222 &copy; Copyright 2016, eventboard.io. 222 &copy; Copyright 2016, EventMQ Contributors.
223 223
224 </p> 224 </p>
225 </div> 225 </div>
diff --git a/utils/messages.html b/utils/messages.html
index f4e13aa..65731a1 100644
--- a/utils/messages.html
+++ b/utils/messages.html
@@ -61,7 +61,7 @@
61 61
62 62
63 <div class="version"> 63 <div class="version">
64 0.2.7 64 0.2.7.1
65 </div> 65 </div>
66 66
67 67
@@ -299,7 +299,7 @@ used by a <code class="xref py py-attr docutils literal"><span class="pre">zmq.R
299 299
300 <div role="contentinfo"> 300 <div role="contentinfo">
301 <p> 301 <p>
302 &copy; Copyright 2016, eventboard.io. 302 &copy; Copyright 2016, EventMQ Contributors.
303 303
304 </p> 304 </p>
305 </div> 305 </div>
diff --git a/utils/settings.html b/utils/settings.html
index 3a19cd3..fe62e9d 100644
--- a/utils/settings.html
+++ b/utils/settings.html
@@ -61,7 +61,7 @@
61 61
62 62
63 <div class="version"> 63 <div class="version">
64 0.2.7 64 0.2.7.1
65 </div> 65 </div>
66 66
67 67
@@ -188,7 +188,7 @@
188 188
189 <div role="contentinfo"> 189 <div role="contentinfo">
190 <p> 190 <p>
191 &copy; Copyright 2016, eventboard.io. 191 &copy; Copyright 2016, EventMQ Contributors.
192 192
193 </p> 193 </p>
194 </div> 194 </div>
diff --git a/utils/timeutils.html b/utils/timeutils.html
index b3ace5e..6cebb34 100644
--- a/utils/timeutils.html
+++ b/utils/timeutils.html
@@ -61,7 +61,7 @@
61 61
62 62
63 <div class="version"> 63 <div class="version">
64 0.2.7 64 0.2.7.1
65 </div> 65 </div>
66 66
67 67
@@ -236,7 +236,7 @@ time.time()</p>
236 236
237 <div role="contentinfo"> 237 <div role="contentinfo">
238 <p> 238 <p>
239 &copy; Copyright 2016, eventboard.io. 239 &copy; Copyright 2016, EventMQ Contributors.
240 240
241 </p> 241 </p>
242 </div> 242 </div>
generated by cgit v1.2.1 (git 2.18.0) at 2026-01-12 04:57:58 +0000