tonyg / rabbithub Goto Github PK
View Code? Open in Web Editor NEWExperimental RabbitMQ PubSubHubBub interface
Experimental RabbitMQ PubSubHubBub interface
This is the output of the command line. rabbithub plug-in is expecting a plugin named "rabbitmq_mochiweb", which I can't find on my rabbitmq distribution. I've tried enabling similar plugins (see below), with no success.
root@ubuntu:/mnt/hgfs/Shared# sudo rabbitmq-plugins enable rabbithub
Error: The following dependencies could not be found:
rabbitmq_mochiweb
root@ubuntu:/mnt/hgfs/Shared# sudo rabbitmq-plugins enable mochiweb
Plugin configuration unchanged.
root@ubuntu:/mnt/hgfs/Shared# sudo rabbitmq-plugins enable webmachine
Plugin configuration unchanged.
root@ubuntu:/mnt/hgfs/Shared# sudo rabbitmq-plugins enable rabbithub
Error: The following dependencies could not be found:
rabbitmq_mochiweb
Is there a way to solve this ?
I am trying to install rabbithub plugin through the mentioned steps in the Readme file but I am stuck in the installation itself. At the step where 'make' is to be done after 'make deps', an error pops up saying -
src/rabbithub_pseudo_queue.erl:27: record amqqueue undefined
src/rabbithub_pseudo_queue.erl:26: Warning: variable 'Pid' is unused
src/rabbithub_pseudo_queue.erl:26: Warning: variable 'QueueName' is unused
src/rabbithub_pseudo_queue.erl:27: record amqqueue undefined
src/rabbithub_pseudo_queue.erl:26: Warning: variable 'Pid' is unused
src/rabbithub_pseudo_queue.erl:26: Warning: variable 'QueueName' is unused
ERROR: compile failed while processing /home/paridhi/rabbithub: rebar_abort
Makefile:40: recipe for target 'compile' failed
make: *** [compile] Error 1
I tried declaring the record amqqueue in the specified file but then same record seems to be undeclared in some other file. Any idea why this might be happening?
On my mac, RabbitMQ with rabbithub as a plugin often (nearly always, in fact) fails to start.
It aborts in rabbithub_app:setup_schema while calling mnesia:create_table, and gives {badtype, rabbithub_lease, disc_copies, rabbit@localhost} as the reason.
It's easy to elicit this from mnesia:
$ erl
1> mnesia:start().
ok
2> mnesia:create_table(foo, [{attributes, [bar, baz]}, {disc_copies, [node()]}]).
{aborted,{bad_type,foo,disc_copies,nonode@nohost}}
This doesn't happen if you've called mnesia:create_schema/1 before starting mnesia. But wait -- that's exactly what setup_schema does!
I suspect there's a race between RabbitMQ calling mnesia:create_schema/1 and mnesia:start/0, and rabbithub doing so then trying to create the table.
We are using the RabbitHub Rabbitmq plugin (https://github.com/brc859844/rabbithub) and experiencing the following issue:
When a queue is pre-populated (say 1000 msgs) then a subscriber is created, or when the publishing volume is sufficiently higher than the subscriber callback rate, each subscriber POST's 99 messages to the callback URL then gets the following error
=ERROR REPORT==== 12-Apr-2016::17:47:51 ===
RabbitHub post error
{rabbithub_consumer,http_post_failure,socket_closed_remotely,{}}
=INFO REPORT==== 12-Apr-2016::17:47:51 ===
RabbitHub stopping consumer, normal
{state,{rabbithub_subscription,{resource,<<"/">>,queue,<<"foo">>},
"foo",
"http://gregg-VirtualBox:8999/rabbithub/sub1"},
#Ref<0.0.1.85179>,<<"amq.http.consumer-zLIH5VOb2BdVbtLR_4J4pw">>}
If we re-up the subscription then the same pattern happens again, 99 msgs are POSTed to the callback URL then we get the same error. The error is per subscriber as I setup 2 queues, 1 with 1 subscriber, 1 with 2 subscribers each with a unique callback URL and each callback URL received 99 msg's then the error occurred for each subscriber.
We tried another server with similar situation and the number was as consistent, but always failed between 98-101 messages.
The backend server hosting the callback does not seem to be the issue, we can hit it directly with a load much higher than what RabbitHub is sending with no issues at all.
Based on some forum posts on the socket_closed_remotely error we tried the following rabbitmq.config
{rabbithub, [
{http_client_options, [
{max_keep_alive_length, 0},
{max_pipeline_length, 0}, {max_sessions, 0}
]}
]}
but it had no effect on the situation. Any assistance on how to fix this issue would be greatly appreciated.
Thanks
Gregg
A declarative, efficient, and flexible JavaScript library for building user interfaces.
๐ Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
An Open Source Machine Learning Framework for Everyone
The Web framework for perfectionists with deadlines.
A PHP framework for web artisans
Bring data to life with SVG, Canvas and HTML. ๐๐๐
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
Some thing interesting about web. New door for the world.
A server is a program made to process requests and deliver data to clients.
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Some thing interesting about visualization, use data art
Some thing interesting about game, make everyone happy.
We are working to build community through open source technology. NB: members must have two-factor auth.
Open source projects and samples from Microsoft.
Google โค๏ธ Open Source for everyone.
Alibaba Open Source for everyone
Data-Driven Documents codes.
China tencent open source team.