Pg backing store

[Matt Williams]

Hi guys, I'm trying to convert from using a single MQ server to
multiple ones backed by a postgres store but I'm not actually seeing a
message make it on the queue nor do I see any schema or data make it
into the database. The problem is there is no error output anywhere.
Also, please note that the message I'm putting and popping off the
queue works fine when just running mq.pl with the defaults.

From my development box:
perl /usr/local/bin/mq.pl --crash-cmd 'echo /tmp/crash.log' --stats --
storage dbi --front-store none --dbi-dsn
DBI:Pg:database=pocomq;hostname=127.0.0.1 --dbi-username pocomq --dbi-
password 12345 --pump-freq 1 --mq-id api1 --data-dir /tmp/perl_mq

After pushing a message, the log reads:
RECV (7): CONNECT :
RECV (7): SEND message B78A5174-58CB-11E1-9A26-3275048EC984 (17688
bytes) to /queue/emails (persistent: 1)
MASTER: Removing client 7
...
(nothing follows)

Starting from zero stats, sending a message, and turning on the
subscriber produced the following in stats.yml:
ID: 'POE::Component::MessageQueue version 0.2.12 (PID: 24501)'
generated: Thu Feb 16 14:04:55 2012
queues:
emails:
avg_secs_stored: 0
avg_size_recvd: 17688
sent: 0
stored: 0
subscriptions: 1
total_recvd: 1
total_sent: 0
total_stored: 0
subscriptions: 1
total_sent: 0
total_stored: 0

Also, the /tmp/crash.log is empty. Any help would be greatly
appreciated!

[Naveed Massjouni]

On Thu, Feb 16, 2012 at 5:20 PM, Matt Williams <ma...@williams-tech.net> wrote:
> Hi guys, I'm trying to convert from using a single MQ server to
> multiple ones backed by a postgres store but I'm not actually seeing a
> message make it on the queue nor do I see any schema or data make it
> into the database. The problem is there is no error output anywhere.
> Also, please note that the message I'm putting and popping off the
> queue works fine when just running mq.pl with the defaults.

To be clear, are you saying you are trying to deploy multiple MQ
servers pointing to the same database backend?
-Naveed

[Matt Williams]

That's correct. I followed the guide here:
https://metacpan.org/module/POE::Component::MessageQueue::Manual::Clustering
I only have the one queue at the moment but I intend to add another
once I have this issue resolved.

-Matt

On Feb 16, 8:44 pm, Naveed Massjouni <navee...@gmail.com> wrote:

[Matt Williams]

I found a couple of lines that were commented out in
POE::Component::MessageQueue::Storage

line 97: debug => 1
line 98: verbose => 1

I uncommented them and got a bit more information - though it still
isn't very telling...

RECV (7): SEND message 0D91BD26-5C11-11E1-849E-8A54AE895CBB (14 bytes)
to /queue/testing (persistent: 1)
poe-generic: 13042: processing request store
poe-generic: request put at /usr/local/lib/perl5/site_perl/5.14.1/POE/
Component/Generic.pm line 455.
RECV (7): DISCONNECT
MASTER: Removing client 7
poe-generic: 13042: processing request disown_all
poe-generic: request put at /usr/local/lib/perl5/site_perl/5.14.1/POE/
Component/Generic.pm line 455.

I'm out of ideas at this point.


On Feb 16, 5:44 pm, Naveed Massjouni <navee...@gmail.com> wrote: