messages not being sent consistently

0 views
Skip to first unread message

Glennstar

unread,
Sep 2, 2009, 12:24:34 PM9/2/09
to PoCo::MQ
Hi,
I have a test server with the latest 0.2.6 build of poco::mq. It
dispatches messages when there is a process connected to the relevant
queue but not when there are messages on the queue and a process
subsequently connects.
I have added a log below. Any feedback welcome.


Glenn


[20090902 16:54:21] notice (63) RECV (10): CONNECT hello:there
[20090902 16:54:21] notice (63) RECV (10): SUBSCRIBE /queue/foo (ack:
client)
[20090902 16:54:21] debug (63) -- PUMP QUEUE: /queue/foo --
[20090902 16:54:40] notice (63) RECV (12): CONNECT hello:there
[20090902 16:54:40] notice (63) RECV (12): SEND message
EC7510E2-97D8-11DE-AB96-D6B997C0922D (23 bytes) to /queue/foo
(persistent: 1)
[20090902 16:54:40] info (63) QUEUE: Message EC7510E2-97D8-11DE-AB96-
D6B997C0922D claimed by 10 during send
[20090902 16:54:40] info (63) STORE: COMPLEX: FRONT: Added
EC7510E2-97D8-11DE-AB96-D6B997C0922D
[20090902 16:54:40] info (63) Dispatching message EC7510E2-97D8-11DE-
AB96-D6B997C0922D to client 10
[20090902 16:54:40] notice (63) RECV (12): DISCONNECT
[20090902 16:54:40] notice (63) MASTER: Removing client 12
[20090902 16:54:40] notice (63) RECV (10): ACK - message
EC7510E2-97D8-11DE-AB96-D6B997C0922D
[20090902 16:54:40] debug (63) -- PUMP QUEUE: /queue/foo --
[20090902 16:54:55] notice (63) MASTER: Removing client 10
[20090902 16:54:55] debug (63) -- PUMP QUEUE: /queue/foo --
[20090902 16:55:00] notice (63) RECV (13): CONNECT hello:there
[20090902 16:55:00] notice (63) RECV (13): SEND message
F8942EE4-97D8-11DE-AB96-D6B997C0922D (23 bytes) to /queue/foo
(persistent: 1)
[20090902 16:55:00] info (63) STORE: COMPLEX: FRONT: Added
F8942EE4-97D8-11DE-AB96-D6B997C0922D
[20090902 16:55:00] debug (63) -- PUMP QUEUE: /queue/foo --
[20090902 16:55:00] notice (63) RECV (13): DISCONNECT
[20090902 16:55:00] notice (63) MASTER: Removing client 13
[20090902 16:55:04] info (63) STORE: COMPLEX: Pushing expired messages
(F8942EE4-97D8-11DE-AB96-D6B997C0922D) to backstore.
[20090902 16:55:04] debug (63) STORE: COMPLEX: BACK: STORAGE: Finished
writing message F8942EE4-97D8-11DE-AB96-D6B997C0922D to disk
[20090902 16:55:06] notice (63) RECV (14): CONNECT hello:there
[20090902 16:55:06] notice (63) RECV (14): SUBSCRIBE /queue/foo (ack:
client)
[20090902 16:55:06] debug (63) -- PUMP QUEUE: /queue/foo --
[20090902 16:55:06] info (63) STORE: COMPLEX: FRONT: Message
F8942EE4-97D8-11DE-AB96-D6B997C0922D claimed by client 14

Glennstar

unread,
Sep 2, 2009, 12:51:44 PM9/2/09
to PoCo::MQ
Having tested a little bit further it appears that while the messages
are in the front-store, everything is fine. As soon as they are
somitted to the backing store things go wrong. I am running this from
mq.pl. Is there any way I can easily change the backing store engine
to test if this is the case or not?

Glenn
Reply all
Reply to author
Forward
0 new messages