ASV Messaging Queue API for message passing between processes.
Project description
# SRM Autonomous Surface Vehicle Messaging Queue API
------
The team SRMASV uses this repository as an API to transfer data from one process or device to another process or device.
------
### Installation
------
To install just type in the following command:
`pip install asvmq`
There are three type of topologies involved:
1. [x] Topic Topology
2. [ ] Work Queue Topology
3. [ ] Merge Topology
## Instructions for Use:
#### Publisher
The `publisher` objects sends data over RabbitMQ broker, acting as the sole messenger to send data over the `asvmq` exchange.
The message has to either be an instance of a protobuf message, or it must be a string to be sent over, otherwise the publisher will generate an error and not send your message altogether.
The syntax of Publisher is asvmq.Publisher(**topic_name**,**object_type**,hostname, port)
Here, the required arguments are bolded.
If the parameter passed to the publish method is a protobuf message, you need not serialise the message, but instead pass the protobuf object to the method itself.
To use the `publisher` object, write the code in the following manner:
```
import asvmq
import asvprotobuf.*_pb2
pub = asvmq.Publisher("hello", asvprotobuf.sensor_pb2.Imu)
while True:
pub.publish("Hello world!!")
```
------
The team SRMASV uses this repository as an API to transfer data from one process or device to another process or device.
------
### Installation
------
To install just type in the following command:
`pip install asvmq`
There are three type of topologies involved:
1. [x] Topic Topology
2. [ ] Work Queue Topology
3. [ ] Merge Topology
## Instructions for Use:
#### Publisher
The `publisher` objects sends data over RabbitMQ broker, acting as the sole messenger to send data over the `asvmq` exchange.
The message has to either be an instance of a protobuf message, or it must be a string to be sent over, otherwise the publisher will generate an error and not send your message altogether.
The syntax of Publisher is asvmq.Publisher(**topic_name**,**object_type**,hostname, port)
Here, the required arguments are bolded.
If the parameter passed to the publish method is a protobuf message, you need not serialise the message, but instead pass the protobuf object to the method itself.
To use the `publisher` object, write the code in the following manner:
```
import asvmq
import asvprotobuf.*_pb2
pub = asvmq.Publisher("hello", asvprotobuf.sensor_pb2.Imu)
while True:
pub.publish("Hello world!!")
```
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
asvmq-0.1.6.tar.gz
(5.2 kB
view details)
Built Distributions
asvmq-0.1.6-py3.7.egg
(13.5 kB
view details)
asvmq-0.1.6-py3-none-any.whl
(6.6 kB
view details)
File details
Details for the file asvmq-0.1.6.tar.gz
.
File metadata
- Download URL: asvmq-0.1.6.tar.gz
- Upload date:
- Size: 5.2 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/1.12.1 pkginfo/1.5.0.1 requests/2.21.0 setuptools/40.7.1 requests-toolbelt/0.9.1 tqdm/4.30.0 CPython/3.7.2
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 8ad249f013efa939725205a9dfda613c478b86b0e177daf28b9a3d46b89b7a2f |
|
MD5 | 4c11053ae3ece1c704866ab4aae64881 |
|
BLAKE2b-256 | 2a668b4cd7c7b77443613f3e06144fd133aaf4cf2525d5945b10798bd2c36b12 |
File details
Details for the file asvmq-0.1.6-py3.7.egg
.
File metadata
- Download URL: asvmq-0.1.6-py3.7.egg
- Upload date:
- Size: 13.5 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/1.12.1 pkginfo/1.5.0.1 requests/2.21.0 setuptools/40.7.1 requests-toolbelt/0.9.1 tqdm/4.30.0 CPython/3.7.2
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | db5ca2238e5931e23708ceb933c24f96b3b08e7c6cf132faf90491d5de44be6e |
|
MD5 | e14f67841218a821bd077b787f7d4d61 |
|
BLAKE2b-256 | 750b1664d2a88f5ff33816a544066c733091fba15e63364d10aa5fb55f31a29a |
File details
Details for the file asvmq-0.1.6-py3-none-any.whl
.
File metadata
- Download URL: asvmq-0.1.6-py3-none-any.whl
- Upload date:
- Size: 6.6 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/1.12.1 pkginfo/1.5.0.1 requests/2.21.0 setuptools/40.7.1 requests-toolbelt/0.9.1 tqdm/4.30.0 CPython/3.7.2
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 83404580bf9ff9ce3478e9c6819cc11179c29dc5f965b08aabcf8cb01f2a23ec |
|
MD5 | 19aff9567599420e422eb7eb2fcd102e |
|
BLAKE2b-256 | 03993a2dce91bcd059ad29939ed6248ff858cc0fc00d8518226ddec17f8c1675 |