I have an AMQ installation with only non-persistent queues. For those I
would like to get the SIZE of the total amount of messages per day
(megabytes, gigabytes, ...).
I know I can use the Enqueue count and (sort of) calculate the message size
by hand - but this is very cumbersome and not too accu
blob/master/activemq-
> broker/src/main/java/org/apache/activemq/broker/util/
> LoggingBrokerPlugin.java>
>
> Thanks,
> Tom
>
>
> > On Jul 17, 2018, at 1:20 AM, Frizz
> wrote:
> >
> > I'd like to get notified each time a messages ends up in a D
I'd like to get notified each time a messages ends up in a DLQ.
My preferred solution would be to use the existing ELK stack and write a
filter in Kibana.
(have the AMQ logfiles sent via Logstash to Kibana)
Question is: How can I configure AMQ to write DLQ related messages in the
logfiles? What m
My clients connect to AMQ with this connection string:
(tcp://amq1:61616,tcp://amq2:61616)?randomize=false&priorityBackup=true
It works - for some time. But sooner or later my AMQ server becomes
unresponsive because the host it runs on runs out of resources (threads).
The AMQ server basically kill
In an atempt to improve the throughput of my system I did various tests. I
started with a simple setup:
- 1 Topic, non persistent
- 1 Producer
- 1 Consumer
- Messge size: 4k
- Active MQ 5.12.1
My system is reasonably fast (8 cores, 32GB memory, SSD) - still I only
manage to send & receive about 45
To improve sending/receiving of ObjectMessages I used another serialization
framework (Kryo). I was a bit surprised, because the performance gain was
not as big es expected.
- When using Kryo with ActiveMQ it improved sending/receiving message with
about factor 2,5.
- In my stand alone Java serial
On Tue, Feb 23, 2016 at 12:25 PM, Robbie Gemmell
wrote:
> I can't say for sure from your summarised description and partial
> code, but it seems like you may only ever create 1 connection object
> with the factory. If so, explicitly creating multiple connections and
> splitting your producers acr
On Mon, Feb 22, 2016 at 5:32 PM, Timothy Bish wrote:
> ... and for the case of many senders you might
> indeed see a performance drop since you are now reducing the number of
> connections to what looks like eight, so all those producers are now
> restricted to eight connection to shovel all thei
Hi there,
I am experimenting with a Pooled Connection Factory - but I don't see any
performance gain (even worse: using PooledConnectionFactory is slower than
ActiveMQConnectionFactory).
What I do: Sending a few 100.000 messages in several threads (using
CompletableFuture). Ond run with a ActiveM
nstead of expected 7 bytes'
Might this be a problem with credentials?
cheers,
Frizz
ut how ActiveMQ uses
> xbeans to generate its XSD:
>
> http://www.christianposta.com/blog/?p=111
>
>
> On Wed, Sep 25, 2013 at 3:26 AM, Frizz wrote:
>
> > Hello,
> >
> > I create my own BrokerPlugin and configured it in activemq.xml like this:
> >
Hello,
I create my own BrokerPlugin and configured it in activemq.xml like this:
http://activemq.apache.org/schema/core";
brokerName="localhost" dataDirectory="${activemq.data}">
http://www.springframework.org/schema/beans";
id="myBrokerPlugin" class="myPackage.MyBrokerPlugin">
>
>
> instead?
> I recently got a destination interceptor to work that way and had to
> specify the namespace for correctly.
>
>
> Regards,
>
> Torsten Mielke
> tmie...@redhat.com
> tmielke.blogspot.com
>
>
> On Sep 12, 2013, at 2:10 PM, Frizz wrote
Hello,
I made a new BrokerPlugin as described here:
http://fusesource.com/docs/mirrors/activemq/features/interceptors.html
I edited activemq.xml to add a "plugins" element to "broker" like this:
http://activemq.org/config/1.0"; brokerName="localhost"
dataDirectory="${activemq.base}/data" plugins
Hi,
is there in ActiveMQ a concept like Interceptors and Phases like in Apache
CXF?
I'd like to plug in some custom functionality in the sending and receiving
part of the messaging.
In CXF I would do something like
Is there
15 matches
Mail list logo
