Message Annotations content missing

[gavinfish]

Related with Azure/azure-event-hubs-go#131.

After some investigation, I find that the msg received in the below method only has three Annotations:

amqp/client.go

Lines 1810 to 1839 in 7c41f1a

	func (r *Receiver) Receive(ctx context.Context) (*Message, error) {
	if atomic.LoadUint32(&r.link.paused) == 1 {
	select {
	case r.link.receiverReady <- struct{}{}:
	default:
	}
	}
	// non-blocking receive to ensure buffered messages are
	// delivered regardless of whether the link has been closed.
	select {
	case msg := <-r.link.messages:
	msg.receiver = r
	return &msg, nil
	case <-ctx.Done():
	return nil, ctx.Err()
	default:
	}
	// wait for the next message
	select {
	case msg := <-r.link.messages:
	msg.receiver = r
	return &msg, nil
	case <-r.link.done:
	return nil, r.link.err
	case <-ctx.Done():
	return nil, ctx.Err()
	}
	}

The missing x-opt-partition-id annotation prevents the event hubs library to parse the partitionId for the event.

https://github.com/Azure/azure-event-hubs-go/blob/26616d904577c5d0b8c0a486b4b0e77c9c002284/event.go#L56-L62

[vcabbage]

Looking at a packet capture when receiving from Event Hubs I don't see x-opt-partition-id. Is there some thing extra that needs to be done to get EH to include that?

[gavinfish]

@devigned it seems that the x-opt-partition-id stuff is introduced in Azure/azure-event-hubs-go#108. Is there any documentation for this? I cannot find any test cases which will let the service side send this annotation.

[devigned]

I can’t find docs regarding x-opt-partition-id and at this point, I’m not sure if that was a meta field that previously existed or if it was a request to the service team to add the field. I’d reach out to the service team or other AMQP SDK teams for guidance.

This issue belongs in the Azure repos.