You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Marko Kohtala (JIRA)" <ji...@apache.org> on 2019/08/06 12:52:00 UTC
[jira] [Created] (ARTEMIS-2446) AMQP message transmission with UUID
properties fails
Marko Kohtala created ARTEMIS-2446:
--------------------------------------
Summary: AMQP message transmission with UUID properties fails
Key: ARTEMIS-2446
URL: https://issues.apache.org/jira/browse/ARTEMIS-2446
Project: ActiveMQ Artemis
Issue Type: Bug
Components: AMQP
Affects Versions: 2.9.0
Environment: I run the broker in a Docker container created based on [https://github.com/vromero/activemq-artemis-docker.] It is based on openjdk:8u222-jdk-stretch image. I've removed the etc and etc-override volumes, removed the excess protocol jars, added guest login.
Reporter: Marko Kohtala
I have an application using AMQP messaging and it works with ActiveMQ Artemis for small messages, but is failing for larger messages with error:
{noformat}
2019-08-06T06:47:01.793175725Z Calculating performance journal ...
2019-08-06T06:47:22.324883428Z 144000
2019-08-06T06:47:33.378573751Z _ _ _
2019-08-06T06:47:33.378610153Z / \ ____| |_ ___ __ __(_) _____
2019-08-06T06:47:33.378622654Z / _ \| _ \ __|/ _ \ \/ | |/ __/
2019-08-06T06:47:33.378634254Z / ___ \ | \/ |_/ __/ |\/| | |\___ \
2019-08-06T06:47:33.378645955Z /_/ \_\| \__\____|_| |_|_|/___ /
2019-08-06T06:47:33.378657155Z Apache ActiveMQ Artemis 2.9.0
2019-08-06T06:47:33.378668156Z
2019-08-06T06:47:33.378679156Z
2019-08-06T06:47:37.544726699Z 2019-08-06 06:47:37,477 INFO [org.apache.activemq.artemis.integration.bootstrap] AMQ101000: Starting ActiveMQ Artemis Server
2019-08-06T06:47:38.565550895Z 2019-08-06 06:47:38,564 INFO [org.apache.activemq.artemis.core.server] AMQ221000: live Message Broker is starting with configuration Broker Configuration (clustered=false,journalDirectory=data/journal,bindingsDirectory=data/bindings,largeMessagesDirectory=data/large-messages,pagingDirectory=data/paging)
2019-08-06T06:47:38.742539672Z 2019-08-06 06:47:38,738 INFO [org.apache.activemq.artemis.core.server] AMQ221012: Using AIO Journal
2019-08-06T06:47:39.048523728Z 2019-08-06 06:47:39,043 INFO [org.apache.activemq.artemis.core.server] AMQ221057: Global Max Size is being adjusted to 1/2 of the JVM max size (-Xmx). being defined as 3,099,590,656
2019-08-06T06:47:39.281507988Z 2019-08-06 06:47:39,278 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-server]. Adding protocol support for: CORE
2019-08-06T06:47:39.281536789Z 2019-08-06 06:47:39,279 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-amqp-protocol]. Adding protocol support for: AMQP
2019-08-06T06:47:40.433221253Z 2019-08-06 06:47:40,426 INFO [org.apache.activemq.artemis.core.server] AMQ221034: Waiting indefinitely to obtain live lock
2019-08-06T06:47:40.433255155Z 2019-08-06 06:47:40,427 INFO [org.apache.activemq.artemis.core.server] AMQ221035: Live Server Obtained live lock
2019-08-06T06:47:40.927969551Z 2019-08-06 06:47:40,925 INFO [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address DLQ supporting [ANYCAST]
2019-08-06T06:47:41.038512746Z 2019-08-06 06:47:41,035 INFO [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue DLQ on address DLQ
2019-08-06T06:47:41.822560701Z 2019-08-06 06:47:41,814 INFO [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address ExpiryQueue supporting [ANYCAST]
2019-08-06T06:47:41.831706739Z 2019-08-06 06:47:41,830 INFO [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue ExpiryQueue on address ExpiryQueue
2019-08-06T06:47:41.857242562Z 2019-08-06 06:47:41,850 INFO [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address /exchange/amq.fanout/analysis supporting [MULTICAST]
2019-08-06T06:47:41.876622291Z 2019-08-06 06:47:41,875 INFO [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address /topic/heartbeat supporting [MULTICAST]
2019-08-06T06:47:43.249534752Z 2019-08-06 06:47:43,242 INFO [org.apache.activemq.artemis.core.server] AMQ221020: Started EPOLL Acceptor at 0.0.0.0:5672 for protocols [AMQP]
2019-08-06T06:47:43.274616353Z 2019-08-06 06:47:43,267 INFO [org.apache.activemq.artemis.core.server] AMQ221007: Server is now live
2019-08-06T06:47:43.274655755Z 2019-08-06 06:47:43,267 INFO [org.apache.activemq.artemis.core.server] AMQ221001: Apache ActiveMQ Artemis Message Broker version 2.9.0 [ae09008555df, nodeID=147edb1d-b816-11e9-a90c-02420ae0020c]
2019-08-06T06:47:47.820575804Z 2019-08-06 06:47:47,816 INFO [org.apache.activemq.hawtio.branding.PluginContextListener] Initialized activemq-branding plugin
2019-08-06T06:47:48.735664537Z 2019-08-06 06:47:48,685 INFO [org.apache.activemq.hawtio.plugin.PluginContextListener] Initialized artemis-plugin plugin
2019-08-06T06:47:52.505572720Z 2019-08-06 06:47:52,453 INFO [io.hawt.HawtioContextListener] Initialising hawtio services
2019-08-06T06:47:52.660606946Z 2019-08-06 06:47:52,660 INFO [io.hawt.system.ConfigManager] Configuration will be discovered via system properties
2019-08-06T06:47:52.682554698Z 2019-08-06 06:47:52,681 INFO [io.hawt.jmx.JmxTreeWatcher] Welcome to hawtio 1.5.5 : http://hawt.io/ : Don't cha wish your console was hawt like me? ;-)
2019-08-06T06:47:52.706528646Z 2019-08-06 06:47:52,701 INFO [io.hawt.jmx.UploadManager] Using file upload directory: /var/lib/artemis/tmp/uploads
2019-08-06T06:47:52.886588371Z 2019-08-06 06:47:52,885 INFO [io.hawt.web.AuthenticationFilter] Starting hawtio authentication filter, JAAS realm: "activemq" authorized role(s): "amq" role principal classes: "org.apache.activemq.artemis.spi.core.security.jaas.RolePrincipal"
2019-08-06T06:47:53.130576058Z 2019-08-06 06:47:53,128 INFO [io.hawt.web.JolokiaConfiguredAgentServlet] Jolokia overridden property: [key=policyLocation, value=file:/var/lib/artemis/etc/jolokia-access.xml]
2019-08-06T06:47:53.247602164Z 2019-08-06 06:47:53,237 INFO [io.hawt.web.RBACMBeanInvoker] Using MBean [hawtio:type=security,area=jmx,rank=0,name=HawtioDummyJMXSecurity] for role based access control
2019-08-06T06:47:54.733611447Z 2019-08-06 06:47:54,732 INFO [io.hawt.system.ProxyWhitelist] Initial proxy whitelist: [localhost, 127.0.0.1, 10.224.2.12, ae09008555df]
2019-08-06T06:47:55.819600768Z 2019-08-06 06:47:55,818 INFO [org.apache.activemq.artemis] AMQ241001: HTTP Server started at http://0.0.0.0:8161
2019-08-06T06:47:55.819647370Z 2019-08-06 06:47:55,818 INFO [org.apache.activemq.artemis] AMQ241002: Artemis Jolokia REST API available at http://0.0.0.0:8161/console/jolokia
2019-08-06T06:47:55.819661171Z 2019-08-06 06:47:55,819 INFO [org.apache.activemq.artemis] AMQ241004: Artemis Console available at http://0.0.0.0:8161/console
2019-08-06T06:49:43.223569212Z 2019-08-06 06:49:43,190 WARN [org.apache.activemq.artemis.protocol.amqp.proton.ProtonServerReceiverContext] class java.util.UUID is not a valid property type: java.lang.RuntimeException: class java.util.UUID is not a valid property type
2019-08-06T06:49:43.223597713Z at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.toCore(AMQPMessage.java:695) [artemis-amqp-protocol-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223611514Z at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.toCore(AMQPMessage.java:701) [artemis-amqp-protocol-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223623515Z at org.apache.activemq.artemis.core.persistence.impl.journal.LargeServerMessageImpl.asLargeMessage(LargeServerMessageImpl.java:63) [artemis-server-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223643615Z at org.apache.activemq.artemis.core.persistence.impl.journal.LargeServerMessageImpl.checkLargeMessage(LargeServerMessageImpl.java:56) [artemis-server-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223656216Z at org.apache.activemq.artemis.core.server.impl.ServerSessionImpl.send(ServerSessionImpl.java:1631) [artemis-server-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223667717Z at org.apache.activemq.artemis.protocol.amqp.broker.AMQPSessionCallback.serverSend(AMQPSessionCallback.java:510) [artemis-amqp-protocol-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223679017Z at org.apache.activemq.artemis.protocol.amqp.broker.AMQPSessionCallback.serverSend(AMQPSessionCallback.java:470) [artemis-amqp-protocol-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223690518Z at org.apache.activemq.artemis.protocol.amqp.proton.ProtonServerReceiverContext.actualDelivery(ProtonServerReceiverContext.java:304) [artemis-amqp-protocol-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223702218Z at org.apache.activemq.artemis.protocol.amqp.proton.ProtonServerReceiverContext.onMessage(ProtonServerReceiverContext.java:299) [artemis-amqp-protocol-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223713819Z at org.apache.activemq.artemis.protocol.amqp.proton.AMQPConnectionContext.onDelivery(AMQPConnectionContext.java:541) [artemis-amqp-protocol-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223725619Z at org.apache.activemq.artemis.protocol.amqp.proton.handler.Events.dispatch(Events.java:92) [artemis-amqp-protocol-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223738920Z at org.apache.activemq.artemis.protocol.amqp.proton.handler.ProtonHandler.dispatch(ProtonHandler.java:485) [artemis-amqp-protocol-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223751021Z at org.apache.activemq.artemis.protocol.amqp.proton.handler.ProtonHandler.flush(ProtonHandler.java:285) [artemis-amqp-protocol-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223762421Z at org.apache.activemq.artemis.protocol.amqp.proton.handler.ProtonHandler.inputBuffer(ProtonHandler.java:242) [artemis-amqp-protocol-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223773722Z at org.apache.activemq.artemis.protocol.amqp.proton.AMQPConnectionContext.inputBuffer(AMQPConnectionContext.java:170) [artemis-amqp-protocol-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223785422Z at org.apache.activemq.artemis.protocol.amqp.broker.ActiveMQProtonRemotingConnection.bufferReceived(ActiveMQProtonRemotingConnection.java:149) [artemis-amqp-protocol-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223797023Z at org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:649) [artemis-server-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223808723Z at org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:73) [artemis-core-client-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.223820324Z at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) [netty-all-4.1.34.Final.jar:4.1.34.Final]
2019-08-06T06:49:43.223831924Z at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:345) [netty-all-4.1.34.Final.jar:4.1.34.Final]
2019-08-06T06:49:43.223848725Z at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:337) [netty-all-4.1.34.Final.jar:4.1.34.Final]
2019-08-06T06:49:43.223882727Z at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1408) [netty-all-4.1.34.Final.jar:4.1.34.Final]
2019-08-06T06:49:43.223899028Z at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) [netty-all-4.1.34.Final.jar:4.1.34.Final]
2019-08-06T06:49:43.223910728Z at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:345) [netty-all-4.1.34.Final.jar:4.1.34.Final]
2019-08-06T06:49:43.223922529Z at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:930) [netty-all-4.1.34.Final.jar:4.1.34.Final]
2019-08-06T06:49:43.223936029Z at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:796) [netty-all-4.1.34.Final.jar:4.1.34.Final]
2019-08-06T06:49:43.223948330Z at io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe$1.run(AbstractEpollChannel.java:382) [netty-all-4.1.34.Final.jar:4.1.34.Final]
2019-08-06T06:49:43.223959931Z at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163) [netty-all-4.1.34.Final.jar:4.1.34.Final]
2019-08-06T06:49:43.223971531Z at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404) [netty-all-4.1.34.Final.jar:4.1.34.Final]
2019-08-06T06:49:43.223982932Z at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:333) [netty-all-4.1.34.Final.jar:4.1.34.Final]
2019-08-06T06:49:43.223994632Z at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:905) [netty-all-4.1.34.Final.jar:4.1.34.Final]
2019-08-06T06:49:43.224006533Z at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [artemis-commons-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.224018233Z Caused by: javax.jms.MessageFormatException: class java.util.UUID is not a valid property type
2019-08-06T06:49:43.224030134Z at org.apache.activemq.artemis.protocol.amqp.converter.jms.ServerJMSMapMessage.setObject(ServerJMSMapMessage.java:140) [artemis-amqp-protocol-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.224041935Z at org.apache.activemq.artemis.protocol.amqp.converter.AMQPMessageSupport.createMapMessage(AMQPMessageSupport.java:363) [artemis-amqp-protocol-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.224053535Z at org.apache.activemq.artemis.protocol.amqp.converter.AmqpCoreConverter.toCore(AmqpCoreConverter.java:184) [artemis-amqp-protocol-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.224065136Z at org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage.toCore(AMQPMessage.java:692) [artemis-amqp-protocol-2.9.0.jar:2.9.0]
2019-08-06T06:49:43.224076736Z ... 31 more
2019-08-06T06:49:43.224087837Z
{noformat}
The message structure is as follows (this is a smaller message as decoded by Wireshark, and I have removed some redundant and private elements from body to only show all the AMQP types used, but larger messages differ in a body vbin8 content).
{noformat}
Internet Protocol Version 4, Src: 172.18.0.8, Dst: 172.18.0.2
Transmission Control Protocol, Src Port: 56776, Dst Port: 5672, Seq: 3932659, Ack: 629, Len: 349
Advanced Message Queueing Protocol
Length: 349
Doff: 2
Type: AMQP (0)
Channel: 0
Performative: transfer (20)
Arguments
Handle: 1
Delivery-Id: 2
Delivery-Tag: 32
Message-Format: 0
Settled: False
More: False
Message-Header
Message-Properties
Correlation-Id: 8e944ee0-b841-11e9-9356-c7125349b5ec
AMQP-Value (map of 10 elements)
position (uuid): cd9d2fa0-b817-11e9-b2e1-1fd86d72a1ef
tags (list of 0 elements)
dtags (map of 0 elements)
filename (str8-utf8): 1x1.png
picture (vbin8): 89504e470d0a1a0a0000000d494844520000000100000001...
content-type (str8-utf8): image/png
date-taken (timestamp): Oct 16, 2018 16:48:36.000000000
{noformat}
If I read the stack trace and source right, it is converting the body to JMS message for storing in large-message storage. This is somewhat unfortunate, as I have no JMS use for the message. I am all AMQP and would prefer nothing to be changed. UUID is very nice, as the AMQP libraries convert it to native types that work well towards other interfaces.
I've had plans to move some fields with UUID values from body to application properties header in hopes they could be used for routing and filtering. Seems if I do that there will be another path where similar limitation in supported types will hit the message.
I am interested if there is a workaround I can use while I wait for next version with support for remaining AMQP types.
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)