ODP: Federation queues - issue with cleaning up resources?

Hi, Just a follow up on this topic - has anybody faced similar issue with federation mechanism ending with OOM on intermittent tcp connection problems? Is there anything we can do to maintain stability of our installation? Thanks Michal Od: Michal Balicki Wysłano: wtorek, 3 stycznia 2023 14:43

Federation queues - issue with cleaning up resources?

.ClientSessionFactoryImpl @ 0xb62518c8 192 106 944 0,06% ...+org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl @ 0xd0b00a40 192 98 336 0,05% ...\Total: 20 entries 960 2 601 984 1,39% When removing federation config on selected node, memory consumption on this node comes back to normal. Thanks M

Server complains that client has disconnected (after proper disconnect)

Hi, we are trying to test performance of the Artemis 1.3.0-SNAPSHOT using Qpid JMS 1.0 client (version 0.9.0). The client is quite straightforward, it opens 3 senders (each in separate thread) and each of them sends messages to the same address, however with a different JMSType. Server diverts the

condui subscriptions set to false on network of brokers but no DUPLICATE?

Hello, I am working on activemq network of brokers enviroment that was not setup by me I started revision of the config and found: network connectors used are: There is no separate connection for queues and topics and there are three brokers on the n

Re: Activemq does not recover from a closed connection using ssl

Please also note that i made the same test with tcp protocol and it also happens, so it is not an ssl issue. Another thing, if i kill the connection using TCPView it does not happen. only when killing the connection from the firewall it happens. thanks -- View this message in context: http://ac

Re: Activemq does not recover from a closed connection using ssl

Hi. thanks for the reply. the bugs you showed are already closed. i am using the 5.7.0 version so they should be closed there. as for the suggestion you added to run with transport.soWriteTimeout : I tried running with configuration: and it didn't work. the connection still hangs. any ideas

Re: Activemq does not recover from a closed connection using ssl

Hi. thanks for the reply. the bugs you showed are already closed. i am using the 5.7.0 version so they should be closed there. as for the suggestion you added to run with transport.soWriteTimeout : I tried running with configuration: and it didn't work. the connection still hangs. any ideas wha

Activemq does not recover from a closed connection using ssl

Hi, I am seeing a scenario where a connection is closed between a activemq client and activemq service(can be simulated by closing the connection in firewall). As a result, the activemq does not see that the connection is closed, it keeps it up and so there is no attempt to reconnect. So as a resu

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

figuration file activemq.xml I do see the AMQ on jconsole. Any ideas why this does not work for the service? Thanks, Michal

Re: performance issues with AMQ POC

Hi. as for point 1) I am testing a point-to-point between two processes. client-server : client sending requests and server sending responses. One test uses spring configuration for both client and server and one is plain activemq code with no spring configuration (which is much faster) This is t

performance issues with AMQ POC

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 Runnin

performance issues with AMQ POC

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 Ru

jms template is slow and stucks

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 i

jms template stuck

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 shoul

RE: how to stop AMQ gracefully?

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?

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

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

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 d

current thread's class loader is changed during onMessage of

, 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: AMQ fails to process messages after a faulty restart

>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:

RE: AMQ fails to process messages after a faulty restart

nherits from 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 li

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

-5.2.0.jar to activemq-all-5.4.2.jar, and update the activemq.xml file to be in alphabetic order? Thanks, Michal -Original Message- From: Gary Tully [mailto:gary.tu...@gmail.com] Sent: ג 29 מרץ 2011 15:18 To: users@activemq.apache.org Subject: Re: I upgraded AMQ from 5.2.0 to 5.4.0 and

RE: AMQ fails to process messages after a faulty restart

March 2011 13:58, Michal Singer 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

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

"; xmlns:amq="http://activemq.org/config/1.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xmlns="http://www.springframework.org/schema/beans";> http://activemq.apache.org/schema/core";> Any ideas? Thanks, Michal

AMQ fails to process messages after a faulty restart

org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185) at java.lang.Thread.run(Unknown Source) Thanks, Michal

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

h / in the rest. > org.apache.activemq.transport.failover.FailoverTransport.oneway(FailoverTransport.java:424) > > On 3 August 2010 08:59, Michal Singer wrote: >> >> Hi, i get sometimes during initialization of AMQ the following exception, >> does anyone what may cause this exception and how it should

javax.jms.JMSException: Unexpected failure in AMQ

(ActiveMQConnection.java:1233) Thanks, Michal -- View this message in context: http://old.nabble.com/javax.jms.JMSException%3A-Unexpected-failure-in-AMQ-tp29332842p29332842.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Message returned in onMessage in client of AMQ is corrupted

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 t

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

(Unknown Source) Does any one know what this means? Thanks, Michal -- View this message in context: http://old.nabble.com/Transport-failed%3A-java.io.IOException%3A-Unknown-data-type%3A-68-tp27893082p27893082.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

How to monitor queue size of a thread pool

) Thanks, Michal -- View this message in context: http://old.nabble.com/How-to-monitor-queue-size-of-a-thread-pool-tp27510776p27510776.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

JMX connection problem

atful for any ideas on what I might be doing wrong... Thanks in advance. Michal -- View this message in context: http://old.nabble.com/JMX-connection-problem-tp26745832p26745832.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

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

limit, but it didn't help? Does any one know how i can allow shut down? Thanks, Michal -- View this message in context: http://www.nabble.com/How-to-shutdown-client-process-which-connects-to-jms-using-failover-parameter--tp22020443p22020443.html Sent from the ActiveMQ - User mailing list

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

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 B

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

> Regards > -- > Dejan Bosanac > > Open Source 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 > wrote: > >> >> Hi, th

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

Hi, the failover transport lets you load balance clients over a number of brokers. However, i have one broker and i don't need any more brokers. I want the client to be able to reconnect to the same broker once it is up again. How can i do that? Thanks, Michal Dejan Bosanac wrote: &g

Fail to reconnect to AMQ queues after restarting the broker

Hi. I am trying to simulate a scenario where the process raising the broker crashed and was raised again. I get a lot of EOF exceptions. what configuration is needed so that the client will succeed to reconnect to the queues after broker was restarted? This is the exception i get: javax.jms.JMSEx

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

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: >>

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

> some more intuitive names etc ? > > On 7 Jul 2008, at 05: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, &g

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

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: > >> &g

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

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: http://www.nabble.

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

: javax.management.InstanceNotFoundException: org.apache.activemq.embeddedbroker:type=Broker Any ideas how to connect? which object name to use? Thanks, Michal -- View this message in context: http://www.nabble.com/How-can-i-connect-to-JMX-beans-of-activemq-from-the-code-tp18111006p18111006.html Sent from the

AMQ 4 to 5: Database schema upgrade

metadata) from version 4 to version 5. Thanks Michal -- View this message in context: http://www.nabble.com/AMQ-4-to-5%3A-Database-schema-upgrade-tp17313145s2354p17313145.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Seperate client from activemq jar

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: http://www.nabble.com/Seperate-client-from-activemq-

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

h my code which maybe does not release resources correctly. Can any one assist me with understanding where the problem is? Thanks, Michal -- View this message in context: http://www.nabble.com/Memory-leak-detected-in-Jprofiler-with-the-following-activemq-objects%3A-%C2%A0MemoryU

ActiveMQQueueReceiver are kept in the memory even though they are closed

for the receivers? Thanks, Michal -- View this message in context: http://www.nabble.com/ActiveMQQueueReceiver-are-kept-in-the-memory-even-though-they-are-closed-tp16254312s2354p16254312.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Queue size of broker increases all the time

: ActiveMQ.Advisory.TempQueue i see the queue increases. It does not seem to influence the memory, but it looks like some kind of problem. Can any one help me? thanks, Michal -- View this message in context: http://www.nabble.com/Queue-size-of-broker-increases-all-the-time

Whats minimal use of jencks required for activemq & spring& consumer

tion: What will the MDP of jencks provide which activemq & spring does not provide, using the pool I used? Thanks, Michal -- View this message in context: http://www.nabble.com/Whats-minimal-use-of-jencks-required-for-activemq---spring--consumer-tp16237302s2354p

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

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 : > > > > > Regards, > Jonas > &

Re: Problems with disabling Advisory Support

The advisory disable does not work when using temp queues. But if i don't disable it, the advisory objects accumulated until out of memory. What should i do to solve this??? Michal Singer wrote: > > The snapshot i am using: > apache-activemq-5.1-20080311.181016-59 > >

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

Can you explain? this problem causes heavy memory leasks. since the Advisor shows increasing q size. submitting ack manually does not solve this. Can you assist me with this? Thanks ,Michal rajdavies wrote: > > ah - ok - so the problem is with the stats - thx > > On 20 Mar 20

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

) 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 messa

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

. AUTO_ACKNOWLEDGE does not work? 2. CLIENT_ACKNOWLEDGE does not work for temp queues? Thanks, Michal -- View this message in context: http://www.nabble.com/AUTO_ACKNOWLEDGE-does-not-work%2C-CLIENT_ACKNOWLEDGE-works-but-not-for-temp-queues-tp16173331s2354p16173331.html Sent from the ActiveMQ

Why does dequeue different from enqueue and from dispatch

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

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

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 memo

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

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. >>

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

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 fixe

Dequeue messages pace is much lower then enqueu - memory problems

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

Re: Problems with disabling Advisory Support

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 accumulate

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

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

will this version be released? James.Strachan wrote: > > Advisories are required to support temporary destinations > > On 17/03/2008, Michal Singer <[EMAIL PROTECTED]> wrote: >> >> Hi. I tried to disable Advisory Support using advisorySupport="false"

Problems with disabling Advisory Support

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 d

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

? 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

Outof memory using temp queus in active MQ- 5.1

exceptions. I use: activemq-all-5.1-SNAPSHOT.jar. I saw in the forum that there are bugs on this issue, but i didn't understand how or if they were solved. Any ideas on how to solve this? Thanks, Michal -- View this message in context: http://www.nabble.com/Outof-memory-using-temp-queus-in-a

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

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

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

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

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

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 399

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

op 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 > co

Jconsole accumulates a list of topics when i only create queues

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 accu

Send response to temporary queue gets stuck after 3900 sends

hi. I am using activemq 5.0.0 broker embedded in spring. I use temporary queues. After calling jmsTemplate.convertAndSend exactly 3990 times, the response will get stuck and not be delivered. No exception or error is shown. it just gets stuck for no apparent reason. Does any one have any ideas wh

Active MQ broker embedded with spring configuration problems

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: With this way i have a few problems: 1. how do i define the active mq configuration file. i c