When using activemq as a windows service, jmx does not work

2012-12-16 Thread Michal Singer
Hi, I am running Activemq as a service on windows I uncommented the lines for enabling the jmx under the ActiveMQ HOME\bin\win64\wrapper.conf: wrapper.java.additional.7=-Dcom.sun.management.jmxremote wrapper.java.additional.12=-Dcom.sun.management.jmxremote.port=1616

performance issues with AMQ POC

2012-11-17 Thread Michal Singer
I am running some POC on Active MQ and I am encountering some serious performance issues: 1. it is slower to work with spring than without: even when i configure the spring to use caching in pool as suggested, Running with out spring 8 point-to-point flows: it takes about 7 seconds

jms template stuck

2012-11-15 Thread Michal Singer
Hi, according to this link: http://activemq.apache.org/jmstemplate-gotchas.html there are problems with using the org.apache.activemq.ActiveMQConnectionFactory and a pooled one should be used instead. I couldn't find the PooledConnectionFactory anywhere. Any recommendations on which pool

jms template is slow and stucks

2012-11-15 Thread Michal Singer
Hi, I am running a simple point-to-point example and trying to run 8 requests from a client to a server. When I run it as is – it goes fast and finishes. When I changed the server to support spring and use jmstemplate to send the message, the reply is slower and gets stuck eventually. Any

RE: how to stop AMQ gracefully?

2011-04-30 Thread Michal Singer
Hi, I am using windows, and activemq is embedded in Spring so this does not work, Any ideas how to do it this way? Thanks, Michal -Original Message- From: manua [mailto:agarwal.m...@gmail.com] Sent: ה 28 אפריל 2011 16:37 To: users@activemq.apache.org Subject: Re: how to stop AMQ

how to stop AMQ gracefully?

2011-04-28 Thread Michal Singer
Hi, what is the recommended way to stop the AMQ broker? Is there any configuration or procedure to do when shutting down the broker? I have a broker embedded in Spring, what is the best way to go down gracefully? Thanks, Michal Singer

current thread's class loader is changed during onMessage of

2011-04-26 Thread Michal Singer
, that of the other web context. This causes many problem. it seems like the thread pool of the AMQ is somehow mixed and so the thread entered on onMessage was somehow wrong. Any ideas what this means? What should be done? Thanks, Michal Singer Expand Networks 6 Hanechoshet Street Tel Aviv

RE: current thread's class loader is changed during onMessage of

2011-04-26 Thread Michal Singer
the onMessage is called, It does: runningThread = Thread.currentThread(); And there I see that the runningThread has a wrong class loader already. -Original Message- From: Michal Singer Sent: ג 26 אפריל 2011 10:24 To: users@activemq.apache.org Subject: current thread's class loader is changed during

RE: AMQ fails to process messages after a faulty restart

2011-04-14 Thread Michal Singer
From what I checked, it looks like some kind of a problem with the same class being loaded by 2 instances of the same class loaders. Any one knows why this could happen? And what do I do to fix this? -Original Message- From: Michal Singer Sent: ה 14 אפריל 2011 07:38 To: users

RE: AMQ fails to process messages after a faulty restart

2011-04-13 Thread Michal Singer
a Serializable class, might that be a problem?) Thanks in advance, Michal -Original Message- From: Michal Singer Sent: ג 29 מרץ 2011 16:16 To: users@activemq.apache.org Subject: RE: AMQ fails to process messages after a faulty restart But actually, after one message like that many

AMQ fails to process messages after a faulty restart

2011-03-29 Thread Michal Singer
Hi, i am using AMQ 5.2.0 on a multi process application to communicate between processes. I am configuring AMQ using Spring version 2.5.6 I am NOT using persistent AMQ. Sometimes after a faulty restart such as: kill java, electric power down - after raise, there are errors: ActiveMQ

I upgraded AMQ from 5.2.0 to 5.4.0 and many exceptions appear now

2011-03-29 Thread Michal Singer
Hi, I upgraded the AMQ to 5.4.0 from 5.2.0, i changed the activemq.xml to be alphabetic as i understood i should, I get these exceptions now all the time, on INFO level, which i never got before: taskExecutorClient-1 [4105026f:12f00165e54:-7f49] 2011-03-29 01:02:17,713 INFO

RE: AMQ fails to process messages after a faulty restart

2011-03-29 Thread Michal Singer
March 2011 13:58, Michal Singer michal.sin...@expand.com wrote: Hi, i am using AMQ 5.2.0 on a multi process application to communicate between processes. I am configuring AMQ using Spring version 2.5.6 I am NOT using persistent AMQ. Sometimes after a faulty restart such as: kill java

RE: I upgraded AMQ from 5.2.0 to 5.4.0 and many exceptions appear now

