kahadb.log files not cleaning up on scheduler store

Hi, We have deployed ActiveMQ v5.6 and it has been running for last 3 years. We are in the process of upgrading to Artemis, but facing an issue currently with deployed version. We are sending messages with AMQ_SCHEDULED_DELAY header to topic and have used retrypolicy on the consumer side. We

[Artemis] Replication error with static connectors

Hi, We have a master/slave setup with static connectors. Setup itself is working fine but we see below message in log files whenever we send message. Not sure why this message is being logged and anything we need to concerned off. 00:01:44,801 DEBUG

Re: [Artemis] Replication error with static connectors

Thanks for the confirmation. Will ignore the message -- View this message in context: http://activemq.2283324.n4.nabble.com/Artemis-Replication-error-with-static-connectors-tp4713332p4713347.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Error while master boots up

Hi All, I am new to Artemis and trying to setup simple master/slave setup with static connectors. I have followed static connector example to setup config. But, when I try to bring up the cluster I am getting an error in master node. Slave is coming up successfully without any issue. Not sure

Re: Error while master boots up

Got it fixed. Had a connector definition wrong on slave broker.xml. Have pushed latest to the examples. -- View this message in context: http://activemq.2283324.n4.nabble.com/Error-while-master-boots-up-tp4707407p4707462.html Sent from the ActiveMQ - User mailing list archive at

Re: Error while master boots up

Thanks for the response. I have added an example with config I am using here: https://github.com/abhijith-prabhakar/activemq-artemis/tree/master/examples/bugs I tried to run Replicated static example test case and it is giving me different error with embedded broker. Please also note

Re: Error while master boots up

Thanks Clebert!! Really apppretiate your help. I will try this out and let you know the outcome. Can I get a bit more info on connector's name? Does connector type is picked up by name?? I tried reading connectors document under 'configuring transports' but couldn't find much info on

Re: Artemis bin/artemis script execution on solaris VM

Found the issue myself. Posting it here in case anyone else needs it. Issue is that all artemis scripts use #!/bin/sh shebang which is not preferred way to achieve portability. More info here . Once I changed

Slave health check

Hi, I have a master/slave configuration with replication enabled using static connectors. We would like to do health check on both master and slave. Verifying master is up is easy enough, but how to verify slave is up and listening to master? Is JMX only option here? I tried to see if slave

Re: Slave health check

Apologies for not being clear. I am referring to Apache Artemis broker with replication enabled. I am not using shared store model. (https://activemq.apache.org/artemis/docs/1.2.0/ha.html) -- View this message in context:

Artemis bin/artemis script execution on solaris VM

Hi, I am trying to execute artemis-1.2.0/bin/artemis script on a solaris VM. I am getting an error :~/apache-artemis]: application/artemis-installer/apache-artemis-1.2.0/bin/artemis help create application/artemis-installer/apache-artemis-1.2.0/bin/artemis: syntax error at line 61:

Adding custom decoder into Artemis classpath

Hi, I have written a custom decoder for password decryption and has bundled it into a jar. Documentation on below link says to add it into the classpath https://activemq.apache.org/artemis/docs/1.2.0/configuration-index.html But, it does not specify how I can add custom jar into classpath. I

Apache Artemis pooling

Hi, I am new to Apache artemis and was looking to pool jms related objects for producer and consumer. We are using embedded Jetty container and do not really want to go JCA route. Is there anything equivalent of org.apache.activemq.pool.PooledConnectionFactory in Artemis? I searched through

Re: Apache Artemis pooling

Appreciate prompt response. I have to implement pool for my requirement and will try to contribute it once I am done. Thanks -- View this message in context: http://activemq.2283324.n4.nabble.com/Apache-Artemis-pooling-tp4707663p4707675.html Sent from the ActiveMQ - User mailing list archive

Artemis Connection retry during initial connection

Hi, I am trying to test initial connection factory retry attempts if connection is unsuccessful. To try this I purposefully did not enable SSL where as my server is setup for TLS communication. Please find below my code ActiveMQConnectionFactory cf =

