Re: ArtemisMQ equivalence of ActiveMQ prefetchSize STOMP header

Hi José, ActiveMQ Artemis doesn't support a property that specifies the maximum number of pending messages that will be dispatched to a STOMP client. However an acceptors supports the `stompConsumerCredits` property to specify the consumerWindowSize[1] for all STOMP clients connected to that

Re: Artemis: Reconfiguring a divert

Hi, I guess you don't want to leave the address without your divert for the time you need to invoke `destroyDivert` and `createDivert` again. If that's the case, you could execute the following steps: 1) create the new divert with a temporary name 2) destroy the old divert 3) create the new

Re: Auto create dead letter Resources - Server not starting

Hi, the element `auto-create-dead-letter-resources` has been introduced since Artemis 2.12 by ARTEMIS-2587 auto-create dead-letter resources[1][2]. [1] https://issues.apache.org/jira/browse/ARTEMIS-2587 [2]

Re: active mq password paramterisation

Hi, it’s possible to pass parameters via the system properties, ie: -Dactivemq.user.name="..." -Dactivemq.user.password="..." Regards, Domenico -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Artemis - audit logging and anonymous user

Hi Steve, the AuditLogger is often called in a context without a `Subject`[1] so it can't log the right username. To avoid this issue the username could be passed explicitly as suggested by Howard. Each AuditLogger entry has 2 methods and adding the `user` parameter to the static one would allow

Re: Artemis: Restricting access based on protocol

Hi Stan, the PR https://github.com/apache/activemq-artemis/pull/3058 is merged so it will be included in the 2.12.0 release. Regards, Domenico -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Artemis 2.11.0 - Cluster node OOM - Queue build up on internal $.artemis.internal.sf... queue

