Skip to content

Commit

Permalink
Make sure to write into topic and add ask for receipt
Browse files Browse the repository at this point in the history
  • Loading branch information
kazeborja committed Jan 26, 2022
1 parent 0a4dc27 commit d677efd
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions stomp.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ func StartStomp(config *Config, queue *ConfirmationQueue) {
stompUser := config.StompUser
stompPassword := config.StompPassword
stompUrl := config.StompURL
stompTopic := config.StompTopic
stompTopic := "/topic/" + config.StompTopic

stompSession := NewStompConnection(stompUser, stompPassword,
*stompUrl, stompTopic)
Expand Down Expand Up @@ -87,7 +87,8 @@ sendMessageLoop:
err := session.conn.Send(
session.topic,
"text/plain",
msg)
msg,
stomp.SendOpt.Receipt)

if err != nil {
log.Errorln("Failed to publish message:", err)
Expand Down

0 comments on commit d677efd

Please sign in to comment.