Comments (6)
Please post a script that reproduces the problem. We also need full server logs.
This plugin needs a new build for 3.6.7 and up, I'm not sure about 3.6.6. A new build for 3.6.7+ should be coming later today or tomorrow.
from rabbitmq-lvc-exchange.
#!/usr/bin/python2.7
import sys
import pika
queue_name='PresenceQueue1'
exchange_name='RMQKodLvc'
target_ip='XX.XX.XX.141'
credentials = pika.PlainCredentials('guest', 'guest')
parameters = pika.ConnectionParameters(target_ip, 5672, 'RMQBroker', credentials)
connection = pika.BlockingConnection(parameters)
mdn_list=[91003, 91004, 91005]
def on_message(channel, method, properties,body):
print "message: {0}".format(body)
if body=='91005_TF3':
channel.stop_consuming()
def iterate(list):
channel = connection.channel()
channel.exchange_declare(exchange=exchange_name, type="x-lvc", durable=True, auto_delete=False);
channel.queue_declare(queue=queue_name, durable=True, auto_delete=True);
for mdn in list:
bind_key='prod.'+str(mdn)+'.kodiakptt.com'
print bind_key
channel.queue_bind(
exchange=exchange_name,
queue=queue_name,
routing_key=bind_key
)
channel.basic_consume(on_message, queue=queue_name, no_ack=True)
channel.start_consuming()
iterate(mdn_list)
connection.close()
from rabbitmq-lvc-exchange.
Thank you!
from rabbitmq-lvc-exchange.
OK, I've just tried this with the tip of stable and a new build of this plugin and it seems to work. I will produce a new LVC release in a bit.
from rabbitmq-lvc-exchange.
A new version is up on Bintray.
from rabbitmq-lvc-exchange.
Thanks Michael. new version is working fine..
from rabbitmq-lvc-exchange.
Related Issues (15)
- Unable to read lvc message with wildcard routing Keys HOT 3
- Does x-lvc supports federation policies. HOT 2
- [In]compatibility with recent RabbitMQ versions HOT 3
- Payload return a memory position instead of the message HOT 2
- Issue with LVC exchange - Mnesia is not replicating the contents for a LVC table
- Durable LVC exchange should persist the cached message (if persistent) across RabbitMQ restarts. HOT 8
- Branch v3.8.x no longer builds - can't find include lib "rabbit/include/amqqueue.hrl" HOT 2
- Plugin does not start with {invalid_ez,einval} error HOT 4
- Retry waiting for schema database tables the same way RabbitMQ core does
- Reset of cache
- does not work with latest rabbitMQ 3.9.13
- Where is the Plugin for RabbitMQ 3.11? HOT 2
- x-lvc does not handle message expiration HOT 1
- Add support for e2e binding HOT 3
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from rabbitmq-lvc-exchange.