uss.
>
> Persistent messages are stored in the Message Store, such as KahaDB. The
> KahaDB architecture comprises several elements: datalogs, cache, BTree
> indexes, etc.
>
> In addition to the Message Store, ActiveMQ has another element where messages
> are also stored: Message
Hi,
I'm trying to understand how ActiveMQ's broker manages persistent messages
internally, and I have some questions that I'd like to discuss.
Persistent messages are stored in the Message Store, such as KahaDB. The KahaDB
architecture comprises several elements: datalogs, cache
ActiveMQ Artemis fully implements the JMS specification so any client using
JMS (e.g. Apache Camel) should work without issues. For what it's worth,
Artemis ships with an example [1] using Apache Camel for bridging messages
between a 5.x broker instance and an Artemis instance.
The ActiveMQ 5.x ha
Hi Tim,
Thanks for your suggestions.
Saying that, moving to ActiveMQ Artemis would be the ideal option. I'm also
not sure whether all the features being used by us (camel routes are used to
produce and consume JMS messages) with ActiveMQ 5.14.4 will be available in
ActiveMQ Artemis 2.5.0.
>From
mmunity after we went live
> with LevelDB, we have stuck to it as we accomplished HA through replicated
> message store which is not available in KahaDB). Now we have reached a
> threshold point where we can't withstand any further LevelDB corrupt and
> lose the messages store
replicated
message store which is not available in KahaDB). Now we have reached a
threshold point where we can't withstand any further LevelDB corrupt and
lose the messages store over there.
We are looking for the possible way forward to solve this and it would be
great if the community can he
pulls the messages 100 at a time form queue of same type.
Thus was expecting consumer to pull all 3 messages, but it did consume only
the once that inserted via Broker1.
This certainly explains me there is message store cached per Broker, which
is not good and causing problems.
--
View this
messages, but it did consume only
the once that inserted via Broker1.
This certainly explains me there is message store cached per Broker, which
is not good and causing problems.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Duplicate-Messages-in-the-Message-Store
deleted, how
> can
> it get the MAX(ID)?
>
> Thanks,
> Sri
>
>
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.
> nabble.com/Duplicate-Messages-in-the-Message-Store-tp4724959.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
t:
http://activemq.2283324.n4.nabble.com/Duplicate-Messages-in-the-Message-Store-tp4724959.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
it works for you.
>
> On Fri, Dec 16, 2016 at 3:26 PM, jahlborn <
> jahlborn@
> > wrote:
>> So, digging into the message store recoverNextMessages() code, it's tough
>> to
>> tell what is going in in terms of statefulness. That method certainly
>> seems
nd iterate over the messages in the store. The best thing
to do would be to write a quick test and see if it works for you.
On Fri, Dec 16, 2016 at 3:26 PM, jahlborn wrote:
> So, digging into the message store recoverNextMessages() code, it's tough to
> tell what is going in in terms of
So, digging into the message store recoverNextMessages() code, it's tough to
tell what is going in in terms of statefulness. That method certainly seems
like it would get me the information that i'm after. two concerns: 1. it
looks to be expecting an existing Transaction (maybe i al
).
>
> I already attempted this a bit myself by adding a method to the region Queue
> for first pulling from the "paged in" messages, and then directly from the
> "PendingMessageCursor messages" to read messages. However, despite the fact
> that the cursor is back
sages, and then directly from the
"PendingMessageCursor messages" to read messages. However, despite the fact
that the cursor is backed by the message store, it still seems to want to
"page in" messages, and also abides by the resource limits. (i was
borrowing code from Queue.getMes
Is there any example of how to configure ActiveMQ to use HSQLDB as message
store?
What does means "support" on this page:
http://activemq.apache.org/jdbc-support.html
Does it means that we don't need to install HSQLDB? Or the DB-driver is
included?
Thanks in advance.
--
View
Has anyone got experience of using Infinispan or JBoss Data Grid as a message
store for handling message persistence - particularly across geographically
dispersed Brokers (e.g. separate physical Data Centres or shared across
on-prem/cloud).
thanks
Tony
--
View this message in context:
http
lBackOff="true" />
>
>
>
>
>
>
>
>
> http://www.springframework.org/schema/beans";
> class="org.apache.activemq.hooks.SpringContextHook"/>
>
>
>
>
>class="org.apache.commons.dbcp.BasicDataSource"
> destroy-method="close">
>
> value="jdbc:mysql://localhost:3306/activemq?relaxAutoCommit=true&autoReconnect=true"/>
>
>
>
>
>
>
>
>
>
>
> {code}
>
> Please help me fiund out is it configuration problem or it is really a bug,
> because I suffer with this problem for about 2 weeks.
> Thanks!
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Memory-leak-in-JDBC-Message-Store-tp4696558.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
uot;;
class="org.apache.activemq.hooks.SpringContextHook"/>
{code}
Please help me fiund out is it configuration problem or it is really a bug,
because I suffer with this problem for about 2 week
checkpoint a message store:
java.util.concurrent.ExecutionException: java.io.IOException: Already
started. |
org.apache.activemq.store.journal.JournalPersistenceAdapter | Persistence
Adaptor Task-6264
java.util.concurrent.ExecutionException: java.io.IOException: Already
started.*
at
Heres the code I run to get the errormessages.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Errors-when-using-h2-as-message-store-tp4686889p4687607.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Hi,
Any updates here. Please respond.
Thanks,
Anuj
--
View this message in context:
http://activemq.2283324.n4.nabble.com/LevelDB-message-store-for-durable-subscriber-tp4686920p4686955.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
s stored 5 time in kahadb. Does LevelDB store this only once ?
Thanks,
Anuj
--
View this message in context:
http://activemq.2283324.n4.nabble.com/LevelDB-message-store-for-durable-subscriber-tp4686920.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
ge in context:
http://activemq.2283324.n4.nabble.com/Errors-when-using-h2-as-message-store-tp4686889.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Hi all,
Is anyone using ActiveMQ with Oracle for persistence and if you have done
some performance benchmarking, can you share some numbers please?
Performance test numbers are fine to share too:
http://activemq.apache.org/activemq-performance-module-users-manual.html
Thank you.
-Gaurav
27; => true);
May be that will safe time to someone other.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/how-to-enable-persistent-message-store-tp4330162p4333191.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
> NOT persistent, so i assume it should be persistent by default. But seems to
> not work with me.
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/how-to-enable-persistent-message-store-tp4330162p4332902.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
uld be persistent by default. But seems to
not work with me.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/how-to-enable-persistent-message-store-tp4330162p4332902.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
as frame to read and it return false.
>
> I check the permissions on kanadb and is all seems good. But all messages
> erased after ActiveMQ restart
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/how-to-enable-persistent-message-store-
return false.
I check the permissions on kanadb and is all seems good. But all messages
erased after ActiveMQ restart
--
View this message in context:
http://activemq.2283324.n4.nabble.com/how-to-enable-persistent-message-store-tp4330162p4330162.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Hi,
I am using ActiveMQ 5.4.0 and i would know which combination of keys is
unique.
We have
producer identifier (ProducerId) and producer sequence identifier (long) in
MessageID
Producer identifier is combination of connection identifier (String)
session identifier (long) and a value (long) [toSt
On Sun, Mar 7, 2010 at 12:34 PM, Tracy Snell wrote:
>
> On Mar 7, 2010, at 1:00 PM, Bruce Snyder wrote:
>
>> Yes, this is Rob's recommendation. Below is a depiction of how it should
>> work:
>>
>> brokerA-old --(network connection)--> brokerB-new
>>
>> * brokerA-old is configured to use the AMQ s
On Mar 7, 2010, at 1:00 PM, Bruce Snyder wrote:
> Yes, this is Rob's recommendation. Below is a depiction of how it should work:
>
> brokerA-old --(network connection)--> brokerB-new
>
> * brokerA-old is configured to use the AMQ store
> * brokerB-new is configured to use the KahaDB store
>
>
On Sun, Mar 7, 2010 at 9:21 AM, cmoulliard wrote:
>
> In fact I will create a network of brokers with by example two static url.
> The old one pointing to the new. As messages need to be consumed on the new
> broker, the old one will send the messages stored in the old to the new. Is
> it correct
ges to the new broker and store them in the KahaDB store.
>>>
>>> Cheers
>>> --
>>> Dejan Bosanac - http://twitter.com/dejanb
>>>
>>> Open Source Integration - http://fusesource.com/
>>> ActiveMQ in Action - http://www.manning.com/snyder/
>&
Bosanac - http://twitter.com/dejanb
>>
>> Open Source Integration - http://fusesource.com/
>> ActiveMQ in Action - http://www.manning.com/snyder/
>> Blog - http://www.nighttale.net
>>
>>
>> On Fri, Mar 5, 2010 at 4:06 PM, cmoulliard wrote:
>>
>&
le.net
>
>
> On Fri, Mar 5, 2010 at 4:06 PM, cmoulliard wrote:
>
>>
>> Hi,
>>
>> Can we migrate the content of an ActiveMQ Message Store to a KahaDB store
>> if
>> we decide to go from Apache ActiveMQ 5.1 to 5.3 ? It this is not possible
>> what
Integration - http://fusesource.com/
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nighttale.net
On Fri, Mar 5, 2010 at 4:06 PM, cmoulliard wrote:
>
> Hi,
>
> Can we migrate the content of an ActiveMQ Message Store to a KahaDB store
> if
> we decide to go from A
Hi,
Can we migrate the content of an ActiveMQ Message Store to a KahaDB store if
we decide to go from Apache ActiveMQ 5.1 to 5.3 ? It this is not possible
what is the migration path proposed ?
Kind regards,
Charles
-
Charles Moulliard
SOA Architect
My Blog : http
t; class="org.apache.activemq.pool.ActiveMQResourceManager"
> init-method="recoverResource">
>
> />
>
>
>
> interface="javax.transaction.TransactionManager" />
>
>
>
>javax.jms.ConnectionFactory
>
>
>
>
>
>
>
> How can I resolve this problem?
>
> Cheers,
> Marcin
> --
> View this message in context:
> http://old.nabble.com/message-store-tp27469568p27469568.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>
--
http://blog.garytully.com
Open Source Integration
http://fusesource.com
How can I resolve this problem?
Cheers,
Marcin
--
View this message in context:
http://old.nabble.com/message-store-tp27469568p27469568.html
Sent
On Thu, Jul 23, 2009 at 3:28 PM, Wxman wrote:
>
> Hi,
>
> My app receives messages that are persisted in the ActiveMQ message store.
> This is good except I want to have some control over how many back messages
> my app receives. Any messages older than a specific time are
Hi,
My app receives messages that are persisted in the ActiveMQ message store.
This is good except I want to have some control over how many back messages
my app receives. Any messages older than a specific time are useless. I
want ActiveMQ to deliver only the messages since a specific time
rom the trunk for example ? Do I need to work with the
ActiveMQ
trunk ?
Thanks
Andreas Gies wrote:
Hi there,
The PersistenceAdapter interface specifies methods
/**
* Cleanup method to remove any state associated with the given
destination.
* This method does not stop the message stor
Hi Stefan,
Thanks for the config, I will run some tests on my machine with yoru
settings (maybe I will get lucky). Let us know how you get on with your
tests on the other machine. Would be interested to know if a third party
product could be interfering with the message store files - I have not
;> trunk ?
>>
>> Thanks
>>
>>
>> Andreas Gies wrote:
>>>
>>> Hi there,
>>>
>>> The PersistenceAdapter interface specifies methods
>>>
>>> /**
>>> * Cleanup method to remove any state as
er interface specifies methods
/**
* Cleanup method to remove any state associated with the given
destination.
* This method does not stop the message store (it might not be
cached).
* @param destination Destination to forget
*/
void removeQueueMessageStore(ActiveMQQueue destina
istenceAdapter interface specifies methods
>
> /**
> * Cleanup method to remove any state associated with the given
> destination.
> * This method does not stop the message store (it might not be
> cached).
> * @param destination Destination to forg
Hi there,
The PersistenceAdapter interface specifies methods
/**
* Cleanup method to remove any state associated with the given
destination.
* This method does not stop the message store (it might not be
cached).
* @param destination Destination to forget
ied
>> again today with the same error. I've tried the syncOnWrite=true
>> setting,
>> but it slows down the broker too much for what is acceptable in my
>> system.
>> I think I'm pretty much out of options.
>>
>> Stefan
>>
>>
&g
I remove the queue thanks BrokerService.removeDestination.
>
> The problem I have is that the message store of my non temporary queue is
> not removed from my AMQ store and then the queue is reloaded at my
> ActiveMQ restart...
>
> I try to find a method from persistenceAdapter like
> removeQueue
f options.
>
> Stefan
>
>
>
> Dave Stanley wrote:
> >
> > It seems as though your message store has been corrupted. You will
> > probably
> > need to wipe the /data directory to start from a clean
> >
> > In order to try and narrow down why t
nley wrote:
>
> It seems as though your message store has been corrupted. You will
> probably
> need to wipe the /data directory to start from a clean
>
> In order to try and narrow down why this might be occurring:
>
> 1) Try test without the java service wrapper (standalo
Hello,
I'm trying to implement a method to remove queue which will check if the
queue has message on it :
if yes I throw an exception
else I remove the queue thanks BrokerService.removeDestination.
The problem I have is that the message store of my non temporary queue is
not removed from m
internals of how ActiveMQ runs? It makes it quite
> impractical if I can't use the service wrapper once I deploy my app.
>
> Cheers,
> Stefan
>
>
> Dave Stanley wrote:
> >
> > It seems as though your message store has been corrupted. You will
> > probably
> &g
nce I deploy my app.
Cheers,
Stefan
Dave Stanley wrote:
>
> It seems as though your message store has been corrupted. You will
> probably
> need to wipe the /data directory to start from a clean
>
> In order to try and narrow down why this might be occurring:
>
> 1) Tr
been
using to guide most of my configuration.
Cheers,
Stefan
Dave Stanley wrote:
>
> It seems as though your message store has been corrupted. You will
> probably
> need to wipe the /data directory to start from a clean
>
> In order to try and narrow down why this might be o
It seems as though your message store has been corrupted. You will probably
need to wipe the /data directory to start from a clean
In order to try and narrow down why this might be occurring:
1) Try test without the java service wrapper (standalone broker) and see if
it makes any difference
2
In the http://activemq.apache.org/amq-message-store.html documentation for
the AMQ Message Store, it mentions that it uses Kaha by default for the
reference store. I'm assuming then that there are other options for the
reference store, but I can't find any mention of them. I'm
al/apache-activemq-5.1.0
>>>
>>> ActiveMQ 5.1.0
>>> For help or more information please see: http://activemq.apache.org
>>>
>>> Thanks,
>>> Sandro
>>>
>>>
>>> rajdavies wrote:
>>>>
>>
Tosi wrote:
Hello,
my filesystem filled up due to ActiveMQ keep writing into nohup.out
this
error message:
ERROR JournalPersistenceAdapter - Failed to checkpoint a
message store:
java.util.concurrent.ExecutionException: java.io.IOException:
Already
started
ich version of activemq ?
>>
>> On 18 Sep 2008, at 07:51, Sandro Tosi wrote:
>>
>>>
>>> Hello,
>>> my filesystem filled up due to ActiveMQ keep writing into nohup.out
>>> this
>>> error message:
>>>
>>> ERROR JournalPersi
:
>
> which version of activemq ?
>
> On 18 Sep 2008, at 07:51, Sandro Tosi wrote:
>
>>
>> Hello,
>> my filesystem filled up due to ActiveMQ keep writing into nohup.out
>> this
>> error message:
>>
>> ERROR JournalPersistenc
which version of activemq ?
On 18 Sep 2008, at 07:51, Sandro Tosi wrote:
Hello,
my filesystem filled up due to ActiveMQ keep writing into nohup.out
this
error message:
ERROR JournalPersistenceAdapter - Failed to checkpoint a
message store:
java.util.concurrent.ExecutionException
Hello,
my filesystem filled up due to ActiveMQ keep writing into nohup.out this
error message:
ERROR JournalPersistenceAdapter - Failed to checkpoint a message store:
java.util.concurrent.ExecutionException: java.io.IOException: Already
started.
java.util.concurrent.ExecutionException
etting created as i
> have set the "maxFileLength" to 2mb. what i assumed/thought is due to
> setting of , only 2 data files should
> get generated as i have set the maxFileLength to 2 mb and my storage usage
> limit is 4 mb. Am i missing some thing here... i am not sure. Le
fusing - it doesn't do anything - as the store
> usage limit is broker wide - you don't need to use a name btw.
> So with the limit set to 4mb - this hint is sent to the Message Store - but
> only the default store - the AMQPersistence Adaptor will use it currently -
> so its maxim
That name attribute IS confusing - it doesn't do anything - as the
store usage limit is broker wide - you don't need to use a name btw.
So with the limit set to 4mb - this hint is sent to the Message Store
- but only the default store - the AMQPersistence Adaptor will use it
curr
>> > resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true"/>
>> > resourceBase="${activemq.base}/webapps/demo" logUrlOnStart="true"/>
>> > resourceBase="${activemq.base}
/
>
> I tried setting both "maxFileLength" and " still facing the same issue. My topic is accepting more messages and the
> broker is creating more data files. It is creating datafiles of the size
> specified in the "maxFileLength" attribute.
gt;
> On 7/28/08, Rob Davies <[EMAIL PROTECTED]> wrote:
>>
>>
>> On 28 Jul 2008, at 07:20, Ramdas Sawant wrote:
>>
>> Hi all,
>>> I am exploring AMQ Message Store of ActiveMQ. I need to know can
>>> i limit the storage size of messag
Thanks a lot Rob, will get back to you after testing, in case i need any
help. Thanks
regards
Ramdas
On 7/28/08, Rob Davies <[EMAIL PROTECTED]> wrote:
>
>
> On 28 Jul 2008, at 07:20, Ramdas Sawant wrote:
>
> Hi all,
>> I am exploring AMQ Message Store of A
On 28 Jul 2008, at 07:20, Ramdas Sawant wrote:
Hi all,
I am exploring AMQ Message Store of ActiveMQ. I need to
know can
i limit the storage size of message store. I mean my topic should
not accept
messages if a certain size of stored messages is reached on disk.
How can i
Hi all,
I am exploring AMQ Message Store of ActiveMQ. I need to know can
i limit the storage size of message store. I mean my topic should not accept
messages if a certain size of stored messages is reached on disk. How can i
configure this ?
The attribute maxFileLength of
The broker and the clients are both at:
Ubuntu Release 8.04
Kernel Linux 2.6.24-16-generic
Please let me know if you need more info. Thank you.
rajdavies wrote:
>
>
> On 13 May 2008, at 18:12, janylj wrote:
>
>>
>> Hello,
>>
>> I am using the AMQ Me
On 13 May 2008, at 18:12, janylj wrote:
Hello,
I am using the AMQ Message Store for the persistence. The
configuration is:
It seems to me that the AMQ message store affects the performance a
lot. I
am using Maven2 performance test
(http://activemq.apache.org/activemq-performance
Hello,
I am using the AMQ Message Store for the persistence. The configuration is:
It seems to me that the AMQ message store affects the performance a lot. I
am using Maven2 performance test
(http://activemq.apache.org/activemq-performance-module-users-manual.html).
For the case of 1
se something that's built-in to ActiveMQ if it's available.
> > I was
> > looking at the AMQ Message Store, and it seems to have an archive
> > option. I
> > tried setting it up, and see files being generated in the journal
> > directory
> > and kr-stor
uilt-in to ActiveMQ if it's available.
I was
looking at the AMQ Message Store, and it seems to have an archive
option. I
tried setting it up, and see files being generated in the journal
directory
and kr-store directory, but nothing gets dumped into the archive
directory.
So, my fi
looking at the AMQ Message Store, and it seems to have an archive option. I
tried setting it up, and see files being generated in the journal directory
and kr-store directory, but nothing gets dumped into the archive directory.
So, my first question is, will the AMQ Message Store allow me to
context:
http://www.nabble.com/ActiveMQ-5.0.0-AMQ-Message-Store-fails-when-using-with-Spring-DefaultMessageListenerContainer-with-more-than-1-concurrentConsumers-to-dispatch-JMS-messages-from-Queue-tp14805901s2354p14882065.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
This is a known issue - please use the latest snapshot
On Jan 14, 2008, at 4:49 PM, Wilson Luong wrote:
Hi,
I am seeing a problem in using ActiveMQ5.0.0 (AMQ Message Store) with
Spring's DefaultMessageListenerContainer. Whenever I set the
DefaultMessageListenerContainer currentConsumer
Hi,
I am seeing a problem in using ActiveMQ5.0.0 (AMQ Message Store) with
Spring's DefaultMessageListenerContainer. Whenever I set the
DefaultMessageListenerContainer currentConsumer value to more than 1 (i.e.
multiple concurrent consumers), it causes activeMQ broker to produce error
shown
s:
ERROR JournalPersistenceAdapter - Failed to checkpoint a message store:
edu.emory.mathcs.backport.java.util.concurrent.ExecutionException:
java.io.IOException: Not started.
at
edu.emory.mathcs.backport.java.util.concurrent.FutureTask.getResult(FutureTask.java:299)
Then most msgs are t
org.apache.activemq.store.journal.JournalPersistenceAdapter doCheckpoint
SEVERE: Failed to checkpoint a message store:
edu.emory.mathcs.backport.java.util.concurrent.ExecutionException:
java.io.IOException: Not started.
edu.emory.mathcs.backport.java.util.concurrent.ExecutionException:
java.io.IOException
Now I'm getting this:
2007-04-17 11:40:31,821 [Persistence Adaptor Task] ERROR
org.apache.activemq.store.journal.JournalPersistenceAdapter:doCheckpoint
:395 - Failed to checkpoint a message store:
edu.emory.mathcs.backport.java.util.concurrent.ExecutionException:
java.io.IOException: Not st
html for more
>> details. This resolved few issues I had including this "failed to
>> checkpoint"
>>
>> -Nilantha
>>
>> -Original Message-
>> From: ptomsic [mailto:[EMAIL PROTECTED]
>> Sent: Thursday, February 01, 2007 12:55 PM
>>
ebruary 01, 2007 12:55 PM
> To: activemq-users@geronimo.apache.org
> Subject: failed to checkpoint a message store?
>
>
> this keeps occurring in our log, any thoughts/suggestions?
>
>
>
> ERROR JournalPersistenceAdapter - Failed to checkpoint a message
> stor
al Message-
From: ptomsic [mailto:[EMAIL PROTECTED]
Sent: Thursday, February 01, 2007 12:55 PM
To: activemq-users@geronimo.apache.org
Subject: failed to checkpoint a message store?
this keeps occurring in our log, any thoughts/suggestions?
ERROR JournalPersistenceAdapter - Failed to
this keeps occurring in our log, any thoughts/suggestions?
ERROR JournalPersistenceAdapter - Failed to checkpoint a message store:
edu.emory.mathcs.backport.java.util.concurrent.ExecutionException:
java.io.IOException: Not started
90 matches
Mail list logo
