Stack Overflow
Stack Overflow

Questions tagged [stomp.py]

Stomp.py is a Python library for STOMP Protocol

Stomp.py providing access to a message broker using the STOMP protocol either programmatically or using a command line client.

23 questions
6
votes
3 answers

ActiveMQ - STOMP+SSL with Python STOMP client

Can anyone explain me how to add SSL to the Python STOMP client I'm using. I added the stomp+ssl transport connector in the ActiveMQ configuration file and my basic Python STOMP client is below: import time import sys import stomp class…
shravan kusuma
  • 109
  • 1
  • 2
  • 9
2
votes
1 answer

How to stack received messages and process them in batch

I'd like to create a consumer which stacks arriving messages, and waits: until n messages have arrived. t seconds are elapsed. to process the whole stack of messages. Pre-fetching is not what I'm looking for. What I really need is to process…
Ghilas BELHADJ
  • 13,412
  • 10
  • 59
  • 99
1
vote
1 answer

Stomp listeners are dropping after some time but program is running without showing any errors

I have a stomp listener on an Activemq queue which just drops itself after being up for a while. The program itself shows no error and shows in running state but listener listed on Activemq UI just shows 0 after some time. I am using this code class…
Aviral Tyagi
  • 13
  • 3
1
vote
1 answer

Stomp.py not processing one message at a time

I am using Stomp.py connecting to a standard ACtiveMQ server. I am simulating cases where the receiver crashes and I want to be able to restart it and it continue running from the message after the one that caused it to crash. I have created two…
Robert3452
  • 1,354
  • 2
  • 17
  • 39
1
vote
1 answer

How to specify topic or queue when sending/subscribing to a JMS object, ActiveMQ Artemis and STOMP

I'm using ActiveMQ Artemis messaging system, and I'm testing my setup with STOMP (stomp.py). I created an "address" on Artemis called Site.SOF.Order.Fulfillment.Submission.ActiveOmni.Topic, and attached two queues to it:…
BenW
  • 737
  • 10
  • 41
1
vote
1 answer

How to force disconnect from ActiveMQ connection with Stomp.py

When listening to a message queue using a durable connection I get an error in the listener. I simulate this by hitting CTRL-Z to quit the program. Trying to re-connect gives me a an error that says: on_error! : "javax.jms.InvalidClientIDException:…
Edison
  • 870
  • 1
  • 13
  • 28
1
vote
1 answer

Django + Activemq and long running connections in the Webserver

I have been using stomp.py and stompest for years now to communicate with activemq to great effect, but this has mostly been with standalone python Daemons. I would like to use these two libraries from the webserver to communicate with the backend,…
user3253945
  • 13
  • 3
1
vote
1 answer

AMQ_SCHEDULED_DELAY is not delaying message when use stomp.py

I am running ActiveMQ server on docker container. I am using AMQ_SCHEDULED_DELAY headers to delay the message. import time import sys import stomp class MyListener(stomp.ConnectionListener): def on_error(self, headers, message): …
Nilesh
  • 20,521
  • 16
  • 92
  • 148
0
votes
1 answer

How to capture heartbeat timeout using Python Stomp connection

I am constantly getting this heartbeat timeout issue, and the receiver sits idle then. The skeleton of my code is like: def connect_and_subscribe(conn): the_id = 1111 user = 'my_user' password = 'my_password' destination =…
xymzh
  • 63
  • 5
0
votes
1 answer

clear ActiveMQ queue with stomp

Is there any way I can clear/delete ActiveMQ's queues from either stomp.py or stomp-js in Angular TypeScript?
qwerty_99
  • 640
  • 5
  • 20
0
votes
0 answers

Failover with Python using STOMP library

I am trying to implement fail-over in my Python applications using STOMP to connect to ActiveMQ brokers (in Amazon MQ). I have 2 brokers (B1, B2), 1 producer (P1), 1 consumer (C1). I am expecting that I only have to connect to a single broker(B1) in…
ans98
  • 96
  • 1
  • 5
0
votes
0 answers

Get response for send() in stomp.py to retry the in case of failure

Below is my listener class with the subscriber import os import time import stomp def connect_and_subscribe(conn): conn.connect('guest', 'guest', wait=True) conn.subscribe(destination='/queue/test', id=1, ack='auto') class…
Umesh K
  • 51
  • 1
  • 2
0
votes
2 answers

Receiving "Error reading in simpleString, length=[] is greater than readableBytes=[]" sending message to ActiveMQ using Stomp.py

I'm trying to send and receive messages using Apache ActiveMQ Artemis 2.24, using Python to send messages using STOMP, and receiving messages in Java. The Stomp.py version is 8.0.1. Python version is 3.10.4. Java version is 1.8.0_342. If I run my…
mindcrime
  • 657
  • 8
  • 23
0
votes
0 answers

Using stomp.py to pick up messages and quit

I'm wondering how to use stomp.py client in a pick-process-finish manner. This means: start; connect; check the queue; pick messages; process them; disconnect; finish. The lib seems to be designed for indefinitely running clients which listen on…
Yuri
  • 4,254
  • 1
  • 29
  • 46
0
votes
1 answer

Implementing heartbeat in stomp.py

I am seeing behavior in our stomp.py 7.0 client (listener only) where after some idle time of not receiving messages the ActiveMQ 5.15.9 broker seems to drop the client (i.e. looking at the ActiveMQ management console shows zero consumers). The odd…
user2714417
  • 53
  • 9
1
2