Support RECEIPT for SUBSCRIBE operations

[rp42]

As far as I can tell go-stomp doesn't support receipts for subscribe operations. I haven't seen a SubscribeOpt for this. When I manually add the header using stomp.SubscribeOpt.Header, I do see a RECEIPT from from the server, but this looks to close the Subscription's channel in go-stomp.

I'm working with a system where you subscribe to a topic and then trigger an operation that posts messages to the topic. Unless I add a sleep in, I can lose the initial messages that are posted.

[worg]

@rp42 Do you have an example using the receipt SubscribeOpt.Header?

[rp42]

Here you go:
main.go.gz

The subscription channel gets closed when go-stomp receives the subscription receipt from what I can work out, so there is no way of receiving the messages from the subscription. If I remove the header then the subscription works ok, but doesn't wait for the server to process the subscribe frame.

[c-bg]

At the developers, thanks a lot for this nice library.
I have exactly the same problem as reported by @rp42 . @rp42 , could you tell me how you solved this problem in the end?
Thanks a lot for your help in advance.

[rp42]

It was a while ago now, but I think we stuck with using a time delay to ensure that the message had been processed by the server. This was acceptable for our real world use case, but it made the test cases run a bit slow.

[c-bg]

okay, I see. thanks a lot for your prompt reply!

[c-bg]

I think I found the reason: The subscription has its own readLoop method that closes the channel whenever it receives any receipt, if I see correctly:

stomp/subscription.go

Line 174 in 123cce4

} else if f.Command == frame.RECEIPT {

Could @thomaslee or @worg or anyone who knows the purpose of these lines comment on this? :)
Thanks a lot for your help in advance.