On 2 May 2008, at 19:48, seven_ephors wrote:
What is the typical message size when BLOB message should be used?
--
View this message in context: http://www.nabble.com/Publisher-can%27t-publish-after-a-certain-number-of-messages-are-sent-tp16995039s2354p17025624.html
Sent from the ActiveMQ -
One of the changes in release 5.1 is this Improvement
http://issues.apache.org/activemq/browse/AMQ-545 but I can't figure
out how it's supposed to be specified.
In every case the broker fails to start. Here's an excerpt from the exception:
UnsatisfiedDependencyException: Error creating bean with
Forgot to mention the test was run on ActiveMQ v4.1.1
--
View this message in context:
http://www.nabble.com/Transaction-State-tp16968998s2354p17028108.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
I built the openwire-c sources under cygwin. When I run the main.exe app it
produces, this is what gets logged by the broker it talks to:
DEBUG WireFormatNegotiator - Sending: WireFormatInfo { version=3,
properties={CacheSize=1024, CacheEnabled=true, SizePrefixDisabled=false,
TcpNoDelay
I've created a test case that shows failover does not work for transacted
sessions on a JDBC Master/Slave topology. By this I mean when the slave
becomes the new master on failover, previously running transactions are not
respected by the new master. This leads to the situation where a message can
I have a couple ad-hoc queues, each with 2 consumers running. For whatever
reason, the number of consumers on one queue is 17, the other 5. These are all
Stomp clients. There have been a few unclean kills of the consumers, but my
understanding is that the consumers would be flushed on the nex
What is the typical message size when BLOB message should be used?
--
View this message in context:
http://www.nabble.com/Publisher-can%27t-publish-after-a-certain-number-of-messages-are-sent-tp16995039s2354p17025624.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
On Fri, May 2, 2008 at 10:50 AM, seven_ephors <[EMAIL PROTECTED]> wrote:
>
> I will give it a try later, but it seems to me that it probably won't solve
> the problem since the consumer fetches the message as soon as it is
> published, and when I increase the message size, the number of message
Allright, the sleuthing continues. I did a heap dump of the broker vm
when the broker was using 100% of its memory and everything had come to
a standstill. I openend the heapdum in visualvm (see pic), but I have to
confess it doesn't mean that much to me. There seem to be an awful lot
of ActiveMQTe
Will 5.1 address all the issues: NullPointerException,
TransportDisposedIOException and RecoveryListenerAdapter error?
I did see that RecoveryListenerAdapter error was fixed on 5.1.
Any idea when 5.1 is planned for release?
rajdavies wrote:
>
>
> On 1 May 2008, at 22:52, sk123 wrote:
>
>>
I will give it a try later, but it seems to me that it probably won't solve
the problem since the consumer fetches the message as soon as it is
published, and when I increase the message size, the number of message that
can be send decrease accordingly. For example, when the BytesMessage has
the
Hi Joe,
Using the Spring listeners, we've actually got about 10-20 threads on
each stage of the pipeline, all consuming messages. The problem is that
we'd like to be able to deal with a situation where there are
potentially millions of messages waiting in to be processed without
having to concede
What about creating clusters of consumers for each of your processing stages
to better-handle the load spikes? The messages will get load-balanced across
the consumers in a cluster.
Joe
Get a free ActiveMQ user guide at www.ttmsolutions.com
Maarten Dirkse-2 wrote:
>
> An update:
> I've now
Hi,
I'd like to contribute to the docs in the activemq wiki. My confluence
username is mdirkse.
Thanks,
Maarten
---
Filterworks BV
Information Compliance
Tel: +31 (0)88 88 222 45
Mob: +31 (0)6 24 65 75 85
Email: [EMA
hi
how can i make activemq persister to use my pre configured datasource.
i am using jboss server and i have a -ds.xml file which creted all my data
sources. Now for persisting messages i want use the data source from -ds.xml
file. so i did a jndi lookup for data source in broker-config file but
An update:
I've now tried it with the standard amqpersistence config:
And it still results in the same problem. When I give the broker 128mb
of memory, everything runs fine until it has processed about 126,000
messages. Then the memory usage hits 100%, and everything slows to a
If that is true, how is it possible that the JBossMQ connection
factory is available to remote clients?
I think is against the purpose of the standard if a change in the
implementation causes the clients to stop working.
Alex Soto
[EMAIL PROTECTED]
-
Amicus Plato, sed magis amica veritas.
Hi again,
here are the full stack traces.
1 - Broker
Loading message broker from: xbean:activemq.xml
INFO BrokerService - Using Persistence Adapter:
AMQPersistenceAdapter(/work/michele/apache-activemq-5.0.0/data/localhost)
INFO BrokerService - ActiveMQ 5.0.0 JM
Hi Jamie,
thanks for your reply. Unfortunately the HeapDumpOnOutOfMemoryError
options works only when the OOME is due to heap space problems, not
when the system is unable to create new threads [1].
Michele
[1] http://java.sun.com/javase/6/webnotes/trouble/TSG-VM/html/
gdaog.html#gbzrr
Filip,
are you talking about the broker or the client? The settings below
are for the broker.
Michele
On 2 May 2008, at 00:20, Filip Hanik - Dev Lists wrote:
-Xms512m -Xmx1024m -Xmn500m
If you can use Java 6, try the following setting:
-XX:+HeapDumpOnOutOfMemoryError
(and -XX:HeapDumpPath if you want the dump to go somewhere specific)
This will give you a heap dump which should help a _lot_ to diagnose
the problem. I'd recommend checking out the Memory Analyzer plugin for
Eclip
On 2 May 2008, at 00:20, Filip Hanik - Dev Lists wrote:
Michele Mazzucco wrote:
Filip,
if you mean on the client side, I have a thread pool configured to
create max 100 threads.
there could still be a thread leak in your application somewhere
No, there's no leak on my client app. It's a
Hi,
I've spent quite a bit of time trying to find a solution to this problem, but
nothing that I've come across in the documentation or the mailing list seems to
help, so here goes:
I've got ActiveMQ set up to provide messaging between a chain of four
components, connected by three queues like
23 matches
Mail list logo
