biskit

Results 33 comments of biskit

updated it: ```go package main import ( "fmt" "os" "time" "github.com/nats-io/nats.go" ) func main() { timeout := 5 * time.Second // Connect to NATS nc, err := nats.Connect("nats://localhost:4223") if err...

that seems to work. i would have never guessed `nats.NewInbox()` as `DeliverSubject` and was scratching my head on how to handle wildcard subjects, like `ORDERS.*`. now, with it compiling and...

thanks @kozlovic for the response. yes, I did add it and it filters. output: ``` --->>stream info ORDERS [ORDERS.*] Publish complete ---->>>m3 hello-0 ---->>>m4 hello-287 ``` the first one gets...

> yes, this is confusing, but that's the way it is unfortunately in the `stan` world, i just did not unsubscribe and closed connections to restore them later either with...

> I think you are just experimenting, but you should let us know what exactly you are trying to do so that we can better explain and you have a...

Then an application using QueueSubscribe that crashes and restarts immediately should be ready to handle out of sequence messages, no matter what the Ack model is. The idea behind using...

it has been a little difficult to pin point this one... running memprofile on a long running program that has the above characteristics, I see memory grow (but not a...

I still have this issue and what @wallyqs says and you do make sense... 65536 slots with each slot holding a message anywhere from 2k to 4k in size and...

all my subscriptions are long standing ones and i keep pulling messages off them...

@piotrpio once I do a msg.Ack() why not free that slot? makes no sense holding on to data I have processed and have no control over releasing memory... also, in...