thanks gary for the reply.
you are right that camel route is consuming all messages. so i can not see
messages in DB.
but when i chang my route to some wrong endpoint which does not exist. which
mean i am sending my message to a wrong consumer e.g
on place of this if i write
then message will
no-one knows about it...??
i think there might be some configuration missing or something else.
please check it.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/message-clears-from-db-if-application-or-activemq-restarts-tp3491807p3500297.html
Sent from the ActiveMQ - User
i think in this line
http://activemq.apache.org/schema/core";
brokerName="localhost" persistent="true"
dataDirectory="${activemq.base}/data" >
persistent="true" is enough for making messages persistance.
please correct me if I am wrong.. or if there is any other solution?
--
View this message
please reply anyone, i need to fix it quickly.
Thanks in advance.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/message-clears-from-db-if-application-or-activemq-restarts-tp3491807p3494583.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
hey martin thanx for reply..
as you have mentioned in my framework i did not change the default
persistent setting of message
other configurations which i am using are:
this is my camel route:
and in readData & read
Hey martin
as i shown my config file, i am using persistency using
jdbcpersistenceadapter in oracle.
& only undelivered messages i can see in the activemq_msgs table.
for making messages undeliver i give a wrong route address which does not
exist, so i can see that message in db. until now i think
I am using camel for routing & test Activemq i am testing by sending jms
message -
this is my junit test
public class JmsTest extends CamelSpringTestSupport{
private static Logger logger = LoggerFactory.getLogger(JmsTest.class);
@Test
public void testJMS() {
ArrayList listObj = n
Can anyone explain me why my messages from ACTIVEMQ_MSGS table gets deleted.
It happens everytime when i restart the activemq or whenever my application
gets restarted.
http://activemq.apache.org/schema/core";
brokerName="localhost" persistent="true"
dataDirectory="${activemq.base}/data" >
