top

AMQP 0.9.1 client with RabbitMQ extensions

Understand the AMQP 0.9.1 messaging model by reviewing these links first. Much of the terminology in this library directly relates to AMQP concepts.

Resources

http://www.rabbitmq.com/tutorials/amqp-concepts.html
http://www.rabbitmq.com/getstarted.html
http://www.rabbitmq.com/amqp-0-9-1-reference.html

Design

Most other broker clients publish to queues, but in AMQP, clients publish Exchanges instead. AMQP is programmable, meaning that both the producers and consumers agree on the configuration of the broker, instead requiring an operator or system configuration that declares the logical topology in the broker. The routing between producers and consumer queues is via Bindings. These bindings form the logical topology of the broker.

In this library, a message sent from publisher is called a "Publishing" and a message received to a consumer is called a "Delivery". The fields of Publishings and Deliveries are close but not exact mappings to the underlying wire format to maintain stronger types. Many other libraries will combine message properties with message headers. In this library, the message well known properties are strongly typed fields on the Publishings and Deliveries, whereas the user defined headers are in the Headers field.

The method naming closely matches the protocol's method name with positional parameters mapping to named protocol message fields. The motivation here is to present a comprehensive view over all possible interactions with the server.

Generally, methods that map to protocol methods of the "basic" class will be elided in this interface, and "select" methods of various channel mode selectors will be elided for example Channel.Confirm and Channel.Tx.

The library is intentionally designed to be synchronous, where responses for each protocol message are required to be received in an RPC manner. Some methods have a noWait parameter like Channel.QueueDeclare, and some methods are asynchronous like Channel.Publish. The error values should still be checked for these methods as they will indicate IO failures like when the underlying connection closes.

Asynchronous Events

Clients of this library may be interested in receiving some of the protocol messages other than Deliveries like basic.ack methods while a channel is in confirm mode.

The Notify* methods with Connection and Channel receivers model the pattern of asynchronous events like closes due to exceptions, or messages that are sent out of band from an RPC call like basic.ack or basic.flow.

Any asynchronous events, including Deliveries and Publishings must always have a receiver until the corresponding chans are closed. Without asynchronous receivers, the sychronous methods will block.

Use Case

It's important as a client to an AMQP topology to ensure the state of the broker matches your expectations. For both publish and consume use cases, make sure you declare the queues, exchanges and bindings you expect to exist prior to calling Channel.Publish or Channel.Consume.

// Connections start with amqp.Dial() typically from a command line argument
// or environment variable.
connection, err := amqp.Dial(os.Getenv("AMQP_URL"))

// To cleanly shutdown by flushing kernel buffers, make sure to close and
// wait for the response.
defer connection.Close()

// Most operations happen on a channel.  If any error is returned on a
// channel, the channel will no longer be valid, throw it away and try with
// a different channel.  If you use many channels, it's useful for the
// server to
channel, err := connection.Channel()

// Declare your topology here, if it doesn't exist, it will be created, if
// it existed already and is not what you expect, then that's considered an
// error.

// Use your connection on this topology with either Publish or Consume, or
// inspect your queues with QueueInspect.  It's unwise to mix Publish and
// Consume to let TCP do its job well.

SSL/TLS - Secure connections

When Dial encounters an amqps:// scheme, it will use the zero value of a tls.Config. This will only perform server certificate and host verification.

Use DialTLS when you wish to provide a client certificate (recommended), include a private certificate authority's certificate in the cert chain for server validity, or run insecure by not verifying the server certificate dial your own connection. DialTLS will use the provided tls.Config when it encounters an amqps:// scheme and will dial a plain connection when it encounters an amqp:// scheme.

SSL/TLS in RabbitMQ is documented here: http://www.rabbitmq.com/ssl.html +build gofuzz

Imported by 869 package(s)

  1. git.adverplex.com/cogo/banksy.git/pacer
  2. github.com/2tvenom/machinery/v1/backends
  3. github.com/2tvenom/machinery/v1/brokers
  4. github.com/3onyc/docker-events-amqp
  5. github.com/6xiao/go/Amqp
  6. github.com/AVOXI/go-ari-library
  7. github.com/AdOnWeb/postmanq/cmd
  8. github.com/AdOnWeb/postmanq/consumer
  9. github.com/AlexanderThaller/grafana/pkg/services/eventpublisher
  10. github.com/Assembla/cony
  11. github.com/Assembla/cony/examples/basic/producer
  12. github.com/Assembla/cony/examples/email/producer
  13. github.com/Assembla/cony/examples/web/producer
  14. github.com/AutogrowSystems/grafana/pkg/services/eventpublisher
  15. github.com/BBerastegui/rpcmq
  16. github.com/Bitbored/croft
  17. github.com/BnLCr/grafana/pkg/services/eventpublisher
  18. github.com/BnLCr/telegraf/plugins/outputs/amqp
  19. github.com/BrightLocal/amqp-rpc
  20. github.com/Cepave/fe/mq
  21. github.com/Cepave/open-falcon-backend/modules/fe/mq
  22. github.com/CodeCollaborate/Server/modules/rabbitmq
  23. github.com/CrowdSurge/amqp/examples/pubsub
  24. github.com/CrowdSurge/amqp/examples/simple-consumer
  25. github.com/CrowdSurge/amqp/examples/simple-producer
  26. github.com/CuriousLLC/celery
  27. github.com/DArcops/first-Queue-with-RabbitMQ
  28. github.com/DECK36/go-amqp2gelf
  29. github.com/DECK36/go-log2amqp
  30. github.com/Dal-Papa/go-the0v3n-microservice/server
  31. github.com/Dal-Papa/microservices-hackathon-october-2014/storage/server
  32. github.com/Dataman-Cloud/health_checker
  33. github.com/DmitryBugrov/backup/AdminAgent/com
  34. github.com/DuoSoftware/DVP-ARDSLiteRoutingEngine/ArdsLiteRoutingEngine
  35. github.com/Eazynow/go-rabbit-playground/basic
  36. github.com/Eazynow/go-rabbit-playground/edge
  37. github.com/Eazynow/go-rabbit-playground/microservice
  38. github.com/Everlane/fluffle-go
  39. github.com/FacepunchProgrammers/bridge-slack
  40. github.com/Fersca/Go-practice/dockerExample
  41. github.com/Financial-Times/adobe-project-creator
  42. github.com/Fortiz2305/rabbitmq-tutorials/go
  43. github.com/Fumon/qs-webdaemons/test
  44. github.com/Fumon/qs-webdaemons/weighscale
  45. github.com/HailoOSS/platform/client
  46. github.com/HailoOSS/platform/raven
  47. github.com/HailoOSS/platform/server
  48. github.com/HolmesProcessing/Holmes-Gateway/gateway
  49. github.com/HolmesProcessing/Holmes-Storage
  50. github.com/HolmesProcessing/Holmes-Totem-Dynamic/check
  51. github.com/HolmesProcessing/Holmes-Totem-Dynamic/feed
  52. github.com/HolmesProcessing/Holmes-Totem-Dynamic/lib
  53. github.com/HolmesProcessing/Holmes-Totem-Dynamic/submit
  54. github.com/Igneous/orc-agent
  55. github.com/Inflatablewoman/cqrs/rabbit
  56. github.com/JKolios/elasticgin
  57. github.com/JKolios/elasticgin/api
  58. github.com/JKolios/elasticgin/rabbitmq
  59. github.com/Jkolios/elasticgin
  60. github.com/Jkolios/elasticgin/api
  61. github.com/Jkolios/elasticgin/rabbitmq
  62. github.com/JoshuaJessery/amqp-go-client/amqp
  63. github.com/Kaey/telegraf/plugins/outputs/amqp
  64. github.com/Kane-Sendgrid/amqpc
  65. github.com/Lobaro/ttn/amqp
  66. github.com/MajorMJR/pingo
  67. github.com/MajorMJR/pingo/server
  68. github.com/MartyMacGyver/rabbit-mq-stress-tester
  69. github.com/Mierdin/todd/comms
  70. github.com/NJUST-FishTeam/go-judgenode
  71. github.com/NathanielMichael/telegraf/plugins/outputs/amqp
  72. github.com/NeowayLabs/wabbit/amqp
  73. github.com/NeowayLabs/wabbit/utils
  74. github.com/NikitaSmall/micro-todo/master
  75. github.com/NikitaSmall/micro-todo/storage
  76. github.com/Noxer/telegraf/plugins/outputs/amqp
  77. github.com/OlivierBoucher/go-tracking-server
  78. github.com/OlivierBoucher/go-tracking-server/processor
  79. github.com/OlivierBoucher/go-tracking-server/queues
  80. github.com/Onefootball/samodelkin/mock/amqpmock
  81. github.com/PandoCloud/pando-cloud/pkg/queue
  82. github.com/Qlean/silvia/silvia
  83. github.com/RackHD/neighborhood-manager/rackhd/models
  84. github.com/RichardKnop/machinery/v1/backends
  85. github.com/RichardKnop/machinery/v1/brokers
  86. github.com/RobAWilkinson/rabbit-test/database
  87. github.com/Sam-Izdat/amqp-rpc-test/demo
  88. github.com/SamuelRamond/autoscaler
  89. github.com/Sergeo17/basicgo/publishers
  90. github.com/Shop2market/mq-benchmarking/benchmark/mq
  91. github.com/ShowMax/gogstash/output/amqp
  92. github.com/ShowMax/logfan-processors/input-amqp
  93. github.com/SolarCity/ftb/publishers
  94. github.com/SolarCity/ftb_milestoneapi/services
  95. github.com/SolarCity/ftb_task-api/services
  96. github.com/SolarCity/ftb_timelineservice/rabbitmq-receive
  97. github.com/SolarCity/ftb_timelineservice/rabbitmq-send
  98. github.com/SolarCity/ftb_wqservice/services
  99. github.com/SummitRoute/srepp_server/CallbackServer/system
  100. github.com/SumoLogic/grafana/pkg/services/eventpublisher
  101. github.com/TF2Stadium/Fumble/mumble
  102. github.com/TF2Stadium/Fumble/rpc
  103. github.com/TF2Stadium/Helen/helpers
  104. github.com/TF2Stadium/Helen/models/rpc
  105. github.com/TF2Stadium/Pauling/rpc
  106. github.com/TF2Stadium/Pauling/server
  107. github.com/TF2Stadium/fumble/mumble
  108. github.com/TF2Stadium/fumble/rpc
  109. github.com/TF2Stadium/twitchbot/rpc
  110. github.com/TheThingsNetwork/croft
  111. github.com/TheThingsNetwork/gateway-connector-bridge/backend/amqp
  112. github.com/TheThingsNetwork/jolie
  113. github.com/TheThingsNetwork/ttn/amqp
  114. github.com/TjiffTjoff/go-alive
  115. github.com/TjiffTjoff/go-alive-service
  116. github.com/TjiffTjoff/go-sensu
  117. github.com/TjiffTjoff/go-sensu-service
  118. github.com/Velrok/postbote
  119. github.com/Wattpad/finn
  120. github.com/Weebly/Hare
  121. github.com/a3linux/celery
  122. github.com/abhijitiitr/govuk_crawler_worker
  123. github.com/abhijitiitr/govuk_crawler_worker/queue
  124. github.com/abhisheksugandhi/metering
  125. github.com/achilleasa/usrv-amqp-transport
  126. github.com/achilleasa/usrv-service-adapters/service/amqp
  127. github.com/achilleasa/usrv-v0/transport
  128. github.com/actionpay/postmanq/cmd
  129. github.com/actionpay/postmanq/consumer
  130. github.com/adamreeve/comments-app-go-rabbit-react
  131. github.com/adamreeve/comments-app-go-rabbit-react/message-queue
  132. github.com/adquality/negroniamqp
  133. github.com/ae6rt/healthchecks
  134. github.com/afking/rrpc
  135. github.com/afxcn/boulder/rpc
  136. github.com/agocs/golangRabbitMQ/examples
  137. github.com/agocs/queuesPresentation/examples
  138. github.com/aleasoluciones/go-spikes/amqp
  139. github.com/aleasoluciones/go-spikes/rabbitmq
  140. github.com/aleasoluciones/gochecks
  141. github.com/aleasoluciones/gosnmpquerier/examples
  142. github.com/aleasoluciones/simpleamqp
  143. github.com/alebaffa/grafana/pkg/services/eventpublisher
  144. github.com/aleicher/dgtk/amqp
  145. github.com/aleicher/dgtk/logging
  146. github.com/alex-glv/microservices-demo/worker
  147. github.com/alexandernyquist/go-passthrough
  148. github.com/alexandrevicenzi/frodo/broker
  149. github.com/alexdeefuse/cony
  150. github.com/alexgarzao/croft
  151. github.com/alexzorin/grafana/pkg/services/eventpublisher
  152. github.com/algos/mq
  153. github.com/alphagov/govuk_crawler_worker
  154. github.com/alphagov/govuk_crawler_worker/queue
  155. github.com/ameihm0912/chorizo
  156. github.com/ameihm0912/gozdef
  157. github.com/ameihm0912/mig/mig-agent
  158. github.com/ameihm0912/mig/mig-scheduler
  159. github.com/ameihm0912/mig/workers
  160. github.com/andreagrandi/go-amqp-example/consumer
  161. github.com/andreagrandi/go-amqp-example/publisher
  162. github.com/andrewwebber/cqrs/rabbit
  163. github.com/andygrunwald/gotrap/stream
  164. github.com/ant1m/picalculator/consumer
  165. github.com/antonikonovalov/benches/pubsub
  166. github.com/aristanetworks/telegraf/plugins/outputs/amqp
  167. github.com/armon/relay
  168. github.com/arnaud-lb/apns/apnscli
  169. github.com/arnaud-lb/apns/apnsclient
  170. github.com/arunk-s/mig/mig-agent
  171. github.com/arunk-s/mig/mig-scheduler
  172. github.com/arunk-s/mig/workers
  173. github.com/arvindram03/asynch-workers/rabbitmq
  174. github.com/asaif/rabbit-mq-stress-tester
  175. github.com/assembla/cony
  176. github.com/athiwatc/dingo/amqp
  177. github.com/autogrowsystems/grafana/pkg/services/eventpublisher
  178. github.com/avinash240/rabbit-mq-stress-tester/producer
  179. github.com/avinash240/rabbit-mq-stress-tester/queue
  180. github.com/axhixh/carrot
  181. github.com/axhixh/rabbitmq-experiments/common
  182. github.com/axhixh/rabbitmq-experiments/exp1
  183. github.com/axhixh/rabbitmq-experiments/exp2
  184. github.com/axhixh/rabbitmq-experiments/exp3
  185. github.com/axhixh/rabbitmq-experiments/exp4
  186. github.com/azoner/rabbitmq-tutorials/go
  187. github.com/barnjamin/spy
  188. github.com/bbangert/amqp/examples/simple-consumer
  189. github.com/bbangert/amqp/examples/simple-producer
  190. github.com/bbucko/glowing-go-code
  191. github.com/beanworks/rex/rabbit
  192. github.com/beardface/grafana/pkg/services/eventpublisher
  193. github.com/benschw/chinchilla/ep
  194. github.com/benschw/chinchilla/example/ex
  195. github.com/benschw/chinchilla/queue
  196. github.com/betacraft/scheduler/queue/rmq
  197. github.com/bg451/iron-maiden
  198. github.com/bhaisaab/hacklab/cloudstack-eventeater
  199. github.com/bifurcation/go-acme
  200. github.com/bifurcation/go-acme/anvil-start
  201. github.com/bigkevmcd/micromastro
  202. github.com/bitbored/croft
  203. github.com/bithavoc/gorch/amqpc
  204. github.com/blablacar/go-nerve/nerve
  205. github.com/blamarche/golang-rabbitmq-poc
  206. github.com/blufor/metcap
  207. github.com/boyand/typhon/rabbit
  208. github.com/bradhe/squall_worker
  209. github.com/bradleyfalzon/heka/plugins/amqp
  210. github.com/brancz/coverageanalysisworker
  211. github.com/brnstz/listen
  212. github.com/bruth/go-plugins/broker/rabbitmq
  213. github.com/bruth/go-plugins/transport/rabbitmq
  214. github.com/bscott/amqpc
  215. github.com/bsphere/celery
  216. github.com/bunsanorg/broker/go/bunsan/broker/service
  217. github.com/byorty/postmanq/cmd
  218. github.com/byorty/postmanq/consumer
  219. github.com/canthefason/relay
  220. github.com/carbonblack/cb-event-forwarder
  221. github.com/castillobg/ping/brokers/rabbit
  222. github.com/castillobg/pong/brokers/rabbit
  223. github.com/castillobgr/ping/brokers/rabbit
  224. github.com/castillobgr/pong/brokers/rabbit
  225. github.com/catalyst-zero/cores-go
  226. github.com/catalyst-zero/cores-go/example
  227. github.com/catuss-a/email-forwarder
  228. github.com/catuss-a/email-poller
  229. github.com/cenk/redialer/amqpredialer
  230. github.com/cenkalti/redialer/amqpredialer
  231. github.com/cgag/link-checker-go/rabbit
  232. github.com/cgeoffroy/telegraf/plugins/outputs/amqp
  233. github.com/ch3lo/telegraf/plugins/outputs/amqp
  234. github.com/chrisg93/grafana/pkg/services/eventpublisher
  235. github.com/chrisguiney/amqp_rest
  236. github.com/chrishoffman/go-sensu-client/gosensu
  237. github.com/chyeh/open-falcon-backend/modules/fe/mq
  238. github.com/ckolbeck/grafana/pkg/services/eventpublisher
  239. github.com/ckpt/backend-services/utils
  240. github.com/cloudaccessio/logrus/amqphook
  241. github.com/cloudnativego/drones-cmds/service
  242. github.com/cloudnativego/drones-events/service
  243. github.com/cloudnativego/rabbit-hello
  244. github.com/cloudnativego/wof-commandprocessing/service
  245. github.com/cloudwan/gohan/server
  246. github.com/cloudwatt/bunny
  247. github.com/cobraextreme/freedom_nozzle
  248. github.com/codekoala/celeriac.v1
  249. github.com/codequest-eu/octopussy/lib
  250. github.com/commesan/pacer/examples
  251. github.com/compassmarketing/telegraf/plugins/outputs/amqp
  252. github.com/compose-ex/postrabbit
  253. github.com/compose-ex/rabbitmqconns/go
  254. github.com/compose-ex/rethinkrabbit
  255. github.com/comynli/grafana/pkg/services/eventpublisher
  256. github.com/conictus/wfe
  257. github.com/coralproject/pillar/pkg/amqp
  258. github.com/corburn/boulder/analysis
  259. github.com/corburn/boulder/rpc
  260. github.com/coredump/monstrics
  261. github.com/crosserclaws/fe/mq
  262. github.com/crosserclaws/open-falcon-backend/modules/fe/mq
  263. github.com/cryptix/anvil
  264. github.com/cryptix/anvil/anvil-start
  265. github.com/cshepp/RMQTest
  266. github.com/cshepp/rmqtest
  267. github.com/ctdk/grafana/pkg/services/eventpublisher
  268. github.com/curt-labs/API/helpers/rabbitmq
  269. github.com/curt-labs/GoAPI/helpers/rabbitmq
  270. github.com/cynexit/Holmes-Gateway/gateway
  271. github.com/cynexit/Holmes-Storage
  272. github.com/cynexit/Holmes-Totem-Dynamic/check
  273. github.com/cynexit/Holmes-Totem-Dynamic/feed
  274. github.com/cynexit/Holmes-Totem-Dynamic/submit
  275. github.com/cynexit/cuckoo_distributed/check_results
  276. github.com/cynexit/cuckoo_distributed/feed_cuckoo
  277. github.com/cynexit/cuckoo_distributed/lib
  278. github.com/cynexit/cuckoo_distributed/overseer
  279. github.com/cynexit/cuckoo_distributed/parse_and_submit
  280. github.com/cyverse-de/condor-launcher
  281. github.com/cyverse-de/messaging
  282. github.com/dalent/mq/rabbit
  283. github.com/danielscottt/amqp-controller
  284. github.com/dankennedy/godispatch
  285. github.com/danslimmon/grafana/pkg/services/eventpublisher
  286. github.com/daocloud-hwu/mbus
  287. github.com/davent/telegraf/plugins/outputs/amqp
  288. github.com/declum/metrix
  289. github.com/deepglint/streamtools/st/library
  290. github.com/denderello/metrix
  291. github.com/devTransition/drone-amqp
  292. github.com/devTransition/job-go-fcgi-proxy/fcgiwork
  293. github.com/devTransition/job-go-fcgi-proxy/proxy
  294. github.com/deviozc/amqp-simplelogger
  295. github.com/divideandconquer/go-celery-api/src
  296. github.com/dmajere/go-sensu
  297. github.com/donnpebe/grafana/pkg/services/eventpublisher
  298. github.com/doubledutch/eventhorizon
  299. github.com/dsantaolalla/golang-pricechange/src
  300. github.com/dubek/rabbitmq-dump-queue
  301. github.com/dustindoiron/Hare
  302. github.com/dustindoiron/amqp/examples/simple-consumer
  303. github.com/dustindoiron/amqp/examples/simple-producer
  304. github.com/dynport/dgtk/amqp
  305. github.com/dynport/metrix
  306. github.com/e-max/pusher
  307. github.com/eazynow/go-rabbit-playground/basic
  308. github.com/eazynow/go-rabbit-playground/edge
  309. github.com/eazynow/go-rabbit-playground/microservice
  310. github.com/eferro/gochecks
  311. github.com/eferro/rabbitmqmgmt
  312. github.com/egravert/phazon
  313. github.com/elliot/grafana/pkg/services/eventpublisher
  314. github.com/elliotpeele/gosense
  315. github.com/elliotpeele/gosense/consumer
  316. github.com/emgenio/email-forwarder
  317. github.com/emgenio/email-poller
  318. github.com/entropyx/rabbitgo
  319. github.com/erans/go-celery
  320. github.com/erlendr/resizer
  321. github.com/espang/examples/go/rabbitmq
  322. github.com/espang/examples/go/rabbitmq/helloworld/get
  323. github.com/espang/examples/go/rabbitmq/helloworld/send
  324. github.com/ethervoid/gluttony/connector
  325. github.com/euforia/spinal-cord/nurv
  326. github.com/euforia/spinal-cord/nurv/libs
  327. github.com/eventials/frodo/broker
  328. github.com/evermax/stargraph/lib/mq
  329. github.com/evolsnow/machinery/v1/backends
  330. github.com/evolsnow/machinery/v1/brokers
  331. github.com/exekias/metric-collector/queue
  332. github.com/f1yegor/grafana/pkg/services/eventpublisher
  333. github.com/farmer-project/farmer-cli/hub
  334. github.com/farmer-project/farmer/hub
  335. github.com/fatih/amqp-examples
  336. github.com/fire/heka/plugins/amqp
  337. github.com/flipendo/flipendo-worker
  338. github.com/flower-pot/coverageanalysisworker
  339. github.com/garo/orbitcontrol/containrunner
  340. github.com/gertv/grafana/pkg/services/eventpublisher
  341. github.com/getroadmap/rabbitmq-go-poc
  342. github.com/ghetzel/qcat
  343. github.com/gincorp/gin/node
  344. github.com/giulioungaretti/coelho
  345. github.com/glestaris/gofigure/providers/rabbitmq
  346. github.com/go-amqprpc/amqprpc
  347. github.com/goaid/god
  348. github.com/gocardless/amqpc
  349. github.com/godfried/impendulo/processor/mq
  350. github.com/gofort/dispatcher
  351. github.com/goinstant/delayd
  352. github.com/gpitfield/gq/lib/rabbitmq
  353. github.com/grafana/grafana/pkg/services/eventpublisher
  354. github.com/grnet/webconf-manager
  355. github.com/grodowski/octopussy
  356. github.com/gsempe/apns/apnscli
  357. github.com/gsempe/apns/apnsclient
  358. github.com/guildencrantz/grafana/pkg/services/eventpublisher
  359. github.com/guilhem/bunny
  360. github.com/guillaumewuip/console_scribeAmqp.go
  361. github.com/gummiboll/grafana/pkg/services/eventpublisher
  362. github.com/gwik/celery/amqpbackend
  363. github.com/gwik/celery/amqpconsumer
  364. github.com/gwik/celery/amqputil
  365. github.com/hackintoshrao/minio
  366. github.com/halafi/gomatch/src
  367. github.com/hamfist/amqp-tee
  368. github.com/hamfist/amqp-tee/amqp-tee
  369. github.com/hartfordfive/grafana/pkg/services/eventpublisher
  370. github.com/hartfordfive/rabbit-mq-stress-tester
  371. github.com/haruio/haru-golang-AnalysisWorker
  372. github.com/haruio/haru-golang-EmailServer
  373. github.com/haruio/haru-golang-MongoDBExport
  374. github.com/heryvictor/sysdist-server/rabbit
  375. github.com/hirolovesbeer/golang-memo
  376. github.com/hlandau/degoutils/net/amqprpc
  377. github.com/hongster/message-forwarder
  378. github.com/hongster/message-forwarder/worker
  379. github.com/hyperboloide/dispatch
  380. github.com/hyperboloide/dispatch/amqp
  381. github.com/ian-lewis-cs/rabbitmq-tutorials/go
  382. github.com/ibmendoza/armor/examples/armor-producer
  383. github.com/ibmendoza/dgtk/amqp
  384. github.com/ibukanov/boulder/rpc
  385. github.com/idcrosby/microservices-demo/sockshop/worker
  386. github.com/ilgooz/cap
  387. github.com/ilgooz/rabbitmq
  388. github.com/ilgooz/rabbitmq/examples
  389. github.com/ilgooz/samqp
  390. github.com/ilgooz/samqp/example
  391. github.com/ilgooz/xamqp
  392. github.com/imjoshholloway/platform/client
  393. github.com/imjoshholloway/platform/raven
  394. github.com/imjoshholloway/platform/server
  395. github.com/index0h/go-porter
  396. github.com/index0h/go-porter/example
  397. github.com/index0h/go-porter/message
  398. github.com/index0h/go-porter/porter
  399. github.com/influxdata/telegraf/plugins/outputs/amqp
  400. github.com/influxdb/telegraf/plugins/outputs/amqp
  401. github.com/intelsdi-x/snap-plugin-publisher-rabbitmq/rmq
  402. github.com/it-man-cn/go-acs/acs
  403. github.com/ivanfoo/grafana/pkg/services/eventpublisher
  404. github.com/jacobgreenleaf/grafana/pkg/services/eventpublisher
  405. github.com/jaehue/anyq
  406. github.com/jakedahn/thingschange/producer
  407. github.com/jakedahn/thingschange/worker
  408. github.com/jameswei/anyq
  409. github.com/jansplichal/commander/queue
  410. github.com/jansplichal/commander/scrap
  411. github.com/jasonrichardsmith/microservices-demo/sockshop/worker
  412. github.com/jaxi/dj/client
  413. github.com/jaxi/dj/server
  414. github.com/jbking/gohan/server
  415. github.com/jbochi/heka/pipeline
  416. github.com/jeffbmartinez/grafana/pkg/services/eventpublisher
  417. github.com/jenrik/golem
  418. github.com/jesselucas/minio
  419. github.com/jessfraz/boulder/rpc
  420. github.com/jfrazelle/boulder/rpc
  421. github.com/jhcook/miscellaneous/rabbit_mongo
  422. github.com/jianyuan/nori/amqp
  423. github.com/jianyuan/nori/transport
  424. github.com/jlabath/postamqp
  425. github.com/jmartin82/mmock/amqp
  426. github.com/jmcfarlane/grafana/pkg/services/eventpublisher
  427. github.com/jmprusi/caronte
  428. github.com/joelanford/grafana/pkg/services/eventpublisher
  429. github.com/johnworth/condor-launcher
  430. github.com/joliva-ob/rabbit-go-test
  431. github.com/jonahglover/hungry
  432. github.com/josemrobles/asset-processing-poc/api
  433. github.com/josemrobles/asset-processing-poc/worker
  434. github.com/josemrobles/data-ingestion-poc/api
  435. github.com/josemrobles/data-ingestion-poc/worker
  436. github.com/josemrobles/distributed-processing-skel/api
  437. github.com/josemrobles/distributed-processing-skel/worker
  438. github.com/josemrobles/rmq-go
  439. github.com/josepharceneaux/rabbitmq-tutorials/go
  440. github.com/joshk/travis-logs-in-go
  441. github.com/jozan/mq-worker
  442. github.com/jroimartin/rpcmq
  443. github.com/jspc/workflow-engine/node
  444. github.com/jsternberg/grafana/pkg/services/eventpublisher
  445. github.com/juliusv/grafana/pkg/services/eventpublisher
  446. github.com/justone/pmb/api
  447. github.com/jvehent/go-toybox
  448. github.com/jvehent/gozdef
  449. github.com/jvehent/mig/mig-agent
  450. github.com/jvehent/mig/mig-scheduler
  451. github.com/jvehent/mig/workers
  452. github.com/jvgutierrez/rpcmq
  453. github.com/k4s/pika/broker
  454. github.com/kaey/telegraf/plugins/outputs/amqp
  455. github.com/karamani/amqphlp
  456. github.com/kavu/AyeAye
  457. github.com/kavu/AyeAye/processor
  458. github.com/kavu/ayeaye/processor
  459. github.com/keithballdotnet/cqrs/rabbit
  460. github.com/kenshinx/amqp/examples/simple-consumer
  461. github.com/kenshinx/amqp/examples/simple-producer
  462. github.com/kf8a/raingauge-loader
  463. github.com/kirecek/celerygo
  464. github.com/kirk91/machinery/v1/backends
  465. github.com/kirk91/machinery/v1/brokers
  466. github.com/koding/broker
  467. github.com/koding/rabbitmq
  468. github.com/koding/rabbitmq/examples
  469. github.com/konjoot/benches-1/pubsub
  470. github.com/kravitz/contra_api
  471. github.com/kravitz/contra_exec
  472. github.com/kravitz/contra_lib/db
  473. github.com/kravitz/contra_mailer
  474. github.com/kumarcv/openstack-performance-test
  475. github.com/kumarcv/rabbitmq-utilities
  476. github.com/kura/grafana/pkg/services/eventpublisher
  477. github.com/kylebrandt/grafana/pkg/services/eventpublisher
  478. github.com/lagilaper/logrus_amqp
  479. github.com/laohanlinux/LearnSomething/go
  480. github.com/lasaris/gomatch/src
  481. github.com/leominov/go-web-amqp
  482. github.com/letsencrypt/anvil/rpc
  483. github.com/letsencrypt/boulder/cmd/rabbitmq-setup
  484. github.com/letsencrypt/boulder/rpc
  485. github.com/lewgun/go/Amqp
  486. github.com/lidaobing/amqp/examples/simple-consumer
  487. github.com/lidaobing/amqp/examples/simple-producer
  488. github.com/liu-rui/mq-benchmarking/benchmark/mq
  489. github.com/liudch/amqp/examples/simple-consumer
  490. github.com/liudch/amqp/examples/simple-producer
  491. github.com/liutaihua/hera/go-hera/hera
  492. github.com/liuyuhang/gocloud
  493. github.com/liuyuhang/gocloud/api
  494. github.com/ljagiello/grafana/pkg/services/eventpublisher
  495. github.com/ljagiello/telegraf/plugins/outputs/amqp
  496. github.com/lucastorri/doc-dryer/queue
  497. github.com/lukasmartinelli/pipecat
  498. github.com/lynxbat/snap-plugin-publisher-rabbitmq/rmq
  499. github.com/mackross/go-relay
  500. github.com/makarski/samodelkin/mock/amqpmock
  501. github.com/maleck13/photoProcessor/messaging
  502. github.com/maleck13/photoprocessor/messaging
  503. github.com/mandolyte/rabbitmq-tutorials/go
  504. github.com/manuelkiessling/grafana/pkg/services/eventpublisher
  505. github.com/markstory/go-consumer
  506. github.com/martinhoefling/gotosyslog
  507. github.com/mattkanwisher/microservices-book-code/queue/pubsub/pub
  508. github.com/mattkanwisher/microservices-book-code/queue/pubsub/sub
  509. github.com/mattkanwisher/microservices-book-code/queue/workqueue/push
  510. github.com/mattkanwisher/microservices-book-code/queue/workqueue/worker
  511. github.com/mattrobenolt/go-celery
  512. github.com/maxwell92/go-cf-autoscaler/producer
  513. github.com/maxwell92/go-cf-autoscaler/worker
  514. github.com/mcgodes/goworker
  515. github.com/mcgodes/goworker/examples
  516. github.com/mcilloni/go-openbaton/vnfm/amqp
  517. github.com/mcqueenorama/open-ocr
  518. github.com/md14454/telegraf/plugins/outputs/amqp
  519. github.com/mgalgs/rafty
  520. github.com/mhenderson-so/grafana/pkg/services/eventpublisher
  521. github.com/michaeldowling/neimodian/executables/node_gateway
  522. github.com/mickelsonm/GoQueue
  523. github.com/mickelsonm/go-helpers/rabbitmq
  524. github.com/micro/go-plugins/broker/rabbitmq
  525. github.com/micro/go-plugins/transport/rabbitmq
  526. github.com/microplatform-io/platform/amqp
  527. github.com/mikechack/bootstrap/rabbitmq
  528. github.com/mikif70/telegraf/plugins/outputs/amqp
  529. github.com/minio/minio/cmd
  530. github.com/miolini/amqp/examples/simple-consumer
  531. github.com/miolini/amqp/examples/simple-producer
  532. github.com/miolini/godaemon
  533. github.com/miolini/rabbitmq-graphite-tool
  534. github.com/miolini/rabbitmq-simpletcp
  535. github.com/mirdhyn/processors/input-amqp
  536. github.com/mirdhyn/processors/output-rabbitmq
  537. github.com/mission-liao/dingo/amqp
  538. github.com/mitadmin/heka/pipeline
  539. github.com/mjdilworth/consumer
  540. github.com/mkabischev/grafana/pkg/services/eventpublisher
  541. github.com/mkuzmin/telegraf/plugins/outputs/amqp
  542. github.com/mmanjoura/utm-admin-v0.8/service/server
  543. github.com/mmb/amqpcastd/amqpcast
  544. github.com/modcloth-labs/amqp-tee
  545. github.com/modcloth-labs/amqp-tee/amqp-tee
  546. github.com/modcloth-labs/phazon
  547. github.com/modcloth/amqp-tools
  548. github.com/modcloth/amqp-tools/amqp-consume-cat
  549. github.com/modcloth/amqp-tools/amqp-publish-files
  550. github.com/modcloth/amqp-tools/amqp-replay-ninja
  551. github.com/modcloth/mithril
  552. github.com/molibei/open-ocr
  553. github.com/mondough/telegraf/plugins/outputs/amqp
  554. github.com/moonshadowmobile/go_common/mq
  555. github.com/motain/amqp/examples/pubsub
  556. github.com/motain/amqp/examples/simple-consumer
  557. github.com/motain/amqp/examples/simple-producer
  558. github.com/mouadino/go-nano/transport/amqp
  559. github.com/movableink/brutus
  560. github.com/mozilla-services/heka/plugins/amqp
  561. github.com/mozilla/TLS-Observer/tools
  562. github.com/mozilla/mig/mig-agent
  563. github.com/mozilla/mig/mig-scheduler
  564. github.com/mozilla/mig/workers
  565. github.com/mozilla/tls-observatory/tools
  566. github.com/msgbox/queue
  567. github.com/msgbox/relay
  568. github.com/msgbox/relay/relay
  569. github.com/msgbox/submission-agent
  570. github.com/msgbox/submission-agent/submission_agent
  571. github.com/msgbox/workers
  572. github.com/msgbox/workers/workers
  573. github.com/mstine/go-cf-autoscaler/producer
  574. github.com/mstine/go-cf-autoscaler/worker
  575. github.com/nabeken/delayd
  576. github.com/nabeken/delayd/testutil
  577. github.com/nabil-s/rabbitmq-tutorials/go
  578. github.com/nati/gohan/server
  579. github.com/nbari/go-sandbox/rabbitmq
  580. github.com/ncode/gogix/broker
  581. github.com/neilcwilkinson/rabbit/consumer
  582. github.com/neilcwilkinson/rabbit/producer
  583. github.com/nerdalert/rabbitmq-client-it
  584. github.com/nerfmiester/gagg
  585. github.com/nerfmiester/gagg-worker
  586. github.com/netlify/messaging
  587. github.com/netlify/messaging/rabbit-client/cmd
  588. github.com/netlify/rabbit-client
  589. github.com/netlify/rabbit-client/tools
  590. github.com/nikitasmall/micro-todo/master
  591. github.com/nikitasmall/micro-todo/storage
  592. github.com/ninnemana/API/helpers/rabbitmq
  593. github.com/nirbhayc/grafana/pkg/services/eventpublisher
  594. github.com/nitro/heka/plugins/amqp
  595. github.com/nkcraddock/smsgs/queue
  596. github.com/noise/telegraf/plugins/outputs/amqp
  597. github.com/nothingelsematters7/golang_proto/producer
  598. github.com/nothingelsematters7/golang_proto/receive
  599. github.com/noxer/telegraf/plugins/outputs/amqp
  600. github.com/nvisibleinc/go-ari-library
  601. github.com/nwolber/grafana/pkg/services/eventpublisher
  602. github.com/nytlabs/streamtools/st/library
  603. github.com/obeattie/typhon/rabbit
  604. github.com/okruhlica/rabbitmq-tutorials/go
  605. github.com/opensciencegrid/gracc-collector
  606. github.com/opiuman/rabbitrun
  607. github.com/ornl-sava/l2r
  608. github.com/ottogiron/ferrariworker/processor/rabbit
  609. github.com/outbrain/grafana/pkg/services/eventpublisher
  610. github.com/pamidu/Rabbitrest
  611. github.com/pamidu/scheduler
  612. github.com/paperstreet/gothings/rabbit
  613. github.com/patito/cony
  614. github.com/patito/cony/examples/basic/producer
  615. github.com/patito/cony/examples/email/producer
  616. github.com/patito/cony/examples/web/producer
  617. github.com/patito/go-adventure/rabbitmq
  618. github.com/patyx7/telegraf/plugins/outputs/amqp
  619. github.com/paulstuart/telegraf/plugins/outputs/amqp
  620. github.com/paypal/openstack-performance-test
  621. github.com/pchojnacki/heka/pipeline
  622. github.com/pchojnacki/piper
  623. github.com/peggyl/grafana/pkg/services/eventpublisher
  624. github.com/penlook/service/module/rabit
  625. github.com/petemoore/pulse-go/pulse
  626. github.com/petemoore/tc-gecko-metrics-go
  627. github.com/phemmer/telegraf/plugins/outputs/amqp
  628. github.com/phoenix24/celery
  629. github.com/phonkee/ergoq
  630. github.com/piffio/owm/amqp
  631. github.com/pilt/grafana/pkg/services/eventpublisher
  632. github.com/pjwerneck/celery
  633. github.com/pjwerneck/go-starbuck
  634. github.com/plar/movie-service/rest
  635. github.com/plimble/kuja/broker/rabbitmq
  636. github.com/pr8kerl/telegraf/plugins/outputs/amqp
  637. github.com/pranked/queue
  638. github.com/pranked/queue/pubsub
  639. github.com/pranked/queue/rpc
  640. github.com/presbrey/http2mq/lib
  641. github.com/presbrey/mqslice
  642. github.com/presbrey/pipe2mq
  643. github.com/primait/go-bin/dlx
  644. github.com/project8/dripline/go/dripline
  645. github.com/project8/hornet/hornet
  646. github.com/promptcloud/amqp/examples/simple-consumer
  647. github.com/promptcloud/amqp/examples/simple-producer
  648. github.com/prusov/rabbitmq-cli-consumer/consumer
  649. github.com/purak/redialer/amqpredialer
  650. github.com/pydima/go-thumbnailer/tasks
  651. github.com/qianlnk/grafana/pkg/services/eventpublisher
  652. github.com/r3boot/go-rtbh/lib/amqp
  653. github.com/r3boot/logshipper/outputs
  654. github.com/rafecolton/gem-server-manager
  655. github.com/rafecolton/gem-server-manager/gsm-server
  656. github.com/raintank/raintank-apps/task-server/event
  657. github.com/raintank/worldping-api/pkg/alerting/jobqueue
  658. github.com/raintank/worldping-api/pkg/events
  659. github.com/rare/push/mq
  660. github.com/ratherdumb/grafana/pkg/services/eventpublisher
  661. github.com/ravikumar10/RabbitMq_Go
  662. github.com/rdallman/iron-maiden
  663. github.com/rday/celery
  664. github.com/reginaldosousa/telegraf/plugins/outputs/amqp
  665. github.com/reiver/turtledq
  666. github.com/relops/rmq/work
  667. github.com/remind101/amqp
  668. github.com/remydb/go_fiddles
  669. github.com/replaygaming/amqp-consumer
  670. github.com/retzkek/gracc-collector
  671. github.com/retzkek/grafana/pkg/services/eventpublisher
  672. github.com/retzkek/rabbitbeat/beater
  673. github.com/ricbra/rabbitmq-cli-consumer/consumer
  674. github.com/richardiux/rabbitmq-to-resque
  675. github.com/rikaardhosein/telegraf/plugins/outputs/amqp
  676. github.com/rjrobinson/go-powerplant
  677. github.com/rjrobinson/go-powerplant/qutils
  678. github.com/rjrobinson/go-powerplant/sensors
  679. github.com/rmorriso/metrix
  680. github.com/rmorriso/sensu-client/checks
  681. github.com/rmorriso/sensu-client/sensu
  682. github.com/robinpercy/amqpbeat-proto
  683. github.com/robinpercy/amqpbeat-proto/beat
  684. github.com/robinpercy/amqpbeat/beat
  685. github.com/robinpercy/amqpbeat/scripts
  686. github.com/robinpercy/melllvar
  687. github.com/robinpercy/melllvar/beat
  688. github.com/robinpercy/telegraf/plugins/outputs/amqp
  689. github.com/robmorgan/dgtk/amqp
  690. github.com/robmorgan/dgtk/logging
  691. github.com/rodrigosaito/amqpsender
  692. github.com/rodrigosaito/amqpworker
  693. github.com/roeepolegfiverr/gofiverr/connectors
  694. github.com/roeepolegfiverr/gofiverr/worker
  695. github.com/ronna-s/scheduler/channels
  696. github.com/rpedde/amqplib
  697. github.com/rtucker-mozilla/chorizo
  698. github.com/runcom/rmqup/consumer
  699. github.com/runner-mei/grafana/pkg/services/eventpublisher
  700. github.com/russellchadwick/xmpptoamqp
  701. github.com/rvolosatovs/ttn/amqp
  702. github.com/samuelramond/autoscaler
  703. github.com/scalegray/sg-golib/amqp
  704. github.com/sebastienfr/cony
  705. github.com/sebastienfr/cony/examples/basic/producer
  706. github.com/sebastienfr/cony/examples/email/producer
  707. github.com/sebastienfr/cony/examples/web/producer
  708. github.com/secmask/rbmassive
  709. github.com/sedarasecurity/gocbapi/serverapi
  710. github.com/seiflotfy/telegraf/plugins/outputs/amqp
  711. github.com/sent-hil/learn/rabbitmq
  712. github.com/seppestas/croft
  713. github.com/sethgrid/hart/service
  714. github.com/shanesawyer-wf/voting-machine
  715. github.com/shaogx/govuk_crawler_worker
  716. github.com/shaogx/govuk_crawler_worker/queue
  717. github.com/sheepbao/pando-cloud/pkg/queue
  718. github.com/shicky/gocelery
  719. github.com/shicky/machinery/v1/backends
  720. github.com/shicky/machinery/v1/brokers
  721. github.com/shidenggui/machinery/v1/backends
  722. github.com/shidenggui/machinery/v1/brokers
  723. github.com/shish/elasticjiffy
  724. github.com/shuaiming/grafana/pkg/services/eventpublisher
  725. github.com/sideb0ard/Craxx
  726. github.com/sideb0ard/Kingpin
  727. github.com/silentfl/bycode
  728. github.com/silentfl/bycode/tools
  729. github.com/sinopower/push/mq
  730. github.com/skbkontur/csp_reporter
  731. github.com/skbkontur/cspreport/amqp
  732. github.com/slok/celery-go/celery/broker
  733. github.com/smallfish/rabbitmq-http
  734. github.com/smartystreets/pipeline/messaging/rabbit
  735. github.com/smartystreets/pipeline/messaging/rabbit/mq
  736. github.com/snormore/go.io/consumer/transport
  737. github.com/solarcity/ftb/publishers
  738. github.com/solarcity/ftb_milestoneapi/services
  739. github.com/solarcity/ftb_task-api/services
  740. github.com/solarcity/ftb_timelineservice/rabbitmq-receive
  741. github.com/solarcity/ftb_timelineservice/rabbitmq-send
  742. github.com/solarcity/ftb_wqservice/services
  743. github.com/soma5mbaas/haru-golang-AnalysisWorker
  744. github.com/soma5mbaas/haru-golang-EmailServer
  745. github.com/soma5mbaas/haru-golang-MongoDBExport
  746. github.com/soma5mbaas/haru-golang-helpcenter/src/controllers
  747. github.com/soma5mbaas/haru-golang-helpcenter/src/models
  748. github.com/soma5mbaas/schemaworker
  749. github.com/soma5mbaas/writeworker
  750. github.com/souled3000/base/rmqs
  751. github.com/soundtrackyourbrand/gaeamqp
  752. github.com/soundtrackyourbrand/rabbit
  753. github.com/st3v/cfkit/service
  754. github.com/st3v/go-plugins/broker/rabbitmq
  755. github.com/st3v/go-plugins/transport/rabbitmq
  756. github.com/straumur/amqpfeed
  757. github.com/subuk/rabbitmq-dump-queue
  758. github.com/supershal/telegraf/plugins/outputs/amqp
  759. github.com/tangentspace/telegraf-cloudwatch-plugin/outputs/amqp
  760. github.com/taoh/gocelery/broker/rabbitmq
  761. github.com/taskcluster/pulse-go
  762. github.com/taskcluster/pulse-go/pulse
  763. github.com/taskcluster/pulse-go/pulsesniffer
  764. github.com/tcard/amqptest
  765. github.com/terryh/mq-benchmarking/benchmark/mq
  766. github.com/tgermain/telegraf/plugins/outputs/amqp
  767. github.com/tgulacsi/rpi/amqpc
  768. github.com/thejsj/enco/server
  769. github.com/thejsj/enco/worker
  770. github.com/thethingsnetwork/croft
  771. github.com/thethingsnetwork/jolie
  772. github.com/thetonymaster/go-ios-notification-server/channels
  773. github.com/thoj/grafana/pkg/services/eventpublisher
  774. github.com/tiabc/amqp-http-benchmark/GoHttpServer
  775. github.com/tiago4orion/wabbit/amqp
  776. github.com/tiago4orion/wabbit/utils
  777. github.com/tleyden/open-ocr
  778. github.com/tlrx/heka/pipeline
  779. github.com/toddproject/todd/comms
  780. github.com/tombooth/masterslave
  781. github.com/tompao/telegraf/plugins/outputs/amqp
  782. github.com/tonyluj/grafana/pkg/services/eventpublisher
  783. github.com/torkale/amqp/examples/simple-consumer
  784. github.com/torkale/amqp/examples/simple-producer
  785. github.com/torkale/go_ahead/facebook_service
  786. github.com/tracyde/cf-powerhour/cf-consumer
  787. github.com/tracyde/cf-powerhour/cf-producer
  788. github.com/travis-ci/worker
  789. github.com/trevorprater/machinery/v1
  790. github.com/tristanls/boulder/rpc
  791. github.com/tsaikd/gogstash/output/amqp
  792. github.com/tsingson/grafana/pkg/services/eventpublisher
  793. github.com/turn/grafana/pkg/services/eventpublisher
  794. github.com/tylertreat/Flotilla/flotilla-server/daemon/broker/amqp
  795. github.com/tylertreat/bench/requester
  796. github.com/tylertreat/mq-benchmarking/benchmark/mq
  797. github.com/ujanssen/learning-go-lang/rabbitmq/receive
  798. github.com/ujanssen/learning-go-lang/rabbitmq/send
  799. github.com/upfluence/sensu-coreos/clients/sensu-thrift-client
  800. github.com/upfluence/thrift-amqp-go/amqp_thrift
  801. github.com/urjitbhatia/rabbitbeans/rabbit
  802. github.com/vCabbage/todd/comms
  803. github.com/vanillahsu/telegraf/plugins/outputs/amqp
  804. github.com/vcabbage/todd/comms
  805. github.com/veino/processors/input-rabbitmq
  806. github.com/veino/processors/output-rabbitmq
  807. github.com/veino/veino/processors/input-rabbitmq
  808. github.com/veino/veino/processors/output-rabbitmq
  809. github.com/vermoudakias/mgpsrv/empty-queue
  810. github.com/vermoudakias/mgpsrv/fill-queue
  811. github.com/vertexclique/grafana/pkg/services/eventpublisher
  812. github.com/vexor/ssh-proxy/agent
  813. github.com/vexor/ssh-proxy/server
  814. github.com/vgarvardt/rabbit-mq-stress-tester
  815. github.com/vibhavp/amqp-rpc
  816. github.com/viki-org/amqp/examples/simple-consumer
  817. github.com/viki-org/amqp/examples/simple-producer
  818. github.com/viktorasm/grafana/pkg/services/eventpublisher
  819. github.com/vincentcr/tormgr
  820. github.com/vladoatanasov/logrus_amqp
  821. github.com/vsayer/pipecat
  822. github.com/vvv-v13/go-snippets
  823. github.com/vwiart/crawler
  824. github.com/vwiart/crawler/crawler
  825. github.com/vwiart/crawler/rabbitmq
  826. github.com/vwiart/rabbitmq-client
  827. github.com/waieez/mdth/api
  828. github.com/waieez/mdth/fetcher
  829. github.com/wangbinxiang/rabbitmq-http
  830. github.com/wdxxs2z/go-cf-autoscaler/producer
  831. github.com/wdxxs2z/go-cf-autoscaler/worker
  832. github.com/weave-lab/phone-system-tests/registrar
  833. github.com/weppos/boulder/rpc
  834. github.com/wheelcomplex/amqpc
  835. github.com/williambailey/cony
  836. github.com/wolfeidau/punter
  837. github.com/wricardo/rabbitevent
  838. github.com/wricardo/rabbitworker
  839. github.com/wuhp/examples/go/mbus
  840. github.com/wuhp/rabbitmq-tutorials/go
  841. github.com/xbarrufet/QueueLibrary
  842. github.com/xbarrufet/gotasksimple
  843. github.com/xert/telegraf/plugins/outputs/amqp
  844. github.com/xianmau/heka/plugins/amqp
  845. github.com/xozrc/eventsourcing/messaging/rabbitmq
  846. github.com/xsandr/notifier
  847. github.com/xuyi/heka/plugins/amqp
  848. github.com/yeahnoob/grafana/pkg/services/eventpublisher
  849. github.com/yetis-br/tp-server/apigateway
  850. github.com/yetis-br/tp-server/mq
  851. github.com/yext/grafana/pkg/services/eventpublisher
  852. github.com/yml/degoutils/net/amqprpc
  853. github.com/yokoi-h/gohan/server
  854. github.com/yookoala/boulder/rpc
  855. github.com/zbindenren/telegraf/plugins/outputs/amqp
  856. github.com/zdavep/dozer/proto/amqp
  857. github.com/zensqlmonitor/grafana/pkg/services/eventpublisher
  858. github.com/zensqlmonitor/telegraf/plugins/outputs/amqp
  859. github.com/zerosvc/go-zerosvc
  860. github.com/zhengzhiren/gibbon/mq
  861. github.com/zhengzhiren/push/mq
  862. github.com/zstyblik/grafana/pkg/services/eventpublisher
  863. github.com/zubairhamed/croft
  864. gopkg.in/amqprpc.v0
  865. gopkg.in/entropyx/rabbitgo.v0
  866. gopkg.in/entropyx/rabbitgo.v1
  867. gopkg.in/jmartin82/mmock.v1/amqp
  868. gopkg.in/mbogus/amqprpc.v0
  869. gopkg.in/mozilla-services/heka.v0/plugins/amqp

Imported only in test by 115 package(s)

  1. github.com/2nd/amqp
  2. github.com/BenChapman/rabbit-hole
  3. github.com/ChannelMeter/amqp
  4. github.com/CrowdSurge/amqp
  5. github.com/HailoOSS/config-service/handler
  6. github.com/HailoOSS/go-hailo-lib/localisation
  7. github.com/Ryanair/amqp
  8. github.com/StephaneP/amqp
  9. github.com/TeamFairmont/amqp
  10. github.com/Wayt/amqp
  11. github.com/abrander/amqp
  12. github.com/adjust/amqp
  13. github.com/aheuermann/amqp
  14. github.com/akrennmair/amqp
  15. github.com/alanchchen/dockertest
  16. github.com/aleasoluciones/amqp
  17. github.com/alexzorin/amqp
  18. github.com/bbangert/amqp
  19. github.com/benchapman/rabbit-hole
  20. github.com/benschw/chinchilla
  21. github.com/bfitzsimmons/amqp
  22. github.com/bookerzzz/amqp
  23. github.com/c-datculescu/amqp
  24. github.com/cbandy/amqp
  25. github.com/cenk/amqp
  26. github.com/cenkalti/amqp
  27. github.com/channelmeter/amqp
  28. github.com/chenyf/amqp
  29. github.com/citysir/amqp
  30. github.com/crowdsurge/amqp
  31. github.com/daemonl/amqp
  32. github.com/dlsniper/amqp
  33. github.com/dmarkham/amqp
  34. github.com/dochong/amqp
  35. github.com/dustindoiron/amqp
  36. github.com/eimugray/amqp
  37. github.com/elmacnifico/amqp
  38. github.com/evanphx/amqp
  39. github.com/frankshearar/amqp
  40. github.com/fyec/amqp
  41. github.com/gonkulator/rabbit-hole
  42. github.com/gonuts/amqp
  43. github.com/grrtrr/amqp
  44. github.com/gwik/amqp
  45. github.com/hagna/amqp
  46. github.com/henrylee2cn/amqp
  47. github.com/hsinhoyeh/dockertest
  48. github.com/ibrt/dockertest
  49. github.com/imkira/amqp
  50. github.com/it-man-cn/amqp
  51. github.com/jaehue/anyq/benchmark
  52. github.com/jaggerwang/dockertest
  53. github.com/jaimegildesagredo/amqp
  54. github.com/jameswei/anyq/benchmark
  55. github.com/jasonmoo/amqp
  56. github.com/jcscottiii/dockertest
  57. github.com/jefferai/dockertest
  58. github.com/jeffjenkins/dispatchd/server
  59. github.com/jerome-laforge/dockertest
  60. github.com/joshk/amqp
  61. github.com/judg3/amqp
  62. github.com/karlseguin/amqp
  63. github.com/kenshinx/amqp
  64. github.com/kolonse/amqp
  65. github.com/lagilaper/amqp
  66. github.com/lasithasenanayake/v6engine-deps/github.com/streadway/amqp
  67. github.com/launchdarkly/amqp
  68. github.com/lidaobing/amqp
  69. github.com/lifeibo/amqp
  70. github.com/linkomnia/amqp
  71. github.com/liudch/amqp
  72. github.com/maddyonline/amqp
  73. github.com/massiveart/amqp
  74. github.com/mattlaver/amqp
  75. github.com/mfycheng/dockertest
  76. github.com/michaelklishin/rabbit-hole
  77. github.com/miko-code/dockertest
  78. github.com/miolini/amqp
  79. github.com/motain/amqp
  80. github.com/mouadino/amqp
  81. github.com/ncodes/golang-amqp-sample
  82. github.com/okmeter/rabbit-hole
  83. github.com/ory-am/dockertest
  84. github.com/ovr/amqp
  85. github.com/petemoore/generic-worker
  86. github.com/petemoore/taskcluster-client-go/queueevents
  87. github.com/phonkee/amqp
  88. github.com/pifuguoshi/amqp
  89. github.com/pnordahl/amqp
  90. github.com/promptcloud/amqp
  91. github.com/relops/amqp
  92. github.com/relops/rabbit-hole
  93. github.com/rjammala/amqp
  94. github.com/shuc324/amqp
  95. github.com/stephanep/amqp
  96. github.com/stormasm/amqp
  97. github.com/sudorandom/amqp
  98. github.com/superkkt/amqp
  99. github.com/takecy/dockertest
  100. github.com/taskcluster/taskcluster-client-go/queueevents
  101. github.com/tompao/amqp
  102. github.com/torkale/amqp
  103. github.com/totherme/rabbit-hole
  104. github.com/ttthzy/amqp
  105. github.com/vektra/amqp
  106. github.com/velocity-toolkit/amqp
  107. github.com/videolabs/amqp
  108. github.com/viki-org/amqp
  109. github.com/viniciusfeitosa/dockertest
  110. github.com/w3hacker/amqp
  111. github.com/wayt/amqp
  112. github.com/wheelcomplex/amqp
  113. github.com/zhangpeihao/amqp
  114. gopkg.in/ory-am/dockertest.v2
  115. gopkg.in/streadway/amqp.v0