from kombu import Connection, Exchange, Queue
from flask import Flask
import os

app = Flask(__name__)
app.config.from_object(os.environ.get('SETTINGS'))

@app.route("/getnextqueuemessage")
#Gets the next message from target queue.  Returns the signed JSON.
def get_last_queue_message():
    #: By default messages sent to exchanges are persistent (delivery_mode=2),
    #: and queues and exchanges are durable.
    exchange = Exchange()
    connection = Connection(app.config['OUTGOING_QUEUE_HOSTNAME'])

    # Create/access a queue bound to the connection.
    queue = Queue(app.config['OUTGOING_QUEUE'], exchange, routing_key='#')(connection)
    queue.declare()

    message = queue.get()

    if message:
        signature = message.body
        message.ack() #acknowledges message, ensuring its removal.
        return signature
    else:
        return "no message", 404



@app.route("/removeallmessages")
#Gets the next message from target queue.  Returns the signed JSON.
def remove_all_messages():
    while True:
        queue_message = get_last_queue_message()
        if queue_message == 'no message':
            break
    return "done", 202


@app.route("/")
def check_status():
    return "Everything is OK"


from kombu import Connection, Exchange, Queue
from flask import Flask
import os

app = Flask(__name__)
app.config.from_object(os.environ.get('SETTINGS'))

@app.route("/getnextqueuemessage")
#Gets the next message from target queue.  Returns the signed JSON.
def get_last_queue_message():
    #: By default messages sent to exchanges are persistent (delivery_mode=2),
    #: and queues and exchanges are durable.
    exchange = Exchange()
    connection = Connection(app.config['OUTGOING_QUEUE_HOSTNAME'])

    # Create/access a queue bound to the connection.
    queue = Queue(app.config['OUTGOING_QUEUE'], exchange, routing_key='#')(connection)
    queue.declare()

    message = queue.get()

    if message:
        signature = message.body
        message.ack() #acknowledges message, ensuring its removal.
        return signature
    else:
        return "no message", 404



@app.route("/removeallmessages")
#Gets the next message from target queue.  Returns the signed JSON.
def remove_all_messages():
    while True:
        queue_message = get_last_queue_message()
        if queue_message == ('no message', 404):
            break
    return "done", 202


@app.route("/")
def check_status():
    return "Everything is OK"


Remove all has to reflect changes to get next
Remove all has to reflect changes to get next