2011-03-29 Thread Michal Singer
%3A+Peer On 29 March 2011 14:01, Michal Singer michal.sin...@expand.com wrote: Hi, I upgraded the AMQ to 5.4.0  from 5.2.0, i changed the activemq.xml to be alphabetic as i understood i should, I get these exceptions now all the time, on INFO level, which i never got before

javax.jms.JMSException: Unexpected failure in AMQ

2010-08-03 Thread Michal Singer
Hi, i get sometimes during initialization of AMQ the following exception, does anyone what may cause this exception and how it should be handled: please note that after this exception occurs, i get invalid responses from onMessage. javax.jms.JMSException: Unexpected failure.

Re: javax.jms.JMSException: Unexpected failure in AMQ

2010-08-03 Thread Michal Singer
. org.apache.activemq.transport.failover.FailoverTransport.oneway(FailoverTransport.java:424) On 3 August 2010 08:59, Michal Singer michal.sin...@expand.com wrote: Hi, i get sometimes during initialization of AMQ the following exception, does anyone what may cause this exception and how it should be handled: please note

Message returned in onMessage in client of AMQ is corrupted

2010-07-18 Thread Michal Singer
Hi. For some reason, on some scenarios after restart of my server, the message the client receives on onMessage is corrupted. I always check the type: if(logicResponse instanceof LogicResponse) and i get true since it is always the same instance. But, on some scenarios, i get false, even though

Transport failed: java.io.IOException: Unknown data type: 68

2010-03-13 Thread Michal Singer
Hi. I am using activemq (5.2.0). On some environments i keep getting this error: ActiveMQ Transport: tcp://localhost/127.0.0.1:61616 2010-03-11 17:20:43,250 WARN [org.apache.activemq.transport.failover.FailoverTransport] Transport failed to tcp://localhost:61616 , attempting to automatically

How to monitor queue size of a thread pool

2010-02-08 Thread Michal Singer
hi. i am trying to check out during runtime, the queue of waiting tasks of a thread pool. I am using org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor and calling this: ThreadPoolTaskExecutor.getThreadPoolExecutor().getQueue().size() But it returns the pool size

How to shutdown client process which connects to jms using failover parameter?

2009-02-15 Thread Michal Singer
Hi. when i use the failover parameter to connect to Active MQ, i can't stop the client. I guess since it tries to reconnect to the AMQ and has threads open which prevent from shutting down the process using System.exit. I tried to configure the connection to have timeouts and attempts max limit,

Re: Fail to reconnect to AMQ queues after restarting the broker

2009-02-14 Thread Michal Singer
I have a problem with this failover parameter: I can't stop the process now. I guess since it stays alive with attempts to reconnect to the AMQ. Any ideas of how i can shut it down? Thanks, Michal Michal Singer wrote: Great, it helped. thanks. Dejan Bosanac wrote: Hi, if you put

Re: Fail to reconnect to AMQ queues after restarting the broker

2009-02-02 Thread Michal Singer
Integration - http://fusesource.com/ ActiveMQ in Action - http://www.manning.com/snyder/ Blog - http://www.nighttale.net On Mon, Feb 2, 2009 at 11:14 AM, Michal Singer michal.sin...@expand.comwrote: Hi, the failover transport lets you load balance clients over a number of brokers. However

Re: TotalEnqueueCount,TotalDequeueCount,TotalMessages in JMX activemq does not work as i would expect

2008-07-07 Thread Michal Singer
Queues rajdavies wrote: are you using topics or queues ? On 7 Jul 2008, at 06:20, Michal Singer wrote: What you explained is what i understood should be: so i would expect that if all messages are consumed by clients, that: TotalEnqueue=TotalMessages=TotalDequeue

TotalEnqueueCount,TotalDequeueCount,TotalMessages in JMX activemq does not work as i would expect

2008-07-06 Thread Michal Singer
When i observe the JMX activemq broker node: I see that TotalMessages + TotalDequeueCount = TotalEnqueueCount I would expect that the TotalEnqueueCount = TotalDequeueCount = TotalMessages Am i wrong? why is the first equation correct? Thanks -- View this message in context:

Re: TotalEnqueueCount,TotalDequeueCount,TotalMessages in JMX activemq does not work as i would expect

2008-07-06 Thread Michal Singer
I am using a snapshot of 5.2: apache-activemq-5.2-20080619.135742-2-bin Can you explain the meaning of these attributes and what they should hold, since i don't understand them. Thanks, Michal rajdavies wrote: On 6 Jul 2008, at 13:40, Michal Singer wrote: When i observe the JMX

Re: TotalEnqueueCount,TotalDequeueCount,TotalMessages in JMX activemq does not work as i would expect

2008-07-06 Thread Michal Singer
:42, Michal Singer wrote: I am using a snapshot of 5.2: apache-activemq-5.2-20080619.135742-2- bin Can you explain the meaning of these attributes and what they should hold, since i don't understand them. Thanks, Michal rajdavies wrote: On 6 Jul 2008, at 13:40, Michal Singer wrote

