Re: Delete me of mailing liste

[Tom Hall]

You can remove yourself by emailing users-unsubscr...@activemq.apache.org 


There are multiple lists, so you want to make sure you have unsubscribed, to 
everything you are currently subscribed to.
dev-unsubscr...@activemq.apache.org 
commits-unsubscr...@activemq.apache.org 

issues-unsubscr...@activemq.apache.org

-Tom

> On May 31, 2018, at 6:12 AM, eric.l...@ec.europa.eu wrote:
> 
> Delete me also from the list pse.
> 
> -Original Message-
> From: Loic Le Meur [mailto:loiclemeur...@gmail.com] 
> Sent: Thursday, May 31, 2018 3:06 PM
> To: users@activemq.apache.org
> Subject: Re: Delete me of mailing liste
> 
> I have tried several times but I continue to receive emails .
> So how do we do it?
> 
> 2018-05-30 23:51 GMT+02:00 Tim Bain :
> 
>> No, but you can unsubscribe yourself. See
>> http://activemq.apache.org/mailing-lists.html for details.
>> 
>> Tim
>> 
>> On Wed, May 30, 2018, 7:35 AM Loic Le Meur 
>> wrote:
>> 
>>> Hello can you delete me of mailing liste.
>>> Thanks
>>> 
>>> 
>>> Loïc
>>> 
>> 

Re: How to avoid ActiveMQ 5.x OutOfMemory in certain high-pressure conditions?

[Tom Hall]

Not sure if this applies here:
http://activemq.2283324.n4.nabble.com/Producer-Window-Size-td4668545.html 


The way I read the response producer window size stops flow control.

-Tom


> On Aug 7, 2018, at 5:52 AM, art.licis  wrote:
> 
> Dear community,
> 
> Sorry, I forgot to add code samples.
> 
> Single-class test:
> https://github.com/art-licis/activemq-showcase/blob/master/src/main/java/today/jvm/amq/showcase/TopicFlowControlOOM.java
> 
> Configuration broker uses:
> https://github.com/art-licis/activemq-showcase/blob/master/src/main/resources/today/jvm/amq/showcase/activemq-flow-control.xml
> 
> Regards,
> Art
> 
> 
> 
> 
> --
> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: cipher in activemq

[Tom Hall]

I am assuming you mean on the ssl transports. You must specify the ones want 
enabled.

docs are here: http://activemq.apache.org/ssl-transport-reference.html 


Assuming you are running java 8 here are the list of cipher suites
https://docs.oracle.com/javase/8/docs/technotes/guides/security/StandardNames.html#ciphersuites

-Tom


> On Aug 28, 2018, at 4:44 AM, ankushssgb  wrote:
> 
> Hi,
> 
> I want to disable RC4 and 3DES ciphers in apache-activemq-5.9.0.
> 
> OS Version: CentOS7
> 
> Can any one help me, how to do it.
> 
> Regards,
> AB
> 
> 
> 
> --
> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Using AWS EFS as the shared file system for master/slave broker pair

[Tom Hall]

There are a number of docker images for activemq, you will need to follow the 
documentation for that docker image.  
Make sure your docker image is using the latest version of activemq.
You are going to need to change the data directory to be under the efs mount, 
and you are going to have to configure a pluggable storage locker as well.
https://cwiki.apache.org/confluence/display/ACTIVEMQ/Pluggable+storage+lockers 

https://activemq.apache.org/pluggable-storage-lockers.html

-Tom

> On Jul 18, 2018, at 3:47 PM, avmpt  wrote:
> 
> I would like to use EFS as the shared file system when I set up a
> master/slave broker pair. What changes would I need to make to the
> persistence adapter to use the mounted EFS path?
> 
> When I have
> 
>
> 
> 
> Would I need to change it to the path where EFS is mounted? Are there any
> additional changes required? My activemq brokers are both docker containers
> so I'm not sure how exactly this would affect my setup. Thanks!
> 
> 
> 
> 
> --
> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: ActiveMQ 5.11.0: Out Of Memory, caused by PageFile object tree filling up heap

[Tom Hall]

Hi Art,
What per destination limit are you looking for? The per destination limits will 
deal with memory used per queue.
http://activemq.apache.org/per-destination-policies.html 

 
   

-Tom

> On Jul 20, 2018, at 3:50 AM, art.licis  wrote:
> 
> 300mb memory limit is on a VM having -XmX 4Gb for heap; on 8Gb (most likely)
> it was more. While I totally agree 300 Mb memory limit is far from the
> optimal setting, and even better per-destination limits are needed.
> 
> However, I have stress tested ActiveMQ with much less memory, and I've seen
> the following in logs:
> 
> topic://topic-3, Usage Manager memory
> limit reached 5242880. Producers will be throttled to the rate at which
> messages are removed from this destination to prevent flooding it.
> 
> << just 5Mb of memory limit on this test!
> 
> .. and eventually this:
> 
> TopicSubscription: consumer=ID:a-thinkpad-44715-1532031318503-1:1:1:1,
> destinations=1, dispatched=32766, delivered=15963293, matched=1460,
> discarded=0, prefetchExtension=0: Pending message cursor
> [org.apache.activemq.broker.region.cursors.FilePendingMessageCursor@6bba423c]
> is full, temp usag (100%) or memory usage (0%) limit reached, blocking
> message add() pending the release of resources.
> 
> << all 10Gb of temp store filled!
> 
> 
> Which means filling up temp store and blocking the producer, but NOT
> crashing with out of memory, having all heap filled with PageFile-related
> data.
> 
> - Art
> 
> 
> 
> --
> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Logging DLQ activity

