ActiveMQ Topic Persistence - ActiveMQ restart

[joesan <co...@gmail.com>]

Dear users,

I have an ActiveMQ broker that contains a topic in it. I have pre-configured
the topic as a start up destination. I have written a producer and a
consumer. The following is what I do:

(1) Start ActiveMQ broker
(2) Start my producer. As soon as I do this, my producer starts publishing
messages to the pre-configured topic destination. I leave my producer to run
and accumulate about 200 messages or so.
(3) I restart my ActiveMQ

As soon as I restart my ActiveMQ, I do not see anymore messages (that got
accumulated in the topic before restart) in the admin console. Why is that
the messages are lost though they have been persisted to the persistent data
store? How do I get my messages in the topic back after ActiveMQ restart



--
View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-Topic-Persistence-ActiveMQ-restart-tp4667501.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ Topic Persistence - ActiveMQ restart

[joesan <co...@gmail.com>]

I figured that out now. But anyways thanks for the post!



--
View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-Topic-Persistence-ActiveMQ-restart-tp4667501p4667503.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ Topic Persistence - ActiveMQ restart

[bizcenter <bi...@gmail.com>]

you should use durable sbuscription!

You follow these steps
    1. Create a durable topic subscription
    2. Publish some messages to the topic(Qos: set persistent to true)

more to see:
http://activemq.apache.org/why-do-i-not-receive-messages-on-my-durable-topic-subscription.html



--
View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-Topic-Persistence-ActiveMQ-restart-tp4667501p4667502.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Did anyone experience the java.io.SyncFailedException during AMQ use?

[Christian Posta <ch...@gmail.com>]

Disk problems? What kind of disk, OS and filesystem are you using?


On Mon, May 27, 2013 at 4:22 AM, lzr <js...@163.com> wrote:

> Dear all,
>
>
> Now I'm running activemq 5.6 and found the following exception, did any
> experience the same problem and fix it?
> xxxx | ERROR | KahaDB failed to store to Journal |
> org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Transport: xxx
> java.io.SyncFailedException: sync failed
> at java.io.FileDescriptor.sync(Native Method)
> at
> org.apache.kahadb.journal.DataFileAppender.processQueue(DataFileAppender.java:367)
> at
> org.apache.kahadb.journal.DataFileAppender$1.run(DataFileAppender.java:188)
>
>
> It would be much appreciated if any suggestions!
>
>
> Best regards,
> Zhuran




-- 
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta

Did anyone experience the java.io.SyncFailedException during AMQ use?

[lzr <js...@163.com>]

Dear all,


Now I'm running activemq 5.6 and found the following exception, did any experience the same problem and fix it?
xxxx | ERROR | KahaDB failed to store to Journal | org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Transport: xxx
java.io.SyncFailedException: sync failed
at java.io.FileDescriptor.sync(Native Method)
at org.apache.kahadb.journal.DataFileAppender.processQueue(DataFileAppender.java:367)
at org.apache.kahadb.journal.DataFileAppender$1.run(DataFileAppender.java:188)


It would be much appreciated if any suggestions!


Best regards,
Zhuran