Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

How to set the correlation ID? #26

Closed
clalos opened this issue Oct 12, 2021 · 1 comment
Closed

How to set the correlation ID? #26

clalos opened this issue Oct 12, 2021 · 1 comment

Comments

@clalos
Copy link

clalos commented Oct 12, 2021

Hello,
first of all thanks for the amazing work. I can't find a way to set the correlation ID of the underlying amqp.Publishing struct. It seems not supported by the configuration.

// Letter contains the message body and address of where things are going.
type Letter struct {
	LetterID   uuid.UUID
	RetryCount uint32
	Body       []byte
	Envelope   *Envelope
}

// Envelope contains all the address details of where a letter is going.
type Envelope struct {
	Exchange     string
	RoutingKey   string
	ContentType  string
	Mandatory    bool
	Immediate    bool
	Headers      amqp.Table
	DeliveryMode uint8
	Priority     uint8
}

--- Update
It would be nice to set the amqp.Publishing.Type as well.

@houseofcat
Copy link
Owner

houseofcat commented Nov 18, 2021

This was solved in release v2.1.4

Envelope struct supports two new fields CorrelationID and Type and are mapped to Publishing methods.

Details:
#27

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants