You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Angus McAllister (JIRA)" <ji...@apache.org> on 2016/01/28 10:16:39 UTC
[jira] [Commented] (ARTEMIS-214) exception when sending 10k message
[ https://issues.apache.org/jira/browse/ARTEMIS-214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15121084#comment-15121084 ]
Angus McAllister commented on ARTEMIS-214:
------------------------------------------
We have encountered this issue in the past few days using Artemis for large messages. Our requirement is to stream large amounts of content (between 10 KB and 500 MB) over messages, to avoid callbacks between components (there are good reasons for this in our context).
This issue is a potential show-stopper for the work we are doing at the moment, so we would immensely appreciate it if it could be looked at and resolved. Many thanks in advance.
> 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
>
> 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)