An enumeration of current transport metadata.
Unless otherwise noted, these only support outbound messages that are replies to a previous message and only one reply per message.
class WikipediaTestCase(TestCase): | |
def setUp(self): | |
self.sample_xml = ("""<?xml version="1.0"?> | |
<SearchSuggestion xmlns="http://opensearch.org/searchsuggest2" | |
version="2.0"> | |
<Query xml:space="preserve">africa</Query> | |
<Section> | |
<Item> | |
<Text xml:space="preserve">Africa</Text> | |
<Description xml:space="preserve">Africa is the world's""" |
2011-10-28 09:19:59+0000 [WorkerAMQClient,client] Starting a CropPriceWorker worker with config: {'transport_name': 'integrat', 'worker_name': 'ussd_crop_prices', 'api_url': 'http://127.0.0.1:8000/api/v1'} | |
2011-10-28 09:19:59+0000 [WorkerAMQClient,client] Started the publisher | |
2011-10-28 09:19:59+0000 [WorkerAMQClient,client] Staring IntegratInboundDynamicConsumer with {'exchange_name': 'vumi', 'queue_name': 'integrat.inbound', 'routing_key': 'integrat.inbound', 'durable': True, 'exchange_type': 'direct'} | |
2011-10-28 09:19:59+0000 [WorkerAMQClient,client] Consumer starting... | |
2011-10-28 09:19:59+0000 [WorkerAMQClient,client] Staring IntegratEventDynamicConsumer with {'exchange_name': 'vumi', 'queue_name': 'integrat.event', 'routing_key': 'integrat.event', 'durable': True, 'exchange_type': 'direct'} | |
2011-10-28 09:19:59+0000 [WorkerAMQClient,client] Unhandled error in Deferred: | |
2011-10-28 09:19:59+0000 [WorkerAMQClient,client] Unhandled Error | |
Traceback (most recent call last): | |
File "/vol/var/pr |
diff --git a/vumi/transports/vas2nets/vas2nets.py b/vumi/transports/vas2nets/vas2nets.py | |
index 06ef000..6ba1c03 100644 | |
--- a/vumi/transports/vas2nets/vas2nets.py | |
+++ b/vumi/transports/vas2nets/vas2nets.py | |
@@ -252,8 +252,9 @@ class Vas2NetsTransport(Transport): | |
'provider': message['transport_metadata']['network_id'], | |
'tariff': message['transport_metadata'].get('tariff', 0), | |
'text': validate_characters(message['content']), | |
- 'subservice': message['transport_metadata'].get( | |
- 'keyword', self.config['subservice']), |
diff --git a/vumi/transports/telnet/tests/test_telnet.py b/vumi/transports/telnet/tests/test_telnet.py | |
index e5a72d0..4e407fc 100644 | |
--- a/vumi/transports/telnet/tests/test_telnet.py | |
+++ b/vumi/transports/telnet/tests/test_telnet.py | |
@@ -35,6 +35,7 @@ class TelnetServerTransportTestCase(TransportTestCase): | |
super(TelnetServerTransportTestCase, self).setUp() | |
self.worker = yield self.get_transport({'telnet_port': 0}) | |
self.client = yield self.make_client() | |
+ yield self.wait_for_client_start() | |
diff --git a/docs/dispatchers.rst b/docs/dispatchers.rst | |
index fb87be6..50ad0d1 100644 | |
--- a/docs/dispatchers.rst | |
+++ b/docs/dispatchers.rst | |
@@ -17,11 +17,14 @@ Examples of use cases for dispatchers: | |
* A single application that sends and receives both SMSes and XMPP | |
messages. | |
-* A single SMPP transports that sends and receives SMSes on behalf of | |
+* A single application that sends and receives SMSes in multiple |
;; fly-make-mode for Python | |
;; pycheck is in ~/bin | |
(when (load "flymake" t) | |
(defun flymake-python-init () | |
(let* ((temp-file (flymake-init-create-temp-buffer-copy | |
'flymake-create-temp-inplace)) | |
(local-file (file-relative-name | |
temp-file | |
(file-name-directory buffer-file-name)))) |
[ui] | |
merge=internal:merge | |
[pager] | |
pager = less -R | |
[extensions] | |
mq = | |
fetch = | |
rebase = |
[ui] | |
merge=internal:merge | |
[pager] | |
pager = less -R | |
[extensions] | |
mq = | |
fetch = | |
rebase = |
[ui] | |
merge=internal:merge | |
[pager] | |
pager = less -R | |
[extensions] | |
mq = | |
fetch = | |
rebase = |