How can i connect to JMX beans of activemq from the code

2008-06-25 Thread Michal Singer
hi. i am trying to monitor actimve jmx beans from inside the code. I am trying something like connecting to the JMX server the process uses with accessing a bean with name: org.apache.activemq.broker name:type=Broker but i get exception: com.expand.expandview.common.exceptions.EVJMXException:

Seperate client from activemq jar

2008-04-28 Thread Michal Singer
Hi. I would like to know how to seperate client from server in the activemq jar. Which jar files needs a client of the broker? Does it need the entire jar file of the activemq, or can it use seperate jar files? -- View this message in context:

Memory leak detected in Jprofiler with the following activemq o bjects:  MemoryUsage,DefaultUsag eCapacity,PollCountStatisticImpl

2008-03-26 Thread Michal Singer
Hi. I am working with latest snapshot of 5.1 ActiveMQ. I have a lot of memory problems. I am trying to find out where the problem is. I monitored the consumer broker process memory using jprofiler, and i saw an obvious memory leak with the following object:  

ActiveMQQueueReceiver are kept in the memory even though they are closed

2008-03-24 Thread Michal Singer
Hi. When i monitor the memory i see that i got accumulation of ActiveMQQueueReceiver objects. I close the receviers in my application and set them with null. I create only one session/connection so i close it only at the shutdown. What can cause this problem? is there some other cleanup needed

Whats minimal use of jencks required for activemq spring consumer

2008-03-23 Thread Michal Singer
Hi. I am using activemq 5.1 (snapshot latest). The producer uses regular activemq API, and the consumer uses activemq with spring jmstemplate. I would like to know if the following conifguration will improve performance or if i need to use the entire, inbound-outbound configuration of jencks:

Queue size of broker increases all the time

2008-03-23 Thread Michal Singer
Hi. I use the 5.1 snapshot. I see that the queue size of broker, and ActiveMQ.Advisory.TempQueue, increase all the time. At first, the problem was that auto_ack did not work. But i changed to use client ack instead. Now, i see that the messages are acknowledged on temp queues, but when i look

AUTO_ACKNOWLEDGE does not work, CLIENT_ACKNOWLEDGE works but not for temp queues

2008-03-20 Thread Michal Singer
Hi. I an using AUTO_ACKNOWLEDGE on a session, but the messages seem to be stuck in the queue. When i update to CLIENT_ACKNOWLEDGE + ack on each message, it works fine. However, if i try the CLIENT_ACKNOWLEDGE + ack on messages delivered on temp queues, it does not work. Does any one know why:

Re: AUTO_ACKNOWLEDGE does not work, CLIENT_ACKNOWLEDGE works but not for temp queues

2008-03-20 Thread Michal Singer
) rajdavies wrote: On 20 Mar 2008, at 07:14, Michal Singer wrote: Hi. I an using AUTO_ACKNOWLEDGE on a session, but the messages seem to be stuck in the queue. When i update to CLIENT_ACKNOWLEDGE + ack on each message, it works fine. However, if i try the CLIENT_ACKNOWLEDGE + ack

Re: AUTO_ACKNOWLEDGE does not work, CLIENT_ACKNOWLEDGE works but not for temp queues

2008-03-20 Thread Michal Singer
, Michal Singer wrote: Hi. I am using the latest snapshot: apache- activemq-5.1-20080311.181016-59 Please note that the messages get stuck when i observe in jconsole the: ActiveMQ.Advisory.TempQueue But if i look specificly on a temp queue (before deleting it - the ack works - after i

Re: How do I remove ActiveMQ.Advisory.Producer.Queue.xxxx

2008-03-20 Thread Michal Singer
Hi. This option does not work with temp queues. Is there another way to disable this accumulation of Advisory Objects? Thx, Michal jlim wrote: Hi, You can disable advisory support in your broker config file : broker brokerName=localhost useJmx=true advisorySupport=false

Why does dequeue different from enqueue and from dispatch

2008-03-19 Thread Michal Singer
Hi. When i use spring to create a connection, i see in the jconsole that the attributes on the Queue DequeueCount EnqueueCount DispatchCount are the same. But when, i create a active mq connection with out spring, i get totally differnet numbers. For example: DequeueCount = 0 EnqueueCount = 467

Memory grows when using temp queues even when closing connections all the time

2008-03-18 Thread Michal Singer
Hi. I use temp queues in my code. they are deleted all the time. I first used one connection which caused memory leak with temp queues. It looks like the context of temp queue was not deleted even after deletion of temp queus (bug in activemq). Then i tried using new connections as a work around

Re: Problems with disabling Advisory Support

2008-03-18 Thread Michal Singer
The snapshot i am using: apache-activemq-5.1-20080311.181016-59 rajdavies wrote: What was the latest 5.1-SNAPSHOT you tried with this issue ? On 18 Mar 2008, at 05:26, Michal Singer wrote: Hi. The problem with them is that they are accumulated even though the temp queues

Dequeue messages pace is much lower then enqueu - memory problems

2008-03-18 Thread Michal Singer
Hi. I use temporary queues in my application. I have bad memory problems. I see that the dequeue pace compared to enqueue pace of messages is a much lower pace. could that cause the memory problems, and does any one know waht can cause such a difference, is it a problem with active mq or with the

Active MQ version 5.X - java 5 - memory leaks

2008-03-18 Thread Michal Singer
Hi. I understand that there are memory leaks when working with jdk1.5 and activemq 5.X. There are also memory leaks concerning temp queues usage. Does this mean that only if i upgrade to jdk1.6 - i can work with activemq 5.X? Do you have a work around for these problems, when will there be

Re: Dequeue messages pace is much lower then enqueu - memory problems

2008-03-18 Thread Michal Singer
yes. I am using: apache-activemq-5.1-20080311.181016-59.zip rajdavies wrote: you tried the very latest snapshot ? On 18 Mar 2008, at 11:59, Michal Singer wrote: Hi. I use temporary queues in my application. I have bad memory problems. I see that the dequeue pace compared to enqueue

Re: Active MQ version 5.X - java 5 - memory leaks

2008-03-18 Thread Michal Singer
I have no permissions. How can i add a jira? rajdavies wrote: could you raise a jira with a test case please ? - it would make it a lot quicker to resolve On 18 Mar 2008, at 15:26, Michal Singer wrote: Hi. I understand that there are memory leaks when working with jdk1.5

Problems with disabling Advisory Support

2008-03-17 Thread Michal Singer
Hi. I tried to disable Advisory Support using advisorySupport=false since i see that temp queus are occumulated there for no reason eveb after deletion. However, i get the following exceptions after i disable: org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured

Re: Outof memory using temp queus in active MQ- 5.1

2008-03-16 Thread Michal Singer
? when will this version be released? Thanks, Michal Michal Singer wrote: Hi. I have the out of memory problems using active MQ 5.1 (activemq-all-5.1-SNAPSHOT.jar) In my application I use many temp queues, delete them after usage. I see that they are deleted, but in addition i see many

Outof memory using temp queus in active MQ- 5.1

2008-03-13 Thread Michal Singer
Hi. I have the out of memory problems using active MQ 5.1 (activemq-all-5.1-SNAPSHOT.jar) In my application I use many temp queues, delete them after usage. I see that they are deleted, but in addition i see many Advisor objects defined and not deleted. After a few hours i get out of memory

Re: Send response to temporary queue gets stuck after 3900 sends

2008-03-12 Thread Michal Singer
Great. It looks like it solved the problem. However, I see that the memory still increases gradually where I would expect it to stay as is. Looks like some kind of memory leak. Michal Singer wrote: hi. I am using activemq 5.0.0 broker embedded in spring. I use temporary queues. After

Re: Jconsole accumulates a list of topics when i only create queues

2008-03-11 Thread Michal Singer
of application and i delete the temp quese after process of responses Can this explain the problem of accumulation?? Thanks, Michal Michal Singer wrote: I use activemq 5.0 broker embedded in spring. When i observe a jconsole, i see the queues and temporary queues in a correct list, but i

Re: Send response to temporary queue gets stuck after 3900 sends

2008-03-11 Thread Michal Singer
Producer uses: auto ack - queueSessionSend = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); Michal Singer wrote: hi. I am using activemq 5.0.0 broker embedded in spring. I use temporary queues. After calling jmsTemplate.convertAndSend exactly 3990 times

Re: Send response to temporary queue gets stuck after 3900 sends

2008-03-11 Thread Michal Singer
be released. Can any one help me with this problem?? Michal Singer wrote: hi. I am using activemq 5.0.0 broker embedded in spring. I use temporary queues. After calling jmsTemplate.convertAndSend exactly 3990 times (Using different temporary queues to reply to different producers), the response

Jconsole accumulates a list of topics when i only create queues

2008-03-10 Thread Michal Singer
I use activemq 5.0 broker embedded in spring. When i observe a jconsole, i see the queues and temporary queues in a correct list, but i also see the queus in the topics list accumulate there. They are not topics so there is no reason for this. does any one knows what this means? why are they

Active MQ broker embedded with spring configuration problems

2008-02-03 Thread Michal Singer
Hi. I am trying to raise an embedded Active MQ broker using spring configuration file. I work with spring 2.0.6 Active MQ 5.0.0. The only way that works is this: amq:broker brokerName=brokerFactory useJmx=true persistent=true amq:managementContext amq:managementContext