Sending large message without ssl

[rustem08]

When sending large messages, about 150 MB without SSL, it arrives to the queue. But when closing the session, an error appears in the log. There are no problems with SSL at all.
What I did:

1. I used an SSL receiver, which has no problems. I disabled SSL. I didn't change any other settings. The error persisted.
2. I created a Java client for AMQP. I sent a large message without SSL. I didn't see any problems.

I use Artemis broker
....

15:56:32.210] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.211] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.212] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.213] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.215] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.216] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.217] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.219] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.220] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.221] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.222] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.223] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.224] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.226] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.227] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.229] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.231] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.232] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.233] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.235] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.236] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.238] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.239] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.241] Frame: SEND (ch=0) transfer(handle:0,more:True) payload 131052
15:56:32.242] Frame: SEND (ch=0) transfer(handle:0) payload 9388
15:56:32.246] Frame: RECV (ch=0) close(error:error(condition:amqp:connection:framing-error,description:org.apache.qpid.proton.engine.TransportException: specified frame size 1215524422 greater than maximum valid frame size 131072))
15:56:32.248] Frame: SEND (ch=0) close()
15:56:51.681] Frame: SEND (ch=0) empty
15:57:21.681] Frame: SEND (ch=0) empty

[xinchen10]

I was not able to reproduce the issue using Artemis 2.33.0 with the client on both .Net Framework 4.8 and .Net 5.0.

            Connection connection = new Connection(new Address("amqp://user:pwd@127.0.0.1:5672"));
            Session session = new Session(connection);
            SenderLink sender = new SenderLink(session, "sender-" + testName, "q1");
            await sender.SendAsync(new Message(new byte[1024 * 1024 * 150])); // send a large message
            await session.CloseAsync();
            await connection.CloseAsync();

[rustem08]

Xin Chen (@xinchen10), thank you for your answer.

AMQP 2.5.0

This issue occurred when I used ConnectionFactory to create a connection in the following way:

private const int KEEP_ALIVE_TIME_MILLISECONDS = 15 * 60 * 1000;
private const int KEEP_ALIVE_INTERVAL_MILLISECONDS = 5 * 1000;
private const int MIN_BUFFER_SIZE = 64;
private const int MAX_BUFFER_SIZE = 16 * 1024 * 1024;
private const int MAX_MEMORY_SIZE = 512 * 1024 * 1024;
// Additional constants used below (defined elsewhere in the class)
private const int TCP_SEND_BUFFER_SIZE = ...;
private const int TCP_TIMEOUT = ...;
private const int AMQP_MAX_FRAME_SIZE = ...;

private static ConnectionFactory CreateFactory()
{
    return new ConnectionFactory
    {
        BufferManager = new BufferManager(MIN_BUFFER_SIZE, MAX_BUFFER_SIZE, MAX_MEMORY_SIZE),
        TCP =
        {
            NoDelay = true,
            SendBufferSize = TCP_SEND_BUFFER_SIZE,
            SendTimeout = TCP_TIMEOUT,
            ReceiveTimeout = TCP_TIMEOUT,
            KeepAlive = new TcpKeepAliveSettings
            {
                KeepAliveInterval = KEEP_ALIVE_INTERVAL_MILLISECONDS,
                KeepAliveTime = KEEP_ALIVE_TIME_MILLISECONDS,
            },
        },
        AMQP =
        {
            MaxFrameSize = AMQP_MAX_FRAME_SIZE,
        }
    };
}

// ...

_connection = await _connectionFactory.CreateAsync(_amqpAddress).ConfigureAwait(false);
_connection.Closed += OnConnectionClosed;

// ...

_sender = _session.CreateSender(_linkName, _queueName);

// ...

await _sender.SendAsync(message);

When I try sending twice, the message goes through without issues.