I have an existing flask application (having a bunch of REST apis) which is hosted by Gunicorn. I also have to send and receive messages from AmazonMQ in the same application. I have functions using stomp.py to send/receive messages from AmazonMQ, but I am not sure where to place them, or how should I use them so as to keep existing flow intact
Placing stomp.py consumer/producer inside Flask-Gunicorn python application
361 Views Asked by Arindam At
1
There are 1 best solutions below
Related Questions in PYTHON
- new thread blocks main thread
- Extracting viewCount & SubscriberCount from YouTube API V3 for a given channel, where channelID does not equal userID
- Display images on Django Template Site
- Difference between list() and dict() with generators
- How can I serialize a numpy array while preserving matrix dimensions?
- Protractor did not run properly when using browser.wait, msg: "Wait timed out after XXXms"
- Why is my program adding int as string (4+7 = 47)?
- store numpy array in mysql
- how to omit the less frequent words from a dictionary in python?
- Update a text file with ( new words+ \n ) after the words is appended into a list
- python how to write list of lists to file
- Removing URL features from tokens in NLTK
- Optimizing for Social Leaderboards
- Python : Get size of string in bytes
- What is the code of the sorted function?
Related Questions in FLASK
- Executing database query gives "TypeError: not all arguments converted during string formatting"
- Flask custom "not found" code
- Python Flask shutdown event handler
- HTML call that triggers daemon subprocess
- Any way to use jinja2 and flask form instead of ajax and jquery or both?
- Deploying flask app on gunicorn, module object has no attribute
- Flask-Restful, oauth, and Salesforce
- Why doesn't my WTForms-JSON form update correctly?
- Apply different stylesheets to different elements of a template
- Flask server to notify webclient when changes occur
- How to let a Reference Field accept multiple Document schemas in MongoEngine?
- Creating 2 dimensional array in Python Flask application Jinja2 Template
- How to do a custom query in Model View on *-to-Many relationship in Flask Admin?
- Syntax error python 2.7
- Load image using $resource in AngularJS
Related Questions in GUNICORN
- Deploying flask app on gunicorn, module object has no attribute
- how to avoid flask insert duplicate entries?
- Gunicorn Django cannot find wsgi module
- SQLAlchemy extension isn't registered when running app with Gunicorn
- Gunicorn ImportError: No module named
- Apache / Gunicorn and Django Issue
- cassandra rises operation time out in uwsgi server
- Run supervisor in virtual environment
- Formatting Flask app logs in json
- Flask session not persistent across requests in Flask app with Gunicorn on Heroku
- Flask redirect ignores base URL with nginx gunicorn
- Restarting Gunicorn/Nginx when changes are made to files
- Correct configuration for Flask SocketIO
- HTTPS with gunicorn?
- "502 Bad Gateway" error after killing Gunicorn processes
Related Questions in AMAZON-MQ
- AmazonMQ/ActiveMQ Message RedeliveryPolicy MaximumRedeliveries Ignored
- AWS solution for data transfers between Amazon MQ and Amazon MSK
- System.Security.Authentication.AuthenticationException - ActiveMQ NMS Connection Start() method giving exception in .Net 4.5 version
- Configuring Maximum Concurrent Message Processing in Amazon MQ w/ActiveMQ with JMS
- Issue with ClickHouse Connection to Amazon MQ for RabbitMQ via AMQPS
- Which TLS/SSL version does Amazon MQ client uses to connect to brokers?
- AMQPSSLConnection connection timeout
- Unable to open direct websocket connection (without stomp) to amazonmq
- Fail connect to AmazonMQ using Symfony messenger
- Failed to connect with Amazon MQ Event Source from Lambda
- Not able to connect to AWS Active MQ broker
- How to use spring-messaging-5.1.* to connect stomp+ssl broker?
- Python Lambda function to capture AWS cloud watch logs of AWS MQ and send to kinesis
- Create Cloudwatch event rule which will trigger AWS MQ Python Lambda Function
- AWS | Syntax error in module': invalid syntax
Related Questions in STOMP.PY
- Placing stomp.py consumer/producer inside Flask-Gunicorn python application
- Python stomp.py connection gets disconnected and listener stops working
- Don't let stomp.py delete packet from ActiveMQ untill the whole packet is processed
- Django + Activemq and long running connections in the Webserver
- AWS ActiveMQ fetch messages from a Consumer and send to a queue
- How to capture heartbeat timeout using Python Stomp connection
- Stomp.py send with custom headers fails
- Stomp.py not processing one message at a time
- Failover with Python using STOMP library
- Stomp listeners are dropping after some time but program is running without showing any errors
- Message count is not zero even after all messages are consumed and acknowledged
- ActiveMQ: Cant enable SSL over Stomp
- ActiveMQ - STOMP+SSL with Python STOMP client
- Using stomp.py to pick up messages and quit
- How to specify topic or queue when sending/subscribing to a JMS object, ActiveMQ Artemis and STOMP
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
Hey thanks for help @AKX, I resolved the issue by triggering the whole process of messaging (Creation of connection, subscription to channel etc) by a method call from on_starting(server) method in gunicorn_config.py