Re: Artemis Connection retry during initial connection

Thanks. It did not really work and I think it is because connection itself is successful but it cannot go any further because of SSL. I think it is bug and will see if I can file report with example. I got around it by setting call timeout. Below settings stops trying to connect after 1 second

Artemis DLQ strategy

Hi, I am trying to setup address-setting in my broker.xml to automatically create a DLQ for each queue created. I am creating queues using client and would like to have one DLQ for each queue created. Looking for similar stuff like "individualDeadLetterStrategy" given on below link

Artemis JMX not showing queues

Hi, I am trying out artemis and creating different JMS queues from client programatically. Code itself works, but when I log into JMX, I see that few queues are listed under "Core/Queue" with jms.queue.# prefix, but they don't appear under "JMS/Queue". I don't understand how this could happen.

Artemis create topic programatically

Hi, I am trying to create topic programatically. Please find below my code @Test public void testCreateTopic() throws Exception { ConnectionFactory cf = ActiveMQJMSClient.createConnectionFactoryWithHA(JMSFactoryType.CF, server1, server2); Connection conn =

Re: Artemis JMX not showing queues

First I am creating a connection factory using ActiveMQConnectionFactory cf = ActiveMQJMSClient.createConnectionFactoryWithHA(JMSFactoryType.CF, server1, server2); Then I am creating client representation of queue Queue queue = ActiveMQJMSClient.createQueue("x"); after that Connection

Artemis failover on initial connection

Hi, I have a HA cluster with one master and one slave. I am creating connection factory with below settings. HashMap map = new HashMap(); map.put("host", "artemis01-mydev"); map.put("port", "61616");

Artemis - Duplicate message detected - message will not be routed.

Hi, I am trying to run transaction failover test which is present below on my local server cluster https://github.com/apache/activemq-artemis/blob/master/examples/features/ha/transaction-failover/src/main/java/org/apache/activemq/artemis/jms/example/TransactionFailoverExample.java As I read

[Artemis] Issue with static connectors

Hi, We have a setup Artemis broker sits behind SSL offloading hardware. client ---TLS---> VIP(ssl-offload) ---TCP--> Artemis broker We have a HA setup with one master and one broker. I have followed the examples and add two TransportConfigurations one for each. ActiveMQConnectionFactory

Artemis slave goes down after master comes back up

Hi, I am seeing a behavior in Artemis HA which I can't really explain why. I ran the example successfully provided here: https://github.com/apache/activemq-artemis/tree/master/examples/features/ha/replicated-failback-static Then bought up both master and slave manually which are present

[Artemis] Error message in log file for cluster on v1.3

Hi, We have a master/slave configuration with static connectors. This was working fine till we upgraded to v1.3 yesterday. With 1.3 we are constantly seeing below ERROR message being logged. 21:12:59,991 ERROR [org.apache.activemq.artemis.core.client] AMQ214016: Failed to create netty

Re: Artems: ParallelGC vs CMS

Yes, we tested with G1 settings in load test environment. Old gen was still increasing with it albeit a bit slower than parallel GC, so we never moved ahead with it. -- View this message in context: http://activemq.2283324.n4.nabble.com/Artems-ParallelGC-vs-CMS-tp4721722p4721737.html Sent from

Artems: ParallelGC vs CMS

Hi, Has there any test done for Artemis using CMS GC? Context: We were using default parallel GC with 6G RAM and were facing an issue where old gen was filling up without full GC being run. We use Netty Transport configuration and have one master/slave setup with static configuration. Our

Re: [Artemis] Error message in log file for cluster on v1.3

We are still facing this issue. Anyone know why this is happening? -- View this message in context: http://activemq.2283324.n4.nabble.com/Artemis-Error-message-in-log-file-for-cluster-on-v1-3-tp4713397p4716576.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

[Artemis] Messages stuck in "Delivering" state infinitely

Hi, We found that few messages were not getting delivered by Artemis. When we ran count-messages using JMX it was returning correct number of messages on queue. But listMessages was returning empty. Then listDeliveringMessages showed all the messages. But messages were stuck in this state

Re: [Artemis] Messages stuck in "Delivering" state infinitely

Yes, we did see few dangling connections and I got the connection id's for the same. Right now there is no JMX operation to close single connection based on connectionId. The only way I could do this was to close all existing connections for the given user. -- View this message in context:

Re: [Artemis] Browse scheduled and delivering messages

Thanks, our requirement is not really performance intensive. It's only done on critical issues which needs immediate support. On another note, what is the best way to read messages with body? listMessages() operation does not retrieve body contents. ~Abhi -- View this message in context:

Re: [Artemis] Browse scheduled and delivering messages

I am assuming you are referring to JMSBrowser. We have locked down Queues and Topics with authentication and authorization. We would have to create a management role just for browsing which I am trying to avoid. Also, this user would be super user who could essentially read from everywhere.

[Artemis] Browse scheduled and delivering messages

Hi, We are trying to monitor Artemis queues for support purpose and one of our requirement is to be able to look at messages body. I found that I can view body of the message using browse() operation which is exposed via JMX. But browse only accounts for messages which are not in scheduled or

[Artemis] Split broker.xml

Hi, Is there anyway to split broker.xml file into smaller configuration? Our list of JMS objects are growing and broker.xml is getting bigger and bigger. We would like to have small set of files, preferably one xml file for each JMS object. Can I include multiple server configuration(s) in

[Artemis] WebConsole (Hawt.io artemis plugin)

Hi, I know there was a big discussion about adding webconsole to Artemis. I am not sure if any conclusion was reached on that. It is a huge benefit for our production support. So, would very much like to see that feature getting added in future releases. For now I was trying to play around

Artemis 1.x support model

Congrats everyone on successful release. We are using Artemis v1.4 today and would like to know support model for 1.x version after major version update. Is there any plan to deprecate 1.x version in near future and not accept any more bug submission? We are trying to determine when to

Re: [Artemis] [Bug] Consume from non-durable jms topic

Good to know. Thanks. Appreciate the help -- View this message in context: http://activemq.2283324.n4.nabble.com/Artemis-Bug-Consume-from-non-durable-jms-topic-tp4724597p4724667.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

[Artemis] [Bug] Consume from non-durable jms topic

Hi, We are using Artemis 1.4.0 version and have a jms topic defined. We have defined two specific roles for all topics, one to send and another to consume artemis-roles.properties: sendtopic=testtopicuser consumetopic=testtopicuser broker.xml: When I try to send to this

Re: [Artemis] [Bug] Consume from non-durable jms topic

Thanks for the reply and thats interesting. Does this mean, in order to listen to a topic you would always need 2 roles? createNonDurableQueue and consume? Trying to understand difference with Queue. We don't need to have createDurableQueue role to consume from a queue..right? -- View this

Re: [Artemis] [Bug] Consume from non-durable jms topic

Looking to move to 2.0 directly. Are there any pitfalls which we need to be aware of? Hoping 1.4 JMS client is fully compatible with 2.0 broker. -- View this message in context: http://activemq.2283324.n4.nabble.com/Artemis-Bug-Consume-from-non-durable-jms-topic-tp4724597p4724745.html Sent

Re: [Artemis] Error message in log file for cluster on v1.3

Resurrecting this thread as we are still facing this issue in v2.1. Any suggestions on how to take it out? There is no issue is performance or message delivery except filling up of logs. Its very annoying and makes debugging almost impossible. -- View this message in context:

Re: [Artemis] Error message in log file for cluster on v1.3

Yep will do that. Will it be fine If I give a docker compose file based on https://github.com/vromero/activemq-artemis-docker? I need to bring up couple of nginx load balancers with ssl offloading as well. I will set it up with self signed certs -- View this message in context:

Re: [Artemis] Error message in log file for cluster on v1.3

I can check if by directly setting SSL example with static connectors. This error message is appearing only when cluster is setup with TLS. -- View this message in context: http://activemq.2283324.n4.nabble.com/Artemis-Error-message-in-log-file-for-cluster-on-v1-3-tp4713397p4728619.html Sent

Re: Artemis v2.1 Spring MessageListener Netty StackOverflow

https://github.com/netty/netty/issues/6931 -- View this message in context: http://activemq.2283324.n4.nabble.com/Artemis-v2-1-Spring-MessageListener-Netty-StackOverflow-tp4728139p4728291.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis v2.1 Spring MessageListener Netty StackOverflow

We have a load balancer in front on Artemis which does ssl offloading. To handle this we have custom ConnectionLoadBalancingPolicy. This policy determines which transport configuration to use for initial connection -- View this message in context:

Re: Artemis v2.1 Spring MessageListener Netty StackOverflow

Please find above stacktrace. I will try to get test case for this, but it is not repeatable on my Mac. I can get this only on Solaris. Will see if I can repeat it consistently. -- View this message in context:

Artemis v2.1 Spring MessageListener Netty StackOverflow

Hi all, We are facing a weird issue while using Spring DefaultMessageListenerContainer with Artemis v2.1 client. We have below piece of code on our custom policy which is run on a Solaris box. try (ServerLocatorImpl serverLocator = new ServerLocatorImpl(false, transportConfiguration)) {

Re: Artemis v2.1 Spring MessageListener Netty StackOverflow

Exception in thread "main" org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'messageListenerContainer' defined in c.p.c.MySpringConfiguration: Invocation of init method failed; nested exception is java.lang.StackOverflowError at

Re: Artemis v2.1 Spring MessageListener Netty StackOverflow

Thanks Justin...appreciate your quick help on this. Looks like v4.1.4.final is working. Will run some more tests and confirm next week. It is netty issue and I will raise a bug for them. But, since Artemis is really dependent on this, should Artemis have netty 4.1.4.final dependency instead of

Re: Artemis v2.1 Spring MessageListener Netty StackOverflow

https://github.com/netty/netty/issues/6931 -- Opened an issue in Netty backlog -- View this message in context: http://activemq.2283324.n4.nabble.com/Artemis-v2-1-Spring-MessageListener-Netty-StackOverflow-tp4728139p4728150.html Sent from the ActiveMQ - User mailing list archive at

Re: Artemis v2.1 Spring MessageListener Netty StackOverflow

To close this loop, Netty guys suggested to increase stack size(Xss) instead of downgrading version. Bumping stack size from 256K to 1024K worked and we don't see the error anymore. Thanks everyone for quick help -- View this message in context:

Re: Artemis v2.0 JDK8 dependency

Thanks for the clarification. I will use CLI tool. Question: Can I use anycast prefix to still have 'jms.queue' appended? We have built some conventions around this prefix and checking if we have change it. -- View this message in context:

Re: Artemis v2.0 JDK8 dependency

You have downgrade dependencies to be JDK7 compatible. You could just include http://www.mojohaus.org/extra-enforcer-rules/enforceBytecodeVersion.html and it will flag any issues including dependencies. -- View this message in context:

Re: Artemis v2.0 JDK8 dependency

sorry, any suggestion here? -- View this message in context: http://activemq.2283324.n4.nabble.com/Artemis-v2-0-JDK8-dependency-tp4725798p4725888.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis v2.0 JDK8 dependency

Thanks for the info. Our broker itself is running on Jdk8, so that is not a problem. Its the client I am concerned about. We have a mixture of Jdk7 and jdk8 clients(publishers and consumers). So, we would like to give them an option to use either and upgrade to jdk8 at their convenient time.

Re: Artemis v2.0 JDK8 dependency

Thanks for the clarification. Since we are talking about upgrade had one more question. Is defining JMS queues using tag in broker.xml not valid anymore in Artemis v2.0? I looked at JMS examples and it has been moved to new model. But I could still see bunch of references of it under

Re: Artemis v2.0 JDK8 dependency

Another note which is on v1.5.4. This version also suffers from same bytecode compatibility issues. [INFO] --- maven-enforcer-plugin:1.4.1:enforce (enforce) @ credit-artemis-client --- [INFO] Restricted to JDK 1.7 yet org.apache.activemq:artemis-journal:jar:1.5.4:test contains

Re: Artemis v2.0 JDK8 dependency

below are the files ➜ activemq-artemis git:(master) grep -rnw . -e "" ./artemis-cli/src/test/resources/broker-reload.xml:25: ./artemis-cli/src/test/resources/broker.xml:25: ./artemis-features/src/main/resources/artemis.xml:28:

Re: Artemis 2.0 upgrade Shared datastore

Thanks for the info. I am assuming you are referring to `data` option present on server/bin/artemis and not distribution. Please let me know if both are same. Another question on migration, Will 1.4 clients work with 2.0 or they have to migrate. I was hoping they can continue to work with 1.4

Artemis 2.0 upgrade Shared datastore

Hi, We have a shared datastore setup and are currently running v1.4. We are planning to upgrade to v2.1 with the same configuration. One of the question which came up was if datastore itself compatible with 2 major versions? If we have to rollback v2.1 for some reason will it work seamlessly

Artemis 2.0 Security settings

Hi, With 1.x we had configured security settings and topic like below

Apache Artemis CLI migrate1x

I am trying to see if I can use migrate1x command on CLI. But when I run help I do not see that command listed on the cli. Is there any documentation I can take a look? Please let me know if I am missing something here. $ server-master/bin/artemis help usage: artemis [] The most commonly

Re: Artemis 2.0 Security settings

Yes, removing prefix is one option. My queries are 1. Shouldn't migrate cover moving security setting and diverts? 2. Is anycastPrefix and multicastPrefix working correctly? On another post Justin had confirmed that adding them should resolve other things 3. Why does random address is printed

Re: Artemis v2.1 divert

Thanks Justin. flag was the reason for store filling up. We were thinking address itself is storing messages, but it was DLQ. Thanks for the help -- View this message in context: http://activemq.2283324.n4.nabble.com/Artemis-v2-1-divert-tp4727498p4727759.html Sent from the ActiveMQ - User

Question on Artemis Shared store static config cluster

Hi, I observed a behavior which was odd and would like to check if I am missing something. We have two node static configuration cluster. One is master and another one is slave with shared store. master true

Re: Artemis Address Message Count

Thanks for the information Justin. I am counting numbers on all the diverts now and will continue with that. -- View this message in context: http://activemq.2283324.n4.nabble.com/Artemis-Address-Message-Count-tp4727127p4727162.html Sent from the ActiveMQ - User mailing list archive at

Re: Artemis Address Message Count

Thanks Justin. But IMHO it is misleading behavior..right? As publisher I would like to get count of no of messages sent to an address. Publisher won't worry about how many queues or diverts are associated to an address. Right now if queues are not associated with an address, there is no way

Artemis Address Message Count

Hi, We are monitoring Artemis via JMX. We have a topic(address with multicast) which has a divert to a queue. If I send messages to this address messages gets diverted correctly to queue. But if I query address mbean both messageCount and noOfMessages is 0. Is this expected? I think

Artemis v2.1 divert

Hi We are having a topic on which a divert is configured. Every message sent to topic has to be diverted to queue. Divert: jms.topic.testtopic01 jms.queue.testqueue01 false Address: DLQ jms.queue.DLQ

Artemis v2.0 JDK8 dependency

Hi, Is there a hard dependency for Artemis v2.0 to be on Jdk8? I am trying to upgrade a client which is built on jdk7, but enforcer plugin is showing bunch of non-compatibility issues. [INFO] --- maven-enforcer-plugin:1.4.1:enforce (enforce) @ my-artemis-client --- [INFO] Restricted to JDK 1.7