[Tom Hall]

If you are willing to do some light development you can put in some specific 
code to do just that logging, or you could enable the logging plugin but you 
will get more than what you want.

take a look at http://activemq.apache.org/developing-plugins.html 

the logging plugin code is at: 
https://github.com/apache/activemq/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 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 messages do I have to look for?

Re: Using AWS EFS as the shared file system for master/slave broker pair

[Tom Hall]

When I implemented AMQ on EFS, EFS only had optimistic locking so the pluggable 
locker was needed.  I can no longer find reference to it, and AWS has made 
significant changes to EFS locking  so it may not be necessary anymore.
Thanks,
-Tom

> On Jul 21, 2018, at 6:25 AM, Tim Bain  wrote:
> 
> Third reply, hopefully this is the last thing I missed.
> 
> If pluggable lockers are required in order to use EFS, they would be
> required irrespective of which version of ActiveMQ you use. However, the
> EFS FAQ says that EFS supports NFS 4.1 locking semantics, which sounds to
> me like pluggable lockers would not be required. But I've not tested that,
> so it would be great if you could let us know how it works when you test
> your setup.
> 
> Thanks,
> Tim
> 
> On Sat, Jul 21, 2018, 7:19 AM Tim Bain  wrote:
> 
>> I forgot to answer your other question.
>> 
>> That just means that you have to configure the path for the KahaDB data
>> directory (in activemq.xml) to be a path under your EFS mount.
>> 
>> Tim
>> 
>> On Sat, Jul 21, 2018, 7:17 AM Tim Bain  wrote:
>> 
>>> The bug I linked to, which addresses the fact that EFS is so large that
>>> the ActiveMQ code believes it has a negative size, was fixed in 5.15.0, so
>>> I would expect 5.14.3 not to work. But YMMV if EFS is reporting a different
>>> amount of free space today than it did when that bug was submitted.
>>> 
>>> Tim
>>> 
>>> On Fri, Jul 20, 2018, 2:22 PM avmpt  wrote:
>>> 
 I am using a custom docker image rather than any of the ones available
 online. The config uses a base os image and then has the following
 activemq
 settings:
 ---
 
 ENV ACTIVEMQ_VERSION 5.14.3
 ENV ACTIVEMQ apache-activemq-$ACTIVEMQ_VERSION
 
 ENV ACTIVEMQ_HOME /opt/activemq
 
 RUN tdnf -y install tar gzip
 
 RUN set -x && \
mkdir -p /opt && \
curl -s -S
 
 https://archive.apache.org/dist/activemq/$ACTIVEMQ_VERSION/$ACTIVEMQ-bin.tar.gz
 | tar xvz -C /opt && \
ln -s /opt/$ACTIVEMQ $ACTIVEMQ_HOME && \
useradd -r -M -d $ACTIVEMQ_HOME activemq
 
 RUN chmod 764 $ACTIVEMQ_HOME
 COPY activemq.xml $ACTIVEMQ_HOME/conf/
 WORKDIR $ACTIVEMQ_HOME
 
 CMD ["/bin/sh", "-c", "bin/activemq console"]
 
 ---
 
 For this version of AMQ (5.14.3) would it still be possible to setup the
 EFS
 without pluggable storage lockers? Also can you elaborate about changing
 the
 data directory to being under the efs mount? I'm not sure I understand
 that
 part. Thanks!
 
 
 thall wrote
> There are a number of docker images for activemq, you will need to
 follow
> the documentation for that docker image.
> Make sure your docker image is using the latest version of activemq.
> You are going to need to change the data directory to be under the efs
> mount, and you are going to have to configure a pluggable storage
 locker
> as well.
> 
 https://cwiki.apache.org/confluence/display/ACTIVEMQ/Pluggable+storage+lockers
> 
 https://cwiki.apache.org/confluence/display/ACTIVEMQ/Pluggable+storage+lockers
 ;
> https://activemq.apache.org/pluggable-storage-lockers.html
> 
> -Tom
> 
>> On Jul 18, 2018, at 3:47 PM, avmpt 
 
> patelakash@
 
>  wrote:
>> 
>> I would like to use EFS as the shared file system when I set up a
>> master/slave broker pair. What changes would I need to make to the
>> persistence adapter to use the mounted EFS path?
>> 
>> When I have
>> 
> 
>> 
> 
>> 
> 
>> 
>> Would I need to change it to the path where EFS is mounted? Are there
 any
