Skip to content

Commit

Permalink
Publish persistent messages (#8)
Browse files Browse the repository at this point in the history
  • Loading branch information
zenovich authored and brettallred committed Sep 14, 2016
1 parent 201ba22 commit 243eba1
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion publisher.go
Original file line number Diff line number Diff line change
Expand Up @@ -154,7 +154,7 @@ func (p *Publisher) PublishBytes(message []byte, subscriber *Subscriber) error {
amqp.Publishing{
ContentType: "application/json",
Body: message,
DeliveryMode: amqp.Transient,
DeliveryMode: amqp.Persistent,
})
}

Expand Down

0 comments on commit 243eba1

Please sign in to comment.