Loading...

Type: Bug
Resolution: Done
Priority: Major
Fix Version/s: AMQ 7.2.2.GA
Affects Version/s: AMQ 7.2.0.GA
Component/s: broker-core
Labels:
None

Affects:

Release Notes
GSS Priority:
Release Note Text:

Hide
In previous releases, multiple threads could concurrently modify a message's properties. This resulted in WARN messages in the log when TRACE-level logging was enabled. Now, concurrent access to message properties is done safely and the WARN messages in the log related to this issue no longer occur.

Show
In previous releases, multiple threads could concurrently modify a message's properties. This resulted in WARN messages in the log when TRACE-level logging was enabled. Now, concurrent access to message properties is done safely and the WARN messages in the log related to this issue no longer occur.
Release Note Status:
Documented as Resolved Issue
Target Release:

AMQ 7.2.2.GA
Upstream Jira:
https://issues.apache.org/jira/browse/ARTEMIS-2095

Sprint:
AMQ Broker 1839

SFDC Cases Counter:
SFDC Cases Open:
SFDC Cases Links:

Enabling TRACE-level logging in the broker leads periodically to the following exception being thrown, and messaging operations fail. It is therefore impossible to collect diagnostics at this level in a production environment.

2018-09-20 11:23:52,493 WARN  [org.apache.activemq.artemis.core.message.impl.CoreMessage] Error creating String for message: : java.util.ConcurrentModificationException
	at java.util.HashMap$HashIterator.nextNode(HashMap.java:1437) [rt.jar:1.8.0_102]
	at java.util.HashMap$EntryIterator.next(HashMap.java:1471) [rt.jar:1.8.0_102]
	at java.util.HashMap$EntryIterator.next(HashMap.java:1469) [rt.jar:1.8.0_102]
	at org.apache.activemq.artemis.utils.collections.TypedProperties.toString(TypedProperties.java:464) [artemis-commons-2.6.1.amq-720008.jar:2.6.1.amq-720008]
	at java.lang.String.valueOf(String.java:2994) [rt.jar:1.8.0_102]
	at java.lang.StringBuilder.append(StringBuilder.java:131) [rt.jar:1.8.0_102]
	at org.apache.activemq.artemis.core.message.impl.CoreMessage.toString(CoreMessage.java:1200) [artemis-core-client-2.6.1.amq-720008.jar:2.6.1.amq-720008]
	at java.lang.String.valueOf(String.java:2994) [rt.jar:1.8.0_102]
	at java.lang.StringBuilder.append(StringBuilder.java:131) [rt.jar:1.8.0_102]
	at org.apache.activemq.artemis.core.protocol.core.impl.wireformat.MessagePacket.getParentString(MessagePacket.java:39) [artemis-core-client-2.6.1.amq-720008.jar:2.6.1.amq-720008]
	at org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionReceiveMessage.toString(SessionReceiveMessage.java:95) [artemis-core-client-2.6.1.amq-720008.jar:2.6.1.amq-720008]
	at java.lang.String.valueOf(String.java:2994) [rt.jar:1.8.0_102]
	at java.lang.StringBuilder.append(StringBuilder.java:131) [rt.jar:1.8.0_102]
	at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.send(ChannelImpl.java:274) [artemis-core-client-2.6.1.amq-720008.jar:2.6.1.amq-720008]
	at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBatched(ChannelImpl.java:239) [artemis-core-client-2.6.1.amq-720008.jar:2.6.1.amq-720008]
	at org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback.sendMessage(CoreSessionCallback.java:128) [artemis-server-2.6.1.amq-720008.jar:2.6.1.amq-720008]
	at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1106) [artemis-server-2.6.1.amq-720008.jar:2.6.1.amq-720008]
	at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:464) [artemis-server-2.6.1.amq-720008.jar:2.6.1.amq-720008]
	at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2938) [artemis-server-2.6.1.amq-720008.jar:2.6.1.amq-720008]
	at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2406) [artemis-server-2.6.1.amq-720008.jar:2.6.1.amq-720008]
	at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$2000(QueueImpl.java:107) [artemis-server-2.6.1.amq-720008.jar:2.6.1.amq-720008]
	at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:3211) [artemis-server-2.6.1.amq-720008.jar:2.6.1.amq-720008]
	at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [artemis-commons-2.6.1.amq-720008.jar:2.6.1.amq-720008]
	at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [artemis-commons-2.6.1.amq-720008.jar:2.6.1.amq-720008]
	at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:66) [artemis-commons-2.6.1.amq-720008.jar:2.6.1.amq-720008]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [rt.jar:1.8.0_102]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [rt.jar:1.8.0_102]
	at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.6.1.amq-720008.jar:2.6.1.amq-720008]

- - Sort By Name
  - Sort By Date
  - Ascending
  - Descending
  - Thumbnails
  - List
  - Download All

TypedPropertiesConcurrencyTest.java
6 kB
2018/09/25 4:35 AM

causes

ENTMQBR-2011 Consumer of store-forward internal queues get dropped when syncing large messages

Closed

is duplicated by

ENTMQBR-2461 HQPropertiesConverter class throws a java.util.ConcurrentModificationException while processing message headers

Closed

Details

Description

Attachments

Attachments

Issue Links

Activity

People

Dates