Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / nsqio/go-nsq issues and pull requests

#370 - producer.PublishAsync - Not working as expected

Issue - State: closed - Opened by wlbwlbwlb 3 months ago - 1 comment
Labels: question

#369 - style: Only do code optimization

Pull Request - State: closed - Opened by qaqhy 4 months ago - 1 comment
Labels: chore

#368 - Channel stats command

Pull Request - State: open - Opened by qaqhy 4 months ago - 2 comments
Labels: enhancement

#367 - go v1.1.0

Issue - State: open - Opened by weicaijiang 5 months ago - 3 comments

#365 - producer: Integrate context.Context with publishing

Pull Request - State: open - Opened by Ulminator 6 months ago
Labels: enhancement, chore

#364 - Update go.mod

Pull Request - State: closed - Opened by furkankahvecinsider 7 months ago

#363 - Use Klaus Post's flate compression library

Pull Request - State: open - Opened by philpearl 7 months ago

#362 - Use buffered writer for Snappy compression.

Pull Request - State: open - Opened by philpearl 8 months ago
Labels: enhancement

#361 - How can I limit the queue size?

Issue - State: open - Opened by aaronchen2k 10 months ago

#360 - *: context.Context and timeouts

Issue - State: open - Opened by jehiah 10 months ago
Labels: enhancement, chore

#359 - MaxAttempts Callback

Issue - State: closed - Opened by dhulihan about 1 year ago - 1 comment
Labels: question

#358 - go.mod: upgrade snappy => v0.0.4; upgrade go.mod version 1.17+

Pull Request - State: closed - Opened by jehiah about 1 year ago
Labels: chore

#357 - remove empty interface from SetBehaviorDelegate signature

Pull Request - State: open - Opened by Imm0bilize over 1 year ago

#356 - chore: use time.Since instead of time.Now().Sub

Pull Request - State: closed - Opened by testwill over 1 year ago - 1 comment
Labels: chore

#355 - how to clear data in nsq

Issue - State: closed - Opened by Nyx2022 over 1 year ago - 1 comment

#354 - Support connections over unix sockets

Pull Request - State: open - Opened by telepenin almost 2 years ago - 4 comments
Labels: enhancement

#353 - Limit read message size

Pull Request - State: closed - Opened by ibice almost 2 years ago - 4 comments
Labels: enhancement

#352 - producer: HTTP response to IDENTIFY causes memory allocation of over 1GB

Issue - State: closed - Opened by ibice almost 2 years ago - 2 comments
Labels: bug

#351 - An Example of multit-hreaded nsq consuming messages

Issue - State: closed - Opened by fy138 almost 2 years ago - 1 comment
Labels: question

#350 - fix(consumer): remove old nsqd connections if addresses change

Pull Request - State: open - Opened by jrkt about 2 years ago - 4 comments

#349 - error connecting to nsqd - dial tcp 127.0.0.1:4150: connect: connection refused？

Issue - State: closed - Opened by opvexe about 2 years ago - 1 comment
Labels: question

#348 - fix(consumer/delegate): requeue when receive resend msg from nsqd.

Pull Request - State: closed - Opened by laushunyu over 2 years ago - 2 comments
Labels: question

#347 - Conn cannot execute multiple subscribe commands

Issue - State: closed - Opened by puoklam over 2 years ago - 1 comment
Labels: question

#346 - producer: handle case of no transactions in popTransaction()

Pull Request - State: closed - Opened by ploxiln over 2 years ago - 5 comments
Labels: bug

#345 - Panic in producer's router

Issue - State: closed - Opened by xakepp35 over 2 years ago - 2 comments
Labels: bug

#344 - Client doesn't know it's disconnected

Issue - State: open - Opened by watchforstock almost 3 years ago - 2 comments
Labels: needs-info

#343 - "go test" fails with "connection refused"

Issue - State: closed - Opened by saurabhghumnar almost 3 years ago - 2 comments
Labels: question

#342 - Disconnects seem to be quite ungraceful

Issue - State: open - Opened by karalabe about 3 years ago - 2 comments
Labels: bug

#341 - consumer: lower old RDYs first, then assign to new connection

Pull Request - State: closed - Opened by karalabe about 3 years ago - 1 comment
Labels: bug

#340 - bump version to 1.1.0 and update ChangeLog

Pull Request - State: closed - Opened by ploxiln about 3 years ago - 1 comment
Labels: chore

#338 - Support NSQ in ArgoLabs Dataflow

Issue - State: closed - Opened by alexec about 3 years ago - 1 comment

#337 - rename module to github.com/CodapeWild/go-nsq

Pull Request - State: closed - Opened by CodapeWild about 3 years ago - 1 comment

#336 - producer: fix shutdown logs to be uniform with others

Pull Request - State: closed - Opened by karalabe about 3 years ago - 2 comments
Labels: chore

#335 - How to use Command?

Issue - State: closed - Opened by caitou2019 about 3 years ago - 1 comment
Labels: question

#334 - Can you tag v1.0.9

Issue - State: closed - Opened by hunterhug about 3 years ago - 1 comment

#333 - consumer: reuse lookupd http client

Pull Request - State: closed - Opened by JieTrancender about 3 years ago - 2 comments
Labels: enhancement

#331 - SIngleton Producer

Issue - State: closed - Opened by wilhart about 3 years ago - 2 comments
Labels: question

#330 - *: fix github actions

Pull Request - State: closed - Opened by mreiferson about 3 years ago - 5 comments
Labels: chore

#329 - *: switch to github actions

Pull Request - State: closed - Opened by mreiferson about 3 years ago
Labels: chore

#328 - v1.2.1 use DeferredPublish publish delay message,delay invalidation

Issue - State: closed - Opened by cnbattle over 3 years ago - 4 comments

#327 - feat: NSQ cluster or public network message synchronization

Issue - State: closed - Opened by godcong over 3 years ago

#326 - consumer: fix send on closed channel when reconnecting

Pull Request - State: open - Opened by Allenxuxu over 3 years ago - 4 comments
Labels: bug

#325 - panic: send closed channel - incomingMessages

Issue - State: closed - Opened by Allenxuxu over 3 years ago - 1 comment
Labels: bug

#324 - docs: fix Consumer.SetLogger() description

Pull Request - State: closed - Opened by gabriel-vasile over 3 years ago

#323 - beginning close

Issue - State: closed - Opened by w896736588 over 3 years ago - 3 comments
Labels: bug, needs-info

#322 - JUST WONDER WHY PRODUCER dose not support lookupd ! is there any official explain for this?

Issue - State: closed - Opened by infynity over 3 years ago - 1 comment
Labels: question

#321 - consumer: fix panic in nextLookupdEndpoint

Pull Request - State: closed - Opened by martin-sucha over 3 years ago - 4 comments
Labels: bug, needs-info

#319 - can i limit disk total size for nsq?

Issue - State: closed - Opened by doudouba over 3 years ago - 1 comment
Labels: question

#318 - producer: read: connection reset by peer

Issue - State: open - Opened by Doslin almost 4 years ago
Labels: needs-info

#317 - producer: improve code readability

Pull Request - State: closed - Opened by martin-sucha almost 4 years ago - 1 comment
Labels: chore

#316 - panic in Consumer.nextLookupdEndpoint

Issue - State: closed - Opened by martin-sucha almost 4 years ago - 1 comment
Labels: bug

#315 - How To Edit NSQ Proxy Configuration?

Issue - State: closed - Opened by spacehash almost 4 years ago - 1 comment
Labels: question

#314 - Check nsqlookupd list emptiness on Consumer instantiation

Pull Request - State: closed - Opened by borodiychuk almost 4 years ago - 3 comments

#313 - Use AuthSecret as Bearer token for lookupd queries

Pull Request - State: closed - Opened by jehiah about 4 years ago - 1 comment
Labels: enhancement

#312 - Set topology region+zone and send in IDENTIFY msg

Pull Request - State: open - Opened by jehiah about 4 years ago - 1 comment
Labels: enhancement

#311 - ProducerPool - easier remote publishing

Pull Request - State: open - Opened by jehiah about 4 years ago - 5 comments
Labels: enhancement

#310 - producer: remove dead code

Pull Request - State: closed - Opened by martin-sucha about 4 years ago - 1 comment
Labels: chore

#309 - docs: what address in `func NewProducer(addr string, ...)`?

Issue - State: closed - Opened by golopot about 4 years ago - 1 comment
Labels: question

#308 - Frequently meet "Broken pipe error", if HandleMessage function is blocked

Issue - State: closed - Opened by umialpha about 4 years ago - 3 comments
Labels: needs-info

#307 - docs: add exit-on-signal and more comments to example consumer

Pull Request - State: closed - Opened by ploxiln over 4 years ago
Labels: chore

#306 - nsq on client side (consumer)

Issue - State: closed - Opened by farzad-845 over 4 years ago - 3 comments
Labels: question

#305 - command: register support topic/channel state

Pull Request - State: open - Opened by juggli over 4 years ago - 7 comments
Labels: enhancement

#304 - will consumer reconnect to the server when the connection is closed by server?

Issue - State: closed - Opened by pengbinbin1 over 4 years ago - 2 comments
Labels: question

#303 - failed to read command read tcp i/o timeout

Issue - State: closed - Opened by pengbinbin1 over 4 years ago - 1 comment
Labels: question

#302 - consumer: LogFailedMessage behavior

Issue - State: closed - Opened by Joevychow over 4 years ago - 1 comment
Labels: question

#300 - consumer: how to manually FIN a message

Issue - State: closed - Opened by umialpha over 4 years ago - 3 comments
Labels: question

#299 - consumer: any way to multiplex subscriptions to topics/channels over a single connection?

Issue - State: closed - Opened by umialpha over 4 years ago - 2 comments
Labels: question

#298 - Max Open File Publishing Message to NSQd

Issue - State: closed - Opened by rizalgowandy over 4 years ago - 3 comments
Labels: question

#297 - *: add AUTHORS file

Pull Request - State: closed - Opened by mreiferson over 4 years ago
Labels: chore

#296 - config: add Dialer option to connect through a proxy

Pull Request - State: open - Opened by HaoweiCh over 4 years ago - 1 comment
Labels: enhancement

#295 - Expose interfaces to public API to ease testing

Pull Request - State: closed - Opened by emaincourt over 4 years ago - 2 comments
Labels: enhancement

#294 - fix(doc): wrong variable for producer

Pull Request - State: closed - Opened by nikitabuyevich over 4 years ago - 1 comment

#293 - Why there is no possibility to publish to nsq lookupd?

Issue - State: closed - Opened by a-urth over 4 years ago - 2 comments
Labels: question

#292 - NSQ admin show channel connections 0

Issue - State: closed - Opened by YuHsiangCheng over 4 years ago
Labels: question

#291 - why "connectedFlag" not set zero when Stop() called

Issue - State: closed - Opened by TT6033 over 4 years ago - 2 comments
Labels: question

#290 - Load balance nsqd for producing messages

Issue - State: closed - Opened by EthanHemo over 4 years ago - 1 comment
Labels: question

#289 - You can also write to nsq using http. What are the advantages of go-nsq over the http method

Issue - State: closed - Opened by guonaihong over 4 years ago - 2 comments
Labels: question

#288 - Use the official example to create producer error reports

Issue - State: closed - Opened by zhoushuguang over 4 years ago - 4 comments
Labels: question

#287 - Why AddConcurrentHandlers will panic after connecting to NSQD or NSQ Lookupd？

Issue - State: closed - Opened by juggli over 4 years ago - 2 comments
Labels: question

#286 - How to: Disconnect client when queue is exhausted

Issue - State: closed - Opened by yohanyflores over 4 years ago - 3 comments
Labels: question

#285 - Excessive heartbeats for Consumer AddHandler

Issue - State: closed - Opened by itsa-sh almost 5 years ago - 3 comments
Labels: question

#284 - Can I get all topic names?

Issue - State: closed - Opened by egorsmkv almost 5 years ago - 2 comments

#283 - remove duplicate 'Config.assertInitialized()' check

Pull Request - State: closed - Opened by SwanSpouse almost 5 years ago - 1 comment

#282 - reduce duplicate rdy update requests

Pull Request - State: closed - Opened by andyxning almost 5 years ago - 5 comments

#281 - minor cleanup of log format handling for per-level logger

Pull Request - State: closed - Opened by ploxiln almost 5 years ago

#280 - About creating a new producer

Issue - State: closed - Opened by stair-go almost 5 years ago - 4 comments
Labels: question

#279 - Prep 1.0.8 release; drop dep support

Pull Request - State: closed - Opened by jehiah almost 5 years ago - 1 comment

#278 - Does single producer support multi thread ?

Issue - State: closed - Opened by mill888 almost 5 years ago - 2 comments
Labels: question

#277 - redistribute RDY in high throughput, idle producer situations

Pull Request - State: open - Opened by mscso almost 5 years ago - 3 comments
Labels: enhancement

#276 - t

Issue - State: closed - Opened by billip215 almost 5 years ago

#275 - Added support for setting logger for each log level

Pull Request - State: closed - Opened by ghost about 5 years ago - 9 comments
Labels: enhancement

#272 - if writeLoop or readLoop is exited,i think the nsq client will not work,why the level of the log in info

Issue - State: closed - Opened by li-bit about 5 years ago - 4 comments
Labels: question

#271 - Add high-level godoc for publisher and consumer

Pull Request - State: closed - Opened by skateinmars about 5 years ago
Labels: docs

#270 - consumer: add SetLoggerLevel

Pull Request - State: closed - Opened by atlas-comstock about 5 years ago - 4 comments
Labels: enhancement

#269 - protocol document

Issue - State: closed - Opened by yuansudong about 5 years ago - 3 comments
Labels: question