Hi Graham, the warnings `No Expiry Address configured for queue...` or `No Expiry Address configured for queue...` are often due to the lack of the default address-setting (address-setting match="#") or to the mismatch from `wildcard-addresses` node and the `address-settings` nodes (the

Re: Artemis: Restricting access based on protocol

Hi Justin and Stan, I found another bug, testing the the MqttConnectMessage rejection: https://issues.apache.org/jira/browse/ARTEMIS-2686 I created a PR to fix this bug: https://github.com/apache/activemq-artemis/pull/3058 Regards, Domenico -- Sent from:

Re: Artemis: Restricting access based on protocol

Hi Stan, Artemis supports interceptors[1] to intercept packets entering and exiting the server. This allows custom code to be executed, e.g. for auditing packets, filtering or other reasons. So you could use an MQTTInterceptor[2] to reject connection messages with admin username. An example of

Re: Artemis 2.11.0 - Cluster node OOM - Queue build up on internal $.artemis.internal.sf... queue

Hi Graham, can you enable the dumping of the java heap when a java.lang.OutOfMemoryError exception is thrown and send a screenshot or summary? To enable the heap dump, you could uncomment the following line in `artemis.profile` file: # JAVA_ARGS="$JAVA_ARGS -XX:+HeapDumpOnOutOfMemoryError

Re: Artemis: Downloading metadata only

Hi Jan, if I understood correctly your requirements you could use a non-exclusive divert[1] to copy all messages that are routed to the old address to the new address and a transformer class[2] to remove the messages body or properties before it is copied. [1]

Re: Artemis: Downloading metadata only

Hi Jan, there isn't a way to receive only the metadata of a message. It could be an enhancement, but I can't understand the purpose. Could you share more information about your context? What interface are you using to receive the messages? Do you want skip the message body on consuming or

Re: Artemis Rest missing msg-pull-consumers response header

Hi Phil, the `500 Server Error` looks like an issue related to RESTEasy. I used `resteasy-jaxrs-3.0.16.Final-all`[1] successfully. What version are you using? Anyway */another thing not related the error/*, I think you don't need the listener `ActiveMQBootstrapListener` in your web.xml. That

Re: Separate trust and key stores for each connector

Hi Jędrzej, Artemis allows separate key store and trust store for each netty acceptor[1] (in ActiveMQ terminology, they are called transport connectors [2][3]), ie: tcp://localhost:61617?sslEnabled=true=/keyStorePath1=/trustStorePath1

Re: ActiveMQ artemis listener not working

Hi, the JmsTemplate creates a new session for each message to send, according to its source[1]. So in the broker log you can find the lines relative the session creating and the message sending for each of the 5 messages sent by `sender.sendmessages`. [1]

Re: ActiveMQ artemis listener not working

Hi, there is an ActiveMQ Artemis Spring Boot Example at https://github.com/apache/activemq-artemis/tree/master/examples/features/standard/spring-boot-integration Regards, Domenico -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: activemq.xml - configuring SSL context

Hi Martin, what about using system properties: Regards, Domenico -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Delayed messages block queue

Hi areddy, which activemq version are you using? Can you share your redeliveryPolicy? Regards, Domenico -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Artemis 2.9.0 Deadlock

Hi, I can't reproduce this issue against Artemis 2.11.0 because this issue was already fixed by Clebert with ARTEMIS-2592. Before the fix, the QueueImpl.removeConsumer locks the queue until the deleting of auto-create queue. The deleting of a queue calls ManagementServiceImpl.unregisterQueue

Re: Artemis 2.9.0 Deadlock

Hi Clebert, I guess you mean `auto-delete-queues-delay`[1]. It can be used to set a timeout before removing auto-created queues. [1] https://activemq.apache.org/components/artemis/documentation/latest/address-model.html Regards, Domenico -- Sent from:

Re: Artemis 2.9.0 Deadlock

Hi ldebello, the deadlock is due to a collision from 2 threads on the same queue with the auto delete queue policy enabled: - the first thread is trying to add a redistributor to the queue for a new consumer. - the second thread is trying to delete the queue because it is empty and the last

Re: Is it possible to limit the storage in ActiveMQ ?

Hi, the System will perform scans on the disk to determine if the disk is beyond a configured limit. These are configured through `max-disk-usage` in percentage. Once that limit is reached any message will be blocked. (unless the protocol doesn't support flow control on which case there will be

Re: Artemis client failover behind virtual ip?

Hi, Can your client app connect to artemis001 or artemis002 with the same addresses used by their cluster connections? If not, a list of servers to be used for the initial connection attempt can be specified in the connection URI using a syntax with ( ) , e.g.:

Re: runtimeConfigurationPlugin causes ActiveMQ to fail to start on Windows

Hi kyro, I guess the error is due to OpenJDK 13.0.2. In the documentation [1] the JRE 1.7 is suggested but I got a successful execution with OpenJDK 8 too. [1] https://activemq.apache.org/getting-started#Pre-InstallationRequirements Regards, Domenico -- Sent from:

Re: REST Interface StdAlone VS Clustered

Hi Magnus, I guess some parts of your message has been lost: z94joma wrote > ... > Config for our working StdAlone: > > In broker.xml we added: > > In rest-messaging.xml > > In web.xml > > This works fine (when including below class) > ... Regards, Domenico -- Sent from:

Re: OutOfMemoryError in ActiveMQ

Hi, for memory usage, could be useful taking some screenshot of objects in the heap dump with VisualVM [1]: - screenshot/s of objects in the heap dump sorted by count; - screenshot/s of objects in the heap dump sorted by size; Thanks, Domenico [1] https://visualvm.github.io/ -- Sent from:

Re: Artemis server logging to Graylog

Hi Vlk, I have a working configuration using logstash-gelf-1.13.0 and prepending the jar in Xbootclasspath: -Xbootclasspath/a:"/home/dbruscin/Downloads/logstash-gelf-1.13.0.jar:$LOG_MANAGER:$WILDFLY_COMMON" I have added the following handler in logging.properties: