Re: JDBC persistence for postgresql

2017-06-19 Thread Bill Chen
Hi Tim, I found Message.setBooleanProperty() in javax.jms.Message, but I actually used the Eclipse Paho MQTT client to publish message. I have set the retained property in org.eclipse.paho.client.mqttv3.MqttMessage, does it like to the ActiveMQ.Retain property as you mentioned? Bill -- View

Re: JDBC persistence for postgresql

2017-06-07 Thread Bill Chen
Tim, I'm sorry that confused you about the reference link. I'm doing the ActiveMQ way, and I have encountered some questions. First, how to set the ActiveMQ.Retain property? Second, I try to add the RetainedMessageSubscriptionRecoveryPolicy in my configuration, but that occurred exception when a

Re: JDBC persistence for postgresql

2017-06-06 Thread Bill Chen
Hi, Tim I'm not sure the retained flag is the same as the persistent flag. About the retained flag as follows: https://www.ibm.com/support/knowledgecenter/en/SSCGGQ_1.0.0/com.ibm.ism.doc/Overview/ov00033.html I publish to a message to a topic, not to a queue. So, I don't have any information in t

Re: JDBC persistence for postgresql

2017-06-06 Thread Bill Chen
Thanks Tim. I have set the retained flag for message when producer publish. But the message still not stored in the activemq_msgs table. May I need to modify my configuration in activemq.xml? -- View this message in context: http://activemq.2283324.n4.nabble.com/JDBC-persistence-for-postgresq

JDBC persistence for postgresql

2017-06-05 Thread Bill Chen
Hi All, I am using ActiveMQ 5.14.5 as MQTT broker, and I would like to use postgres as database. My configuration in activemq.xml: When I start ActiveMQ, I check the tables(activemq_acks, activemq_lock, activemq_msgs) has created in postgres. But,

store a daily data into ten minute queue

2014-07-28 Thread Chen Wang
! Chen

Re: Problem using NFSv4 for Shared File System Master Slave

2013-04-30 Thread Chen
I created a issue, hope someone can give me a hand, thanks. https://issues.apache.org/jira/browse/AMQ-4497 -- View this message in context: http://activemq.2283324.n4.nabble.com/Problem-using-NFSv4-for-Shared-File-System-Master-Slave-tp4666336p4666437.html Sent from the ActiveMQ - User mailing

Problem using NFSv4 for Shared File System Master Slave

2013-04-28 Thread Chen
Hi all, I'm using ActiveMQ 5.5.1 to be my HA JMS, but recently I've found an unexpected error. Both master and slave AMQ can grab the same file lock and receive client's request one the network back stable from unstable. In my experiment, I used kahaDB to be the persistenceAdapter. The setting is

Re: Acknowledge messages

2011-03-28 Thread Nereus Chen
I suggest you to use a session independently in every thread which is contained by a excutor. and cannot share the session by multi threads. In the thread you can use the consumer.receive() method rather then the linstener's onMessage(). -- View this message in context: http://activemq.2

Re: Acknowledge messages

2011-03-28 Thread Nereus Chen
Ok.I know. you want to consumer a message and process it in a transaction to ignore lose the message when occurs exceptions during the process. -- View this message in context: http://activemq.2283324.n4.nabble.com/Acknowledge-messages-tp3411289p3411356.html Sent from the ActiveMQ - User mail

Re: Message timeout delete

2011-03-28 Thread Nereus Chen
HI. The ActiveMQ cannot auto delete the message after some seconds. But you can use the produer's timeToLive properties. such as: MessageProducer producer = ;// to new a producer producer.setTimeToLive(timeToLive)//timeToLive = 20*1000; 20 seconds Try to do it.

Re: Acknowledge messages

2011-03-28 Thread Nereus Chen
HI,Amit try to use the AUTO_ACKNOWLEDGE. such as : session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 2011/3/28 amit_csus [via ActiveMQ] < ml-node+3411289-406426425-224...@n4.nabble.com> > Hi, > > I am using ActiveMQ 5.4.2. > > Can i acknowledge individu

Re: activemq consumes 2GB disk per day

2011-01-17 Thread Chen Bangzhong
ction - http://www.manning.com/snyder/ > Blog - http://www.nighttale.net > > > > On Mon, Jan 17, 2011 at 9:39 AM, Chen Bangzhong > wrote: > > Hi, All > > > > My activemq consumed 2GB disk per day. The disk is being exhausted. > > > > I found the size

activemq consumes 2GB disk per day

2011-01-17 Thread Chen Bangzhong
Hi, All My activemq consumed 2GB disk per day. The disk is being exhausted. I found the size of journal folder is about 237GB. How can I free my disk space? I tried purge in my lab machine, it seems not help. then I set the deleteAllMessageOnStartup to true and restart, it works. what's the s

How to change the JDBC store mode to Kaha store mode ?

2010-01-11 Thread Lyan Chen
Hi I have a small project about activeMQ. previously , I was used jdbcPersistenceAdapter for store message. But later, it being more slower when starting and running. I checked my oracle database, There was about 10,000 rows data in the activemq_msgs table. That was not largely ,isn't it ? now

Re: ActiveMQ 5.3 pending message issue

2009-08-12 Thread Chen-hsiu Huang
e disconnected by server. Chen-hsiu Huang wrote: > > Hi, > > We're using ActiveMQ 5.3 as our message service. However, we found that > messages stall easily through our test. > > 1. We have two servers, each with two Intel Xeon E5420 CPUs, total 8 > cores, 32 GB

ActiveMQ 5.3 pending message issue

2009-08-11 Thread Chen-hsiu Huang
ovide stable services? Thanks in advance. PS: attached with one of our server configuration file. BR, Chen-hsiu Huang http://www.nabble.com/file/p24913211/activemq_01.xml activemq_01.xml -- View this message in context: http://www.nabble.com/ActiveMQ-5.3-pending-message-issue-tp24913211p24913211

I try to sort out the errors and exception messages I have met

2008-04-02 Thread Chen Yi Chen
are 18 warning messages similar to the above one. Please help me to analyze the question. Best Regards and Have a Nice Day Chen Yi Chen http://www.nabble.com/file/p16446677/runSemops.log runSemops.log -- View this message in context: http://www.nabble.com/I-try-to-sort-out-the-error

Re: Cannot download ActiveMQ 5.0 Snapshot

2007-09-21 Thread Chen Xinjun
Hi Alan Mehio, Thanks for you help. I am new to Maven and ActiveMQ. When I post the message, the link http://people.apache.org/repo/m2-snapshot-repository/org/apache/activemq/apache-activemq/5.0-SNAPSHOT/ contains nothing. I checked just now. It seems OK. Thank you for you info. Regards,

Cannot download ActiveMQ 5.0 Snapshot

2007-09-14 Thread Chen Xinjun
Dear ActiveMQ users, I am new to ActiveMQ. Can anyone tell me why I cannot download ActiveMQ 5.0 Snapshot? Regards, Xinjun -- View this message in context: http://www.nabble.com/Cannot-download-ActiveMQ-5.0-Snapshot-tf067s2354.html#a12680074 Sent from the ActiveMQ - User mailing list a