[
https://issues.apache.org/jira/browse/ARTEMIS-1709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16379819#comment-16379819
]
Simon Chalmers edited comment on ARTEMIS-1709 at 2/28/18 6:06 AM:
------------------------------------------------------------------
Example tester client code, using Amqp.Net Lite.
var connectionFactory = new ConnectionFactory();
var connection = await connectionFactory.CreateAsync(new
Address("amqp://artemis:simetraehcapa@linuxhost"));
var session = new Session(connection);
var senderLink = new SenderLink(session, "sender-link",
"queue.in.my-service.test-request");
var rng = new Random();
var messageContent = new byte[600000];
rng.NextBytes(messageContent);
senderLink.Send(new Message(messageContent));
await senderLink.CloseAsync();
await session.CloseAsync();
await connection.CloseAsync();
was (Author: auskeptic):
Example tester client code, using Amqp.Net Lite.
var connectionFactory = new ConnectionFactory();
var connection = await connectionFactory.CreateAsync(new
Address("amqp://artemis:simetraehcapa@linuxhost"));
var session = new Session(connection);
var senderLink = new SenderLink(session, "sender-link",
"queue.in.my-service.test-request");
var rng = new Random();
var messageContent = new byte[60000];
rng.NextBytes(messageContent);
senderLink.Send(new Message(messageContent));
await senderLink.CloseAsync();
await session.CloseAsync();
await connection.CloseAsync();
> Can't send large messages with AMQP
> -----------------------------------
>
> Key: ARTEMIS-1709
> URL: https://issues.apache.org/jira/browse/ARTEMIS-1709
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Components: AMQP
> Affects Versions: 2.4.0
> Environment: broker.xml file attached.
> Reporter: Simon Chalmers
> Priority: Major
> Fix For: 2.3.0
>
> Attachments: broker.xml
>
>
> Sending a single message using AMQP to a queue where the size of the single
> message is 501741 bytes errors out.
> Sending the same single message to version 2.3.0 of Artemis does not result
> in the same error and is sent successfully.
> Error:
>
> Unhandled Exception: Amqp.AmqpException: AMQ119029: No address configured on
> the Server''s Session
> at Amqp.SenderLink.SendInternal(Message message, Int32 waitMilliseconds)
> at
> MI.Messaging.AmqpNetLite.Test.MessageDispatcher.<SendMessages>d__6.MoveNext()
> in C:\Users\BillPoole\Documents\Visual Studio 2017\Projects\MI Messaging
> Framework\MI.Messaging.AmqpNetLite.Test\MessageDispatcher.cs:line 54
> — End of stack trace from previous location where exception was thrown —
> at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
> at
> MI.Messaging.AmqpNetLite.Test.MessageDispatcher.<SendMessages>d__6.MoveNext()
> in C:\Users\BillPoole\Documents\Visual Studio 2017\Projects\MI Messaging
> Framework\MI.Messaging.AmqpNetLite.Test\MessageDispatcher.cs:line 102
> — End of stack trace from previous location where exception was thrown —
> at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
> at
> System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task
> task)
> at MI.Messaging.AmqpNetLite.Test.Program.<Main>d__17.MoveNext() in
> C:\Users\BillPoole\Documents\Visual Studio 2017\Projects\MI Messaging
> Framework\MI.Messaging.AmqpNetLite.Test\Program.cs:line 131
> — End of stack trace from previous location where exception was thrown —
> at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
> at
> System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task
> task)
> at MI.Messaging.AmqpNetLite.Test.Program.<Main>(String[] args)
>
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
