Page MenuHomeDevCentral
Files F5037090

D1649.id4215.diff
No OneTemporary
Actions

D1649.id4215.diff
View Options

diff --git a/app.py b/app.py
--- a/app.py
+++ b/app.py
@@ -11,8 +11,8 @@
# -------------------------------------------------------------
"""
-This module connects to the message broker, fire a web server,
-and allow to interact through the broker from HTTP requests.
+This module connects to the message broker, fires a web server,
+and allows to interact through the broker from HTTP requests.
"""
from flask import Flask, abort, jsonify, request
@@ -37,7 +37,7 @@
def check_config():
- """Ensure configuration is complete."""
+ """Ensures configuration is complete."""
return set(mandatory_environment_variables()).issubset(os.environ)
@@ -77,7 +77,7 @@
def get_credentials(config):
- """Get credentials to connect to the broker from the configuration."""
+ """Gets credentials to connect to the broker from the configuration."""
return pika.PlainCredentials(
username=config['Broker']['User'],
password=config['Broker']['Password'],
@@ -93,7 +93,7 @@
def get_broker_connection(config):
- """Connect to the broker."""
+ """Connects to the broker."""
parameters = get_broker_connection_parameters(config)
return pika.BlockingConnection(parameters)
@@ -119,12 +119,12 @@
def get_queue_name(queue_key):
- """Map a queue name with its key."""
+ """Maps a queue name with its key."""
return "delivery-" + queue_key
def add_broker_queue(exchange_name, routing_key):
- """Add a queue to the broker, bind to the exchange."""
+ """Adds a queue to the broker, bind to the exchange."""
queue_key = generate_queue_key()
queue_name = get_queue_name(queue_key)
@@ -140,7 +140,7 @@
# We've created a queue but we can't use it,
# so let's try to delete it through a new connection.
try:
- print("Deleting unused queue: {0}".format(queue_name))
+ print("Deleting not used queue: {0}".format(queue_name))
delete_broker_queue(queue_name, True)
except pika.exceptions.ChannelClosed:
pass
@@ -168,7 +168,7 @@
def get_exchange_from_request():
- """Get the exchange name from the request, the environment, or abort."""
+ """Gets the exchange name from the request, the environment, or aborts."""
exchange_name = get_variable_from_request("exchange")
if exchange_name is None:
@@ -190,13 +190,13 @@
@app.route(endpoint + "/status")
def status():
- """Determine if the application returns a 200 on GET request."""
+ """Determines if the application returns a 200 on GET request."""
return "ALIVE"
@app.route(endpoint + "/register_consumer", methods=['POST'])
def register_consumer():
- """Subscribe to an exchange, record the queue, send queue key."""
+ """Subscribes to an exchange, records the queue, sends queue key."""
# Reads request
if not request.json:
@@ -241,14 +241,14 @@
def initialize_application():
- """Initialize a container with required services."""
+ """Initializes a container with required services."""
return {
'config': get_config()
}
def run_application(web_application):
- """Run the server."""
+ """Runs the server."""
if not check_config():
sys.exit(1)

File Metadata

Mime Type
text/plain
Expires
Wed, Mar 5, 01:32 (13 h, 4 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2460620
Default Alt Text
D1649.id4215.diff (3 KB)

Event Timeline

Nasqueron DevCentral · If it had been much bigger the moon would have had a core of ice. · Powered by Phabricator