[
https://issues.apache.org/jira/browse/ARTEMIS-214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15257456#comment-15257456
]
ASF GitHub Bot commented on ARTEMIS-214:
----------------------------------------
Github user clebertsuconic commented on the pull request:
https://github.com/apache/activemq-artemis/pull/482#issuecomment-214591080
@gaohoward the test you added doesn't work:
I get lots of exceptions:
```
java.lang.IllegalArgumentException: Unknown Destination Type passed to JMS
Transformer.
at
org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer.destinationType(JMSMappingOutboundTransformer.java:322)
at
org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer.convert(JMSMappingOutboundTransformer.java:193)
at
org.apache.activemq.artemis.core.protocol.proton.converter.ProtonMessageConverter.outbound(ProtonMessageConverter.java:105)
at
org.apache.activemq.artemis.core.protocol.proton.plug.ProtonSessionIntegrationCallback.encodeMessage(ProtonSessionIntegrationCallback.java:214)
at
org.proton.plug.context.server.ProtonServerSenderContext.deliverMessage(ProtonServerSenderContext.java:270)
at
org.apache.activemq.artemis.core.protocol.proton.plug.ProtonSessionIntegrationCallback.sendMessage(ProtonSessionIntegrationCallback.java:363)
at
org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1027)
at
org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:417)
at
org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2463)
at
org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:1955)
at
org.apache.activemq.artemis.core.server.impl.QueueImpl.access$1400(QueueImpl.java:98)
at
org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2694)
at
org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$ExecutorTask.run(OrderedExecutorFactory.java:100)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
22:43:02,734 WARN [org.apache.activemq.artemis.core.server] AMQ222151:
removing consumer which did not handle a message, consumer=ServerConsumerImpl
[id=0, filter=null, binding=LocalQueueBinding [address=jms.queue.exampleQueue,
queue=QueueImpl[name=jms.queue.exampleQueue, postOffice=PostOfficeImpl
[server=ActiveMQServerImpl::serverUUID=971a280e-0b58-11e6-999f-426c8fd39000]]@35137fbc,
filter=null, name=jms.queue.exampleQueue,
clusterName=jms.queue.exampleQueue971a280e-0b58-11e6-999f-426c8fd39000]],
message=Reference[5]:RELIABLE:ServerMessage[messageID=5,durable=true,userID=null,priority=4,
bodySize=32768, timestamp=Mon Apr 25 22:43:02 EDT 2016,expiration=0,
durable=true,
address=jms.queue.exampleQueue,properties=TypedProperties[JMS_AMQP_NATIVE=false,JMS_AMQP_MA_x-opt-jms-dest=0,JMS_AMQP_MESSAGE_FORMAT=0,JMS_AMQP_MA_x-opt-jms-msg-type=5]]@74198727:
java.lang.IllegalStateException: Can't deliver message
org.proton.plug.exceptions.ActiveMQAMQPInternalErrorException: Unknown
Destination Type passed to JMS Transformer.
at
org.apache.activemq.artemis.core.protocol.proton.plug.ProtonSessionIntegrationCallback.sendMessage(ProtonSessionIntegrationCallback.java:370)
[:]
at
org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1027)
[:]
at
org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:417)
[:]
at
org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2463)
[:]
at
org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:1955)
[:]
at
org.apache.activemq.artemis.core.server.impl.QueueImpl.access$1400(QueueImpl.java:98)
[:]
at
org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2694)
[:]
at
org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$ExecutorTask.run(OrderedExecutorFactory.java:100)
[:]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
[rt.jar:1.8.0_73]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
[rt.jar:1.8.0_73]
at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_73]
Caused by: org.proton.plug.exceptions.ActiveMQAMQPInternalErrorException:
Unknown Destination Type passed to JMS Transformer.
at
org.proton.plug.context.server.ProtonServerSenderContext.deliverMessage(ProtonServerSenderContext.java:274)
[:]
at
org.apache.activemq.artemis.core.protocol.proton.plug.ProtonSessionIntegrationCallback.sendMessage(ProtonSessionIntegrationCallback.java:363)
[:]
... 10 more
```
> exception when sending 10k message
> ----------------------------------
>
> Key: ARTEMIS-214
> URL: https://issues.apache.org/jira/browse/ARTEMIS-214
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Components: AMQP
> Reporter: Andy Taylor
> Assignee: Howard Gao
>
> if you send a 10kb message using the qpid jms client the server throws an
> exception:
> java.lang.IllegalArgumentException
> at java.nio.Buffer.limit(Buffer.java:267)
> at
> org.apache.qpid.proton.codec.DecoderImpl.readRaw(DecoderImpl.java:945)
> at
> org.apache.qpid.proton.codec.StringType$AllStringEncoding.readValue(StringType.java:169)
> at
> org.apache.qpid.proton.codec.StringType$AllStringEncoding.readValue(StringType.java:121)
> at
> org.apache.qpid.proton.codec.DynamicTypeConstructor.readValue(DynamicTypeConstructor.java:39)
> at
> org.apache.qpid.proton.codec.DecoderImpl.readObject(DecoderImpl.java:885)
> at
> org.apache.qpid.proton.message.impl.MessageImpl.decode(MessageImpl.java:647)
> at
> org.apache.qpid.proton.message.impl.MessageImpl.decode(MessageImpl.java:577)
> at
> org.apache.qpid.proton.jms.EncodedMessage.decode(EncodedMessage.java:46)
> at
> org.apache.qpid.proton.jms.JMSMappingInboundTransformer.transform(JMSMappingInboundTransformer.java:40)
> at
> org.apache.activemq.artemis.core.protocol.proton.converter.ProtonMessageConverter.inboundJMSType(ProtonMessageConverter.java:61)
> at
> org.apache.activemq.artemis.core.protocol.proton.converter.ProtonMessageConverter.inbound(ProtonMessageConverter.java:47)
> at
> org.apache.activemq.artemis.core.protocol.proton.plug.ProtonSessionIntegrationCallback.serverSend(ProtonSessionIntegrationCallback.java:269)
> at
> org.proton.plug.context.server.ProtonServerReceiverContext.onMessage(ProtonServerReceiverContext.java:131)
> at
> org.proton.plug.context.AbstractConnectionContext$LocalListener.onDelivery(AbstractConnectionContext.java:277)
> at org.proton.plug.handler.Events.dispatch(Events.java:104)
> at
> org.proton.plug.handler.impl.ProtonHandlerImpl.dispatch(ProtonHandlerImpl.java:399)
> at
> org.proton.plug.handler.impl.ProtonHandlerImpl.flush(ProtonHandlerImpl.java:298)
> at
> org.proton.plug.handler.impl.ProtonHandlerImpl.inputBuffer(ProtonHandlerImpl.java:178)
> at
> org.proton.plug.context.AbstractConnectionContext.inputBuffer(AbstractConnectionContext.java:72)
> at
> org.apache.activemq.artemis.core.protocol.proton.ActiveMQProtonRemotingConnection.bufferReceived(ActiveMQProtonRemotingConnection.java:142)
> at
> org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:694)
> at
> org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:73)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:332)
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:318)
> at
> io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:787)
> at
> io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:125)
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:507)
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:464)
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:378)
> at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:350)
> at
> io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116)
> at java.lang.Thread.run(Thread.java:745)
> the following code will show it
> try
> {
> ctx = new InitialContext(properties);
> connection = ((ConnectionFactory)
> ctx.lookup("connection")).createConnection();
> session = connection.createSession(false,
> Session.CLIENT_ACKNOWLEDGE);
> producer = session.createProducer((Destination)
> ctx.lookup("address"));
> if (!options.persistent)
> {
> producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
> }
> else
> {
> producer.setDeliveryMode(DeliveryMode.PERSISTENT);
> }
> connection.start();
> TextMessage message =
> session.createTextMessage(options.messageText);
> producer.send(message);
> producer.close();
> session.close();
> connection.close();
> }
> catch (NamingException | JMSException e)
> {
> e.printStackTrace();
> }
> private static String createMessage(int messageSize)
> {
> final String AB = "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ";
> Random rnd = new Random();
> StringBuilder sb = new StringBuilder((int) messageSize);
> for (int j = 0; j < messageSize; j++ )
> {
> sb.append(AB.charAt(rnd.nextInt(AB.length())));
> }
> return sb.toString();
> }
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
