Re: Topic - Wait for space

I think I might have found where I am using up memory, my policyEntry looks like: Does the space for the 2500 messages for slow consumers not come out of the 10mb for each consumer, but instead out of the overall SystemUsage memory? Thanks. -- View this

Topic - Wait for space

Hi, I have a thread trying to send to a topic, which is caught in a 'waitForSpace' function. I am only using memory, no disk and I believe I have plenty configured in the SystemUsage. I thought sending to a topic would not invoke producer control when no one is reading it... so I am not sure what

Controlling Queue w/o Consumers

Hi, I have a situation where a consumer on a queue could disappear. The sending components wouldn't know for a while (they have to be told via another mechanism) and messages might build and stop the producer. What are my options for controlling this in activemq, w/o any kick back to the producer

Help with Topic Expirations

Hi, My topics messages aren't expiring. I want messages to expire after the number of pending messages reach 1, basically having the consumer not get all the messages if it can't keep up. I thought the pendingMessageLimitStrategy would give me this, but it doesn't appear to be working as I con

Upgrading 5.5.1->5.6.0 - Core Libraries

Hi, I have a system with an embedded broker. I use the activemq-core & a few other jars (pulled in via maven pom file). I am trying to upgrade from 5.5.1->5.6.0, which I thought was just a maintenance release. But after inspecting and upgrading, I am noticing a lot more to this. The dependencie

Subscribed w/Wildcard, Not propagating across brokers

Hi, I have a network of brokers, all attached to each other. When 1 client subscribes to a queue or topic, regardless of which broker the sender is on, the messages correctly propagate between the brokers. However, when I subscribe to a topic using a wildcard (i.e. 'PROJ.>') only clients connect

Re: addNetworkConnector - JMX Error

You can't set the connector name because it fails on the first line, before the connector object is returned. I did find an answer (documenting here in case anyone googles this group later). Basically, don't use the addNetworkConnector(String), but instead addNetworkConnector(NetworkConnector). >

addNetworkConnector - JMX Error

Hi, I want to be able to add a network connector a runtime. I believe this code works, but it throws an error on the first line: > NetworkConnector connector = > broker.addNetworkConnector("static://"+"tcp://"+host+":61616"); > connector.setDuplex(true); > connector.start(); Is it the connector

Simple Embedded Broker from Jar file

Hi, I am trying to get a very simple embedded broker running, inside a jar, running correctly. I have the broker reading the activemq.xml file from the jar. But what about other needed files? It appears to be trying to download other xsds. My assumption was: If I have the right jars, it shouldn

Shutting down a broker w/an active queue

Hi, I am experimenting with multiple consumers & shutting them down individually. I have a scenario where I have a consumer and someone sends something to 'testQueue'. > broker = new BrokerService(); > broker.setBrokerName("PhillyBroker"); > broker.addConnector("tcp://localhost:61616"); > broker.

Not restarting after GC

I have a java components set with a 8gb heap size. When it runs out of memory & tries to GC, it looks like the activemq times out (which I guess is normal considering the time it takes to run through the heap). Other actions on the component recover, however, one function that was stopped when t

Re: Can I set a temporary queue size?

to the same memory limits as regular queues > but > there is no explicit size limit. Message expiry (time to live) is probably > your friend here. > > 2009/10/20 sub3 > >> >> In my activemq.xml file, I like to keep all the queues small. However, >> for >

Can I set a temporary queue size?

In my activemq.xml file, I like to keep all the queues small. However, for one processes that accepts requests & return the data via a temporary queue, the data might be larger than my maximum size. Is there anyway to set the size of a temporary queue? Thanks. -- View this message in context:

Re: Stack Overflow

I guess upgrading was a bad idea. Now I get spammed on the console with the message below. Can someone suggest a version between the 2 that will work? Thanks. 2008-11-12 15:37:04,156 [ActiveMQ Transport: tcp:///127.0.0.1:1293] ERROR org.apache.activemq.broker.TransportConnection.Service - Async

Re: Stack Overflow

g the stack. The > stack does look to be repeating itself. Is the problem easily > reproducible? > Also what version of the broker are you using? > > /Dave > > On Tue, Nov 11, 2008 at 11:32 AM, sub3 <[EMAIL PROTECTED]> wrote: > >> >> Hi, >> >> Ca

Stack Overflow

Hi, Can someone tell me what is happening here? I don't know much about the internals of ActiveMQ code, so I am not sure how to diagnosis. 2008-11-11 16:20:36,586 [ActiveMQ Transport: tcp:///127.0.0.1:2250] ERROR org.apache.activemq.broker.TransportConnection.Service - Async error occurred: jav

Getting ActiveMQ to reconnect

How do I get a jms client to relisten to a queue? Am I supposed to be listening for errors & find out who it might be for? The Situation: Occasionally, I might get the 'javax.jms.JMSException: Channel was inactive for too long...' errors. My clients using camel reconnected fine & started listenin

Re: Under IO Load

After pouring through more debug, this one seems to come up occasionally: 2008-08-13 12:26:50,144 [InactivityMonitor Async Task: [EMAIL PROTECTED] DEBUG org.apache.activemq.ActiveMQConnection - Async exception with no exception listener: org.apache.activemq.transport.InactivityIOException: Channe

Re: Under IO Load

Hope that helps. Thanks. elihusmails wrote: > > what is your hardware configuration? > > > On Mon, Aug 11, 2008 at 8:23 PM, sub3 <[EMAIL PROTECTED]> wrote: > >> >> Sorry, that last sentence sounds wrong, let me restate: >> When I run several o

Re: Under IO Load

bsnyder wrote: > > On Mon, Aug 11, 2008 at 3:08 PM, sub3 <[EMAIL PROTECTED]> wrote: >> >> I have a system where 1 is sending to several (a & b) and occasionally b >> sends to c (all queues). Very simple. Persistence is set to false. >> Queue >>

Re: Under IO Load

ogged down with i/o. Any insight would be appreciated. Thanks. sub3 wrote: > > That is correct. The processes that are performing the i/o on the disk > are separate jvms. It is not the same as the components using ActiveMQ. > They high i/o usage are somehow causing ActiveMQ to sto

Re: Under IO Load

gt; > > On Mon, Aug 11, 2008 at 5:08 PM, sub3 <[EMAIL PROTECTED]> wrote: > >> >> I have a system where 1 is sending to several (a & b) and occasionally b >> sends to c (all queues). Very simple. Persistence is set to false. >> Queue >> s

Under IO Load

I have a system where 1 is sending to several (a & b) and occasionally b sends to c (all queues). Very simple. Persistence is set to false. Queue sizes are capped at 50mb. If I put the system under a heavy i/o load (several programs reading/writing lots of files), ActiveMQ will stop. Am I hi

Debugging a locked state

Hi, Occasionally, my system locks up (7/31 Snapshot). I've poured though the logs and can't find any reason for the stoppage. If I restart a component, it gets locked when it executes 'connection.setClientID(clientId)'. Can any give me any insight as to what ActiveMQ does here? I.e. is it waiti

Virtual Topic Size

Hi, Is there a way to set the maximum size of a Virtual Topic. I have my queues & topic set to a maximum of 50mb, but it doesn't appear to work with VirtualTopic. Currently, I am seeing the system slow down to a crawl when the VT takes up most of the activemq jvm memory. Any suggestions? Thanks

Queue Fill Up

Hi, I am using VirtualTopics and when I start nailing the system with messages, ActiveMQ starts to throw null pointers. Since I am putting out a lot of messages, I am assuming some internal queue if filling up. Is that right? I though ActiveMQ would slow down in this instance. Is there a paramete

Help With Virtual Topic

Hi, I can't seem to get the VirtualTopic working correctly. I have 1 producer & 2 consumers. However, each message only ends up getting to 1 of the receivers. Can someone tell me if I am setting these up correctly: Producer: Destination myQueue = session.createTopic("VirtualTopic.FOO"); produc