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

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