I am brand new to AMQP 1.0 (have some AMQP 0.9 experience which honestly
doesn't help much).
I have a .NET Core application using the amqpnetlite client and a Go
application using vcabbage/amqp client. They both are running on the same
Linux VM with ActiveMQ 5.15.10 as the provider
I have run into an issue that I think may be related to the way I'm sending
a message over a "one shot" sender link from the .NET core application
(sender) to the Go application (receiver).
Things are generally working as expected until at some unknown point the
receiver begins receiving this error dozens (maybe hundreds) of times per
second and seems to continue "forever":
*Error{Condition: amqp:decode-error, Description: Could not decode AMQP
frame: hex: 0000017202000000005314d00000001300000004 ...
I've read this can happen if the sender closes the connection too quickly.
Here's my sender C# .NET core code (note that the session is long lived):
ISenderLink sender = null;
try
{
...
sender = _session.CreateSender(routingKey, routingKey);
sender.Send(m);
}
catch (Exception e)
{
...
}
finally
{
if (sender != null)
{
sender.Close();
}
}
Here's the receiver Go code:
// Create a receiver
v1bc.receiver, err = v1bc.session.NewReceiver(
amqp.LinkSourceAddress(v1bc.rpcAddress),
amqp.LinkCredit(1), // Is this correct???
)
if err != nil {
...
}
// Receive callback messages asynchronously here
go func() {
for {
// Receive next message
msg, err := v1bc.receiver.Receive(context.Background())
if err != nil {
...
continue
}
// Accept message
if err = msg.Accept(); err != nil {
...
continue
}
v1bc.payloadChannel <- msg.Value.([]byte)
}
}()
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