>> additional changes required? My activemq brokers are both docker
>> containers
>> so I'm not sure how exactly this would affect my setup. Thanks!
>> 
>> 
>> 
>> 
>> --
>> Sent from:
>> http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
 
 
 
 
 
 --
 Sent from:
 http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
 
>>> 

Re: ActiveMQ 5.11.0: Out Of Memory, caused by PageFile object tree filling up heap

[Tom Hall]

Are you really limiting ram to 300 mb? Why so low if you are on a 8G box?
Thanks,
Tom

> On Jul 19, 2018, at 7:13 AM, art.licis  wrote:
> 
> Dear community,
> 
> We've been evaluation AMQ which is based on version 5.11.0. Several tests in
> staging environments which would have a big number of producers and
> consumers ended up with OutOfMemory: GC Overhead Limit exceeded exception.
> However, it looks like it's just one slow consumer that is causing this
> memory problem (details below).
> 
> Initially, we tried running AMQ with 4Gb of max heap, later with 8Gb but it
> had the same outcome.
> 
> Configuration: we have intentionally producer flow control turned off, and
> expecting temp store to fill up before the producer is blocked
> (non-persistent topic messages). I can simulate this with a simple and
> controlled tests involving very fast producer, and several fast and some
> slow consumers. With manual testing we achieve the desired result: when temp
> store reaches the limit, the producer is blocked.
> 
> We analyzed GC outputs and heap dump which we got upon the crash. Time spent
> in GC keeps significantly increasing before the crash, and heap dump shows
> the majority of memory occupied by PageFile object tree (lots of
> PageFile$PageWrite objects, which indicate that too much data remains in
> memory uncommitted to temp store; also related DataFileAppender$WriteBatch).
> PageFile is the correct one, the one used in PListStoreImpl (i.e. temp store
> for non-persistent messages).
> 
> During my analysis I also discovered some bug that was fixed recently -
> *AMQ-6815*. It looks like it affects the exact class family that could have
> caused the memory leak. 
> 
> I'd be grateful for any help or suggestions. I'm currently preparing the
> bigger test environment with many producers/consumers (and I'm also gonna
> run Activemq in docker to limit I/O speed while I'm sure it wasn't the
> issue), but the fact is that out of potentially thousands of
> producers/consumers there was only one slow consumer. Eventually, we will
> try running whole system against latest ActiveMQ, however, it will take lots
> of arrangements and I'd like to see if I can make reproducable and
> controlled test environment, and if there're some pitfalls in current setup.
> 
> activemq.xml is below (the slow consumer was not the one listening to
> virtual topic). And I will post more info if I'm able to solve the issue or
> at least get more hints.
> 
> Thank you.
> -Art
> 
>   xmlns="http://www.springframework.org/schema/beans;
>  xmlns:amq="http://activemq.apache.org/schema/core;
>  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
>  xsi:schemaLocation="http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans.xsd
>  http://activemq.apache.org/schema/core
> http://activemq.apache.org/schema/core/activemq-core.xsd;>
> 
> 
> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
>
>
>
>
> 
>http://activemq.apache.org/schema/core;
> brokerName="${broker-name}" dataDirectory="${data}" start="false"
> restartAllowed="false">
> 
>
>
>  
>
>
> optimizedDispatch="true" >
>
>  
>
>
> 
>
>
>
> 
>
>
>
> 
>
>
>
> 
>
>
> 
>
>
>
>
>
>
>
>
>
>
>
>
>
> 
>
> uri="tcp://0.0.0.0:0?maximumConnections=1000wireFormat.maxFrameSize=104857600"/>
>
> 
>
>
>
> forwardOnly="false">
>
> physicalName="rpc.request.virtual.notifications" />
>
>
> forwardOnly="false">
>
> physicalName="rpc.response.virtual.notifications" />
>
>
>
>
>
> 
>
> 
> 
> 
> 
> 
> --
> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: What does “Messages Dequeued” mean on ActiveMQ web console page?

[Tom Hall]

This is the first result when I googled your question.
http://activemq.2283324.n4.nabble.com/Message-Dequeue-count-in-jconsole-0-even-after-messages-are-recieved-and-consumed-by-subscribers-td4675875.html
 

It seems to answer your question.


> On Jul 12, 2018, at 7:20 AM, libing195205  wrote:
> 
> It's sad that nobody interests in it, could anyone help?
> 
> 
> 
> --
> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: How to do a check health with telnet on ActiveMQ

[Tom Hall]

I think you might be better off using something like this: 
https://github.com/prometheus/jmx_exporter 


-Tom


> On Jan 16, 2020, at 11:09 AM, Daniel Trüssel  wrote:
> 
> Hey
> 
> I use Prometheus blackbox_exporter
> https://github.com/prometheus/blackbox_exporter/blob/master/CONFIGURATION.md#tcp_probe
> 
> I wish to have a telnet command to check for ActiveMQ health.
> 
> an example for IRC protocal is this
> https://github.com/prometheus/blackbox_exporter/blob/master/example.yml#L88-L97
> 
> kind regards
> Daniel
>