“stomp.py” is a Python client library for accessing messaging servers (such as ActiveMQ or RabbitMQ) using the STOMP protocol (versions 1.0, 1.1 and 1.2). It can also be run as a standalone, command-line client for testing.
Apache License 2.0
492
stars
167
forks
source link
Not receiving the same sized data stream as what was sent #319
So I wrote a simple script to test stomp.py communicating through an ActiveMQ broker.
I am trying to send a bytes stream of 184 bytes through the connection:
self.m_conn.send(body=data, destination="/topic/" + self.m_topic) #len(data) = 184
What I am receiving on the other end is intermittent sometimes 181 sometimes its 182
def on_message(self, headers, message):print(len(message)) #prints 181 or 182
This only happens when both the producer and consumer of the message is a stomp.py implementation. If I send data from stomp.py to the broker and then to a C++ process it works just fine, and vice versa.
So I wrote a simple script to test stomp.py communicating through an ActiveMQ broker. I am trying to send a bytes stream of 184 bytes through the connection:
self.m_conn.send(body=data, destination="/topic/" + self.m_topic) #len(data) = 184
What I am receiving on the other end is intermittent sometimes 181 sometimes its 182
def on_message(self, headers, message):
print(len(message)) #prints 181 or 182
This only happens when both the producer and consumer of the message is a stomp.py implementation. If I send data from stomp.py to the broker and then to a C++ process it works just fine, and vice versa.