On 15 Oct 2008, at 00:16, lawrencek wrote:
Hi,
I'm designing a system that will have a few central services and
upward of
6000 processes on thousands of machines on a LAN. They all
communicate using
ActiveMQ, with the central services having well-known queue names
and the
distributed co
What about using selective consumers? That way one queue can act like
multiple queues.
Joe
Get a free ActiveMQ user guide @ http://www.ttmsolutions.com
lawrencek wrote:
>
> Hi,
>
> I'm designing a system that will have a few central services and upward of
> 6000 processes on thousands of
On Tue, Oct 14, 2008 at 5:45 PM, ilango_g <[EMAIL PROTECTED]> wrote:
>
> I would definitely want to try this one out. The other question I have is: is
> it possible to have an MDB or a servlet do the same job?
>
> If it is, where can I start?
> Meanwhile, I will start working on the content based r
I would definitely want to try this one out. The other question I have is: is
it possible to have an MDB or a servlet do the same job?
If it is, where can I start?
Meanwhile, I will start working on the content based router based on your
suggestions.
thanks
ilango
bsnyder wrote:
>
> On Mon, O
Hi,
I'm designing a system that will have a few central services and upward of
6000 processes on thousands of machines on a LAN. They all communicate using
ActiveMQ, with the central services having well-known queue names and the
distributed components having randomly-generated queue names. I rec
On Tue, Oct 14, 2008 at 10:33 AM, jamh <[EMAIL PROTECTED]> wrote:
>
> Hi,
>
> When I start activemq (v. 5.1.0), I always see a couple of queues and
> destinations that were previously created with the persistent flag, and I
> suspect they hold messages that were never consumed. How do I get rid of
2008/10/14 Mark Webb <[EMAIL PROTECTED]>:
> nevermind, I thought this was a source code change
It was - on trunk
--
James
---
http://macstrac.blogspot.com/
Open Source Integration
http://fusesource.com/
nevermind, I thought this was a source code change
On Tue, Oct 14, 2008 at 1:52 PM, Mark Webb <[EMAIL PROTECTED]> wrote:
> on what branch did you check this in on? I just performed an update on the
> trunk and see no changes.
>
>
>
>
> On Tue, Oct 14, 2008 at 10:36 AM, James Strachan <[EMAIL
On Mon, Oct 13, 2008 at 4:52 PM, ilango_g <[EMAIL PROTECTED]> wrote:
>
> Actually I have refined my question further:
> There would be a queue that has messages
> sitting on it. This queue has a listener that listens for messages, picks up
> a certain message (FIFO perhaps), and sends it off to a d
on what branch did you check this in on? I just performed an update on the
trunk and see no changes.
On Tue, Oct 14, 2008 at 10:36 AM, James Strachan
<[EMAIL PROTECTED]>wrote:
> 2008/10/14 Mark Webb <[EMAIL PROTECTED]>:
> > You would be my new best friend if you did :)
>
> Done! :)
>
> --
> J
Hi,
When I start activemq (v. 5.1.0), I always see a couple of queues and
destinations that were previously created with the persistent flag, and I
suspect they hold messages that were never consumed. How do I get rid of
these? In the web admin interface I can purge/delete them, but on restart
Would it be possible to verify this behavior with trunk or with the
5.2 release candidate?
http://www.nabble.com/-VOTE--ActiveMQ-5.2.0---RC2-td19874910.html
If it is still an issue it warrants a jira and if you have a test
case, it would be fantastic!
thanks,
Gary.
2008/10/14 Rick Blair <[EMAIL
>this causes the following exception:
>Exception in thread "main"
>org.springframework.beans.factory.BeanDefinitionStoreException:
Unrecognized
>xbean namespace mapping: http://activemq.apache.org/camel/schema/spring
Assuming you run a maven project, have you added camel-spring as a
dependency?
2008/10/14 Mark Webb <[EMAIL PROTECTED]>:
> You would be my new best friend if you did :)
Done! :)
--
James
---
http://macstrac.blogspot.com/
Open Source Integration
http://fusesource.com/
You would be my new best friend if you did :)
In my opinion, it seems to me like this should be turned off by default and
then the option to turn it on is available. I am hitting OutOfMemory errors
after 10,000 messages, which takes about an hour for me.
On Tue, Oct 14, 2008 at 10:16 AM, James
I guess you miss camel schema definition
try adding something like this
http://activemq.apache.org/camel/schema/spring
http://activemq.apache.org/camel/schema/spring/camel-spring.xsd
at the end of your tag (or take a look at the default activemq
conf file).
Cheers
--
Dejan Bosanac
http://w
2008/10/10 Rob Davies <[EMAIL PROTECTED]>:
> That's not a a memory leak you're seeing - that's the wacky Retroactive
> Consumer functionality - see
> http://activemq.apache.org/retroactive-consumer.html
> The default policy is FixedSizeSubscrptionRecoveryPolicy - and the default
> cache size for e
2008/10/14 Dejan Bosanac <[EMAIL PROTECTED]>:
> Ah, Cool :) It's fixed now (revision 704544)
Yay! :)
--
James
---
http://macstrac.blogspot.com/
Open Source Integration
http://open.iona.com
Ah, Cool :) It's fixed now (revision 704544)
Cheers
--
Dejan Bosanac
http://www.ttmsolutions.com - get a free ActiveMQ user guide
ActiveMQ in Action - http://www.manning.com/snyder/
Scripting in Java - http://www.scriptinginjava.net
James Strachan wrote:
> Sorry I meant the field called "p
Hi all,
A little more information.
I looked at the acks that were being sent back from the subscriber. Under
heavy load the messageCount field in the ack message sometimes goes
negative. Once that happens, it is not long before the subscriber quits
sending acks. I have tried small and large val
So I would see this increase in memory on the JMS sender? This seems a
little strange. I have tried ActiveMQ 5.2 and see the same problem on the
sending client application.
On Fri, Oct 10, 2008 at 2:39 AM, Rob Davies <[EMAIL PROTECTED]> wrote:
> That's not a a memory leak you're seeing - tha
Hello there,
ich tried to configure the embedded broker with xml file like this:
BrokerService broker = BrokerFactory.createBroker(new
URI("xbean:file:C:/frameworks/ActiveM/activemq.xml"));
this causes the following exception:
Exception in thread "main"
org.springframework.beans.factory.BeanDefi
You're right, Ben. This is still rather flaky.
I've reopened the jira.
Thanks,
Joe
Benjamin April wrote:
>
> Joe Fernandez wrote:
>> Ben,
>>
>> I just ran a quick test with my 5.1 setup and everything worked as
>> expected.
>> With the networkConnector below, only messages destined for que
2008/10/14 Dejan Bosanac <[EMAIL PROTECTED]>:
> Done. BTW ObjectMessage already had this implemented.
>
> I'm not sure about properties, most of the message properties are
> fields, we could only mess things with byte properties and such.
Sorry I meant the field called "properties" which (from mem
Done. BTW ObjectMessage already had this implemented.
I'm not sure about properties, most of the message properties are
fields, we could only mess things with byte properties and such.
Cheers
--
Dejan Bosanac
http://www.ttmsolutions.com - get a free ActiveMQ user guide
ActiveMQ in Action - h
2008/10/14 Dejan Bosanac <[EMAIL PROTECTED]>:
> Hi,
>
> this all looks good. The fact that you see text = null (even when it is
> not null) in the log is because "text" filed of the text message object
> is set only after the first call of getText() method.
>
> What is returned by
>
> objMessage. g
Hi,
this all looks good. The fact that you see text = null (even when it is
not null) in the log is because "text" filed of the text message object
is set only after the first call of getText() method.
What is returned by
objMessage. getText()
call?
Also, can you check that the message you've
Peer did not send his wire format ...
Did anyone find with a solution for this problem ?
I have the same problem
javadevel wrote:
>
> We are trying to create a distributed logging service using Log4J and JMS
> appender to an ActiveMQ topic. However, we keep getting an error "Wire
> format ne
2008/10/14 Markus Wolf <[EMAIL PROTECTED]>:
> -BEGIN PGP SIGNED MESSAGE-
> Hash: SHA1
>
> Hi,
>
> when I try to start our client application with a failover transport and
> no broker is running, the application blocks until a broker is started.
> Is this desired behaviour or does I do somet
-BEGIN PGP SIGNED MESSAGE-
Hash: SHA1
Hi,
when I try to start our client application with a failover transport and
no broker is running, the application blocks until a broker is started.
Is this desired behaviour or does I do something wrong?
Thanks
Markus Wolf
- --
NMMN - New Media Mark
Thanks for the answer, will look at it.
-Original Message-
From: James Strachan [mailto:[EMAIL PROTECTED]
Sent: dinsdag 14 oktober 2008 10:56
To: users@activemq.apache.org
Subject: Re: Concurrent use of connections
Please see the FAQ entry...
http://activemq.apache.org/how-do-i-use-jms-
Please see the FAQ entry...
http://activemq.apache.org/how-do-i-use-jms-efficiently.html
you are not meant to create a consumer or producer for each message;
but reuse the same consumer
If you are new to JMS and have not yet grokked how to use it
efficiently, try using the JmsTemplate / MessageLi
Hi,
I managed to reproduce the problem in the simple sample below. What I do is to
create a connection that is shared between a consuming thread and a producing
thread. The consumer is slower than the producer. When I run this sample,
either the consumer stops consuming although lots of message
33 matches
Mail list logo
