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 1100 package(s)

  1. git.adverplex.com/cogo/banksy.git/pacer
  2. github.com/0neSe7en/Rabbit-Go
  3. github.com/0neSe7en/Rabbit-Go/Base
  4. github.com/0neSe7en/Rabbit-Go/workers
  5. github.com/2tvenom/machinery/v1/backends
  6. github.com/2tvenom/machinery/v1/brokers
  7. github.com/3onyc/docker-events-amqp
  8. github.com/6xiao/go/Amqp
  9. github.com/9466/heka/plugins/amqp
  10. github.com/AALEKH/heka/plugins/amqp
  11. github.com/AVOXI/go-ari-library
  12. github.com/AdOnWeb/postmanq/cmd
  13. github.com/AdOnWeb/postmanq/consumer
  14. github.com/Afrostream/afrostream-gostats
  15. github.com/AirHelp/rabbit-amazon-forwarder/rabbitmq
  16. github.com/AlexanderThaller/grafana/pkg/services/eventpublisher
  17. github.com/AristaNetworks/telegraf/plugins/inputs/amqp_consumer
  18. github.com/AristaNetworks/telegraf/plugins/outputs/amqp
  19. github.com/Assembla/cony
  20. github.com/Assembla/cony/examples/basic/producer
  21. github.com/Assembla/cony/examples/email/producer
  22. github.com/Assembla/cony/examples/web/producer
  23. github.com/AutogrowSystems/grafana/pkg/services/eventpublisher
  24. github.com/B2BFamily/rmq
  25. github.com/BBerastegui/rpcmq
  26. github.com/Bitbored/croft
  27. github.com/BnLCr/grafana/pkg/services/eventpublisher
  28. github.com/BnLCr/telegraf/plugins/outputs/amqp
  29. github.com/BrightLocal/amqp-rpc
  30. github.com/Cepave/fe/mq
  31. github.com/Cepave/open-falcon-backend/modules/fe/mq
  32. github.com/CodeCollaborate/Server/modules/rabbitmq
  33. github.com/CrowdSurge/amqp/examples/pubsub
  34. github.com/CrowdSurge/amqp/examples/simple-consumer
  35. github.com/CrowdSurge/amqp/examples/simple-producer
  36. github.com/CuriousLLC/celery
  37. github.com/DArcops/first-Queue-with-RabbitMQ
  38. github.com/DECK36/go-amqp2gelf
  39. github.com/DECK36/go-log2amqp
  40. github.com/Dal-Papa/go-the0v3n-microservice/server
  41. github.com/Dal-Papa/microservices-hackathon-october-2014/storage/server
  42. github.com/Danceiny/gocelery
  43. github.com/DanielHeckrath/go-micro/broker/rabbitmq
  44. github.com/DanielHeckrath/go-micro/transport/rabbitmq
  45. github.com/Dataman-Cloud/health_checker
  46. github.com/Dataman-Cloud/heka/plugins/amqp
  47. github.com/DaveBlooman/telegraf/plugins/outputs/amqp
  48. github.com/DispatchMe/cony
  49. github.com/DmitryBugrov/backup/AdminAgent/com
  50. github.com/DuoSoftware/DVP-ARDSLiteRoutingEngine/ArdsLiteRoutingEngine
  51. github.com/Eazynow/go-rabbit-playground/basic
  52. github.com/Eazynow/go-rabbit-playground/edge
  53. github.com/Eazynow/go-rabbit-playground/microservice
  54. github.com/Everlane/fluffle-go
  55. github.com/FX-HAO/subscriber
  56. github.com/FacepunchProgrammers/bridge-slack
  57. github.com/Fersca/Go-practice/dockerExample
  58. github.com/Fiery/heka/plugins/amqp
  59. github.com/Financial-Times/adobe-project-creator
  60. github.com/Fortiz2305/rabbitmq-tutorials/go
  61. github.com/Fumon/qs-webdaemons/test
  62. github.com/Fumon/qs-webdaemons/weighscale
  63. github.com/GiterLab/rmq
  64. github.com/HailoOSS/platform/client
  65. github.com/HailoOSS/platform/raven
  66. github.com/HailoOSS/platform/server
  67. github.com/HolmesProcessing/Holmes-Gateway/gateway
  68. github.com/HolmesProcessing/Holmes-Storage
  69. github.com/HolmesProcessing/Holmes-Storage/amqp
  70. github.com/HolmesProcessing/Holmes-Totem-Dynamic/check
  71. github.com/HolmesProcessing/Holmes-Totem-Dynamic/feed
  72. github.com/HolmesProcessing/Holmes-Totem-Dynamic/lib
  73. github.com/HolmesProcessing/Holmes-Totem-Dynamic/submit
  74. github.com/Igneous/orc-agent
  75. github.com/Inflatablewoman/cqrs/rabbit
  76. github.com/IntelliQru/webgo-modules
  77. github.com/JKolios/elasticgin
  78. github.com/JKolios/elasticgin/api
  79. github.com/JKolios/elasticgin/rabbitmq
  80. github.com/JStech/heka/plugins/amqp
  81. github.com/Jeffail/benthos/lib/input/reader
  82. github.com/Jeffail/benthos/lib/output
  83. github.com/Jkolios/elasticgin
  84. github.com/Jkolios/elasticgin/api
  85. github.com/Jkolios/elasticgin/rabbitmq
  86. github.com/JoshuaJessery/amqp-go-client/amqp
  87. github.com/Kaey/telegraf/plugins/outputs/amqp
  88. github.com/Kane-Sendgrid/amqpc
  89. github.com/KushalP/heka/plugins/amqp
  90. github.com/LTD-Beget/cony
  91. github.com/Lobaro/ttn/amqp
  92. github.com/MajorMJR/pingo
  93. github.com/MajorMJR/pingo/server
  94. github.com/MartyMacGyver/rabbit-mq-stress-tester
  95. github.com/Mierdin/todd/comms
  96. github.com/NJUST-FishTeam/go-judgenode
  97. github.com/NathanielMichael/telegraf/plugins/outputs/amqp
  98. github.com/NeowayLabs/wabbit/amqp
  99. github.com/NeowayLabs/wabbit/utils
  100. github.com/NikitaSmall/micro-todo/master
  101. github.com/NikitaSmall/micro-todo/storage
  102. github.com/Nitro/heka/plugins/amqp
  103. github.com/NixM0nk3y/heka/plugins/amqp
  104. github.com/Noxer/telegraf/plugins/outputs/amqp
  105. github.com/OGNITIO/telegraf/outputs/amqp
  106. github.com/OlivierBoucher/go-tracking-server
  107. github.com/OlivierBoucher/go-tracking-server/processor
  108. github.com/OlivierBoucher/go-tracking-server/queues
  109. github.com/Onefootball/samodelkin/mock/amqpmock
  110. github.com/OwnLocal/heka/plugins/amqp
  111. github.com/PandoCloud/pando-cloud/pkg/queue
  112. github.com/Qlean/silvia/silvia
  113. github.com/RackHD/neighborhood-manager/rackhd/models
  114. github.com/RichardKnop/machinery/v1/backends
  115. github.com/RichardKnop/machinery/v1/brokers
  116. github.com/RichardKnop/machinery/v1/common
  117. github.com/RidgeA/amqp-rpc/transport
  118. github.com/RobAWilkinson/rabbit-test/database
  119. github.com/Sam-Izdat/amqp-rpc-test/demo
  120. github.com/SamuelRamond/autoscaler
  121. github.com/Sergeo17/basicgo/publishers
  122. github.com/Shop2market/mq-benchmarking/benchmark/mq
  123. github.com/ShowMax/gogstash/output/amqp
  124. github.com/ShowMax/logfan-processors/input-amqp
  125. github.com/SokoloffA/telegraf/outputs/amqp
  126. github.com/SolarCity/ftb/publishers
  127. github.com/SolarCity/ftb_milestoneapi/services
  128. github.com/SolarCity/ftb_task-api/services
  129. github.com/SolarCity/ftb_timelineservice/rabbitmq-receive
  130. github.com/SolarCity/ftb_timelineservice/rabbitmq-send
  131. github.com/SolarCity/ftb_wqservice/services
  132. github.com/SpirentOrion/telegraf/plugins/outputs/amqp
  133. github.com/SummitRoute/srepp_server/CallbackServer/system
  134. github.com/SumoLogic/grafana/pkg/services/eventpublisher
  135. github.com/TF2Stadium/Fumble/mumble
  136. github.com/TF2Stadium/Fumble/rpc
  137. github.com/TF2Stadium/Helen/helpers
  138. github.com/TF2Stadium/Helen/models/rpc
  139. github.com/TF2Stadium/Pauling/rpc
  140. github.com/TF2Stadium/Pauling/server
  141. github.com/TF2Stadium/Server/helpers
  142. github.com/TF2Stadium/Server/models/rpc
  143. github.com/TF2Stadium/fumble/mumble
  144. github.com/TF2Stadium/fumble/rpc
  145. github.com/TF2Stadium/twitchbot/rpc
  146. github.com/TheThingsNetwork/croft
  147. github.com/TheThingsNetwork/gateway-connector-bridge/backend/amqp
  148. github.com/TheThingsNetwork/jolie
  149. github.com/TheThingsNetwork/ttn/amqp
  150. github.com/TjiffTjoff/go-alive
  151. github.com/TjiffTjoff/go-alive-service
  152. github.com/TjiffTjoff/go-sensu
  153. github.com/TjiffTjoff/go-sensu-service
  154. github.com/Velrok/postbote
  155. github.com/Wattpad/finn
  156. github.com/Weebly/Hare
  157. github.com/Winiex/heka/plugins/amqp
  158. github.com/a3linux/celery
  159. github.com/abdullin/heka/plugins/amqp
  160. github.com/abhijitiitr/govuk_crawler_worker
  161. github.com/abhijitiitr/govuk_crawler_worker/queue
  162. github.com/abhisheksugandhi/metering
  163. github.com/achilleasa/usrv-amqp-transport
  164. github.com/achilleasa/usrv-service-adapters/service/amqp
  165. github.com/achilleasa/usrv-v0/transport
  166. github.com/achilleasa/usrv/transport/amqp
  167. github.com/actionpay/postmanq/cmd
  168. github.com/actionpay/postmanq/consumer
  169. github.com/adamreeve/comments-app-go-rabbit-react
  170. github.com/adamreeve/comments-app-go-rabbit-react/message-queue
  171. github.com/adamweiner/boa
  172. github.com/adquality/negroniamqp
  173. github.com/ae6rt/healthchecks
  174. github.com/afajl/heka/plugins/amqp
  175. github.com/afking/rrpc
  176. github.com/afxcn/boulder/rpc
  177. github.com/agocs/golangRabbitMQ/examples
  178. github.com/agocs/queuesPresentation/examples
  179. github.com/ahjdzx/amqpc
  180. github.com/aleasoluciones/go-spikes/amqp
  181. github.com/aleasoluciones/go-spikes/rabbitmq
  182. github.com/aleasoluciones/gochecks
  183. github.com/aleasoluciones/gosnmpquerier/examples
  184. github.com/aleasoluciones/simpleamqp
  185. github.com/alebaffa/grafana/pkg/services/eventpublisher
  186. github.com/aleicher/dgtk/amqp
  187. github.com/aleicher/dgtk/logging
  188. github.com/alex-glv/microservices-demo/worker
  189. github.com/alexandernyquist/go-passthrough
  190. github.com/alexandrevicenzi/frodo/broker
  191. github.com/alexandrevicenzi/goevents/amqp
  192. github.com/alexdeefuse/cony
  193. github.com/alexgarzao/croft
  194. github.com/alexzorin/grafana/pkg/services/eventpublisher
  195. github.com/algos/mq
  196. github.com/almasry/amqp-client
  197. github.com/alphagov/govuk_crawler_worker
  198. github.com/alphagov/govuk_crawler_worker/queue
  199. github.com/ameihm0912/chorizo
  200. github.com/ameihm0912/gozdef
  201. github.com/ameihm0912/mig/mig-agent
  202. github.com/ameihm0912/mig/mig-scheduler
  203. github.com/ameihm0912/mig/workers
  204. github.com/andreagrandi/go-amqp-example/consumer
  205. github.com/andreagrandi/go-amqp-example/publisher
  206. github.com/andreiavrammsd/go-rabbitmq
  207. github.com/andrewwebber/cqrs/rabbit
  208. github.com/andygrunwald/gotrap/stream
  209. github.com/ant1m/picalculator/consumer
  210. github.com/antonikonovalov/benches/pubsub
  211. github.com/anynines/a9s-rabbitmq-app
  212. github.com/aranair/heka/plugins/amqp
  213. github.com/aristanetworks/telegraf/plugins/inputs/amqp_consumer
  214. github.com/aristanetworks/telegraf/plugins/outputs/amqp
  215. github.com/armon/relay
  216. github.com/arnaud-lb/apns/apnscli
  217. github.com/arnaud-lb/apns/apnsclient
  218. github.com/arunk-s/mig/mig-agent
  219. github.com/arunk-s/mig/mig-scheduler
  220. github.com/arunk-s/mig/workers
  221. github.com/arvindram03/asynch-workers/rabbitmq
  222. github.com/asaif/rabbit-mq-stress-tester
  223. github.com/assembla/cony
  224. github.com/asticode/go-astiamqp
  225. github.com/athiwatc/dingo/amqp
  226. github.com/att/gopkgs/rabbit_hole
  227. github.com/autogrowsystems/grafana/pkg/services/eventpublisher
  228. github.com/avinash240/rabbit-mq-stress-tester/producer
  229. github.com/avinash240/rabbit-mq-stress-tester/queue
  230. github.com/axhixh/carrot
  231. github.com/axhixh/rabbitmq-experiments/common
  232. github.com/axhixh/rabbitmq-experiments/exp1
  233. github.com/axhixh/rabbitmq-experiments/exp2
  234. github.com/axhixh/rabbitmq-experiments/exp3
  235. github.com/axhixh/rabbitmq-experiments/exp4
  236. github.com/azoner/rabbitmq-tutorials/go
  237. github.com/barnjamin/spy
  238. github.com/bartke/go-rabbitmq-hash-partitioning
  239. github.com/bbangert/amqp/examples/simple-consumer
  240. github.com/bbangert/amqp/examples/simple-producer
  241. github.com/bbucko/glowing-go-code
  242. github.com/beanworks/rex/rabbit
  243. github.com/beardface/grafana/pkg/services/eventpublisher
  244. github.com/benschw/chinchilla/ep
  245. github.com/benschw/chinchilla/example/ex
  246. github.com/benschw/chinchilla/queue
  247. github.com/betacraft/scheduler/queue/rmq
  248. github.com/bg451/iron-maiden
  249. github.com/bhaisaab/hacklab/cloudstack-eventeater
  250. github.com/bifurcation/go-acme
  251. github.com/bifurcation/go-acme/anvil-start
  252. github.com/bigkevmcd/micromastro
  253. github.com/bitbored/croft
  254. github.com/bithavoc/gorch/amqpc
  255. github.com/blablacar/go-nerve/nerve
  256. github.com/blamarche/golang-rabbitmq-poc
  257. github.com/blind-oracle/go-amqp-wrapper
  258. github.com/blufor/metcap
  259. github.com/bnlcr/grafana/pkg/services/eventpublisher
  260. github.com/bnlcr/telegraf/plugins/outputs/amqp
  261. github.com/boyand/typhon/rabbit
  262. github.com/bradhe/squall_worker
  263. github.com/bradleyfalzon/heka/plugins/amqp
  264. github.com/brancz/coverageanalysisworker
  265. github.com/breathbath/micro_consumer
  266. github.com/brettallred/go-rabbit
  267. github.com/brnstz/listen
  268. github.com/bruth/go-plugins/broker/rabbitmq
  269. github.com/bruth/go-plugins/transport/rabbitmq
  270. github.com/bscott/amqpc
  271. github.com/bsphere/celery
  272. github.com/bunsanorg/broker/go/bunsan/broker/service
  273. github.com/byorty/postmanq/cmd
  274. github.com/byorty/postmanq/consumer
  275. github.com/bysir-zl/bygo/mq
  276. github.com/caerus-platform/caerus-cli/commands
  277. github.com/caiqfrog/heka/plugins/amqp
  278. github.com/canthefason/relay
  279. github.com/carbonblack/cb-event-forwarder
  280. github.com/castillobg/ping/brokers/rabbit
  281. github.com/castillobg/pong/brokers/rabbit
  282. github.com/castillobgr/ping/brokers/rabbit
  283. github.com/castillobgr/pong/brokers/rabbit
  284. github.com/catalyst-zero/cores-go
  285. github.com/catalyst-zero/cores-go/example
  286. github.com/catuss-a/email-forwarder
  287. github.com/catuss-a/email-poller
  288. github.com/celestialstats/chatlog
  289. github.com/cenk/redialer/amqpredialer
  290. github.com/cenkalti/redialer/amqpredialer
  291. github.com/cgag/link-checker-go/rabbit
  292. github.com/cgeoffroy/telegraf/plugins/outputs/amqp
  293. github.com/ch3lo/telegraf/plugins/outputs/amqp
  294. github.com/chentao/heka/plugins/amqp
  295. github.com/cheshir/go-mq
  296. github.com/chrisg93/grafana/pkg/services/eventpublisher
  297. github.com/chrisguiney/amqp_rest
  298. github.com/chrishoffman/go-sensu-client/gosensu
  299. github.com/christianvozar/heka/plugins/amqp
  300. github.com/chyeh/open-falcon-backend/modules/fe/mq
  301. github.com/chzyer-dev/heka/plugins/amqp
  302. github.com/ckolbeck/grafana/pkg/services/eventpublisher
  303. github.com/ckpt/backend-services/utils
  304. github.com/cloudaccessio/logrus/amqphook
  305. github.com/cloudfoundry-community/gautocloud/connectors/amqp/client
  306. github.com/cloudnativego/drones-cmds/service
  307. github.com/cloudnativego/drones-events/service
  308. github.com/cloudnativego/rabbit-hello
  309. github.com/cloudnativego/wof-commandprocessing/service
  310. github.com/cloudwan/gohan/server
  311. github.com/cloudwatt/bunny
  312. github.com/cobraextreme/freedom_nozzle
  313. github.com/codekoala/celeriac.v1
  314. github.com/codequest-eu/octopussy/lib
  315. github.com/commesan/pacer/examples
  316. github.com/compassmarketing/telegraf/plugins/outputs/amqp
  317. github.com/compose-ex/postrabbit
  318. github.com/compose-ex/rabbitmqconns/go
  319. github.com/compose-ex/rethinkrabbit
  320. github.com/compose/transporter/adaptor/rabbitmq
  321. github.com/comynli/grafana/pkg/services/eventpublisher
  322. github.com/conictus/wfe
  323. github.com/coralproject/pillar/pkg/amqp
  324. github.com/corburn/boulder/analysis
  325. github.com/corburn/boulder/rpc
  326. github.com/coredump/monstrics
  327. github.com/corvus-ch/rabbitmq-cli-consumer/consumer
  328. github.com/corvus-ch/rabbitmq-cli-consumer/delivery
  329. github.com/crosserclaws/fe/mq
  330. github.com/crosserclaws/open-falcon-backend/modules/fe/mq
  331. github.com/cryptix/anvil
  332. github.com/cryptix/anvil/anvil-start
  333. github.com/cshepp/RMQTest
  334. github.com/cshepp/rmqtest
  335. github.com/ctdk/grafana/pkg/services/eventpublisher
  336. github.com/curt-labs/API/helpers/rabbitmq
  337. github.com/curt-labs/GoAPI/helpers/rabbitmq
  338. github.com/cynexit/Holmes-Gateway/gateway
  339. github.com/cynexit/Holmes-Storage
  340. github.com/cynexit/Holmes-Totem-Dynamic/check
  341. github.com/cynexit/Holmes-Totem-Dynamic/feed
  342. github.com/cynexit/Holmes-Totem-Dynamic/submit
  343. github.com/cynexit/cuckoo_distributed/check_results
  344. github.com/cynexit/cuckoo_distributed/feed_cuckoo
  345. github.com/cynexit/cuckoo_distributed/lib
  346. github.com/cynexit/cuckoo_distributed/overseer
  347. github.com/cynexit/cuckoo_distributed/parse_and_submit
  348. github.com/cyverse-de/condor-launcher
  349. github.com/cyverse-de/dataone-indexer
  350. github.com/cyverse-de/messaging
  351. github.com/dalent/mq/rabbit
  352. github.com/danielscottt/amqp-controller
  353. github.com/dankennedy/godispatch
  354. github.com/danslimmon/grafana/pkg/services/eventpublisher
  355. github.com/daocloud-hwu/mbus
  356. github.com/davent/telegraf/plugins/outputs/amqp
  357. github.com/declum/metrix
  358. github.com/deepglint/streamtools/st/library
  359. github.com/denderello/metrix
  360. github.com/devTransition/drone-amqp
  361. github.com/devTransition/job-go-fcgi-proxy/fcgiwork
  362. github.com/devTransition/job-go-fcgi-proxy/proxy
  363. github.com/devimteam/amqp
  364. github.com/devimteam/amqp/conn
  365. github.com/deviozc/amqp-simplelogger
  366. github.com/divideandconquer/go-celery-api/src
  367. github.com/dmajere/go-sensu
  368. github.com/donnpebe/grafana/pkg/services/eventpublisher
  369. github.com/doubledutch/eventhorizon
  370. github.com/drunkenfall/drunkenfall/towerfall
  371. github.com/dsantaolalla/golang-pricechange/src
  372. github.com/dubek/rabbitmq-dump-queue
  373. github.com/dustindoiron/Hare
  374. github.com/dustindoiron/amqp/examples/simple-consumer
  375. github.com/dustindoiron/amqp/examples/simple-producer
  376. github.com/dynport/dgtk/amqp
  377. github.com/dynport/metrix
  378. github.com/e-max/pusher
  379. github.com/eazynow/go-rabbit-playground/basic
  380. github.com/eazynow/go-rabbit-playground/edge
  381. github.com/eazynow/go-rabbit-playground/microservice
  382. github.com/eferro/gochecks
  383. github.com/eferro/rabbitmqmgmt
  384. github.com/egravert/phazon
  385. github.com/eleme/banshee/cluster
  386. github.com/eliothedeman/heka/plugins/amqp
  387. github.com/elliot/grafana/pkg/services/eventpublisher
  388. github.com/elliotpeele/gosense
  389. github.com/elliotpeele/gosense/consumer
  390. github.com/emgenio/email-forwarder
  391. github.com/emgenio/email-poller
  392. github.com/entropyx/rabbitgo
  393. github.com/erans/go-celery
  394. github.com/erlendr/resizer
  395. github.com/espang/examples/go/rabbitmq
  396. github.com/espang/examples/go/rabbitmq/helloworld/get
  397. github.com/espang/examples/go/rabbitmq/helloworld/send
  398. github.com/ethervoid/gluttony/connector
  399. github.com/euforia/spinal-cord/nurv
  400. github.com/euforia/spinal-cord/nurv/libs
  401. github.com/evandigby/rtb/amqp
  402. github.com/eventials/frodo/broker
  403. github.com/eventials/goevents/amqp
  404. github.com/evermax/stargraph/lib/mq
  405. github.com/evolsnow/machinery/v1/backends
  406. github.com/evolsnow/machinery/v1/brokers
  407. github.com/exekias/metric-collector/queue
  408. github.com/f1yegor/grafana/pkg/services/eventpublisher
  409. github.com/farmer-project/farmer-cli/hub
  410. github.com/farmer-project/farmer/hub
  411. github.com/fasthall/cappa/mq
  412. github.com/fatih/amqp-examples
  413. github.com/fernandezvara/heka/plugins/amqp
  414. github.com/ferrariframework/ferrariworker/processor/rabbit
  415. github.com/fire/heka/plugins/amqp
  416. github.com/flipendo/flipendo-worker
  417. github.com/flower-pot/coverageanalysisworker
  418. github.com/fmarmol/rmq
  419. github.com/funshine/heka/plugins/amqp
  420. github.com/furdarius/rabbitroutine
  421. github.com/garo/orbitcontrol/containrunner
  422. github.com/geektrust/go-mqmail
  423. github.com/gertv/grafana/pkg/services/eventpublisher
  424. github.com/getconversio/go-utils/services/amqp
  425. github.com/getroadmap/rabbitmq-go-poc
  426. github.com/getsentry/heka/plugins/amqp
  427. github.com/ghetzel/qcat
  428. github.com/ghigt/rabbitmq-delayed
  429. github.com/gincorp/gin/node
  430. github.com/giulioungaretti/coelho
  431. github.com/gkarlik/quark-go/broker/rabbitmq
  432. github.com/glestaris/gofigure/providers/rabbitmq
  433. github.com/go-amqpirq/amqpirq
  434. github.com/go-amqprpc/amqprpc
  435. github.com/goadapp/goad/infrastructure/docker
  436. github.com/goaid/god
  437. github.com/gocardless/amqpc
  438. github.com/gocelery/gocelery
  439. github.com/godfried/impendulo/processor/mq
  440. github.com/gofort/dispatcher
  441. github.com/goinstant/delayd
  442. github.com/gophergala2016/goad/infrastructure/docker
  443. github.com/gpavlidi/go-micro/broker/rabbitmq
  444. github.com/gpavlidi/go-micro/transport/rabbitmq
  445. github.com/gpitfield/gq/lib/rabbitmq
  446. github.com/grafana/grafana/pkg/services/eventpublisher
  447. github.com/graphite-ng/carbon-relay-ng/input
  448. github.com/grnet/webconf-manager
  449. github.com/grodowski/octopussy
  450. github.com/gsempe/apns/apnscli
  451. github.com/gsempe/apns/apnsclient
  452. github.com/guildencrantz/grafana/pkg/services/eventpublisher
  453. github.com/guilhem/bunny
  454. github.com/guilhermehubner/worker/broker
  455. github.com/guillaumewuip/console_scribeAmqp.go
  456. github.com/gummiboll/grafana/pkg/services/eventpublisher
  457. github.com/gushitong/gocelery
  458. github.com/gwik/celery/amqpbackend
  459. github.com/gwik/celery/amqpconsumer
  460. github.com/gwik/celery/amqputil
  461. github.com/hackerwins/rotty/server
  462. github.com/hackintoshrao/minio
  463. github.com/halafi/gomatch/src
  464. github.com/hamfist/amqp-tee
  465. github.com/hamfist/amqp-tee/amqp-tee
  466. github.com/hartfordfive/grafana/pkg/services/eventpublisher
  467. github.com/hartfordfive/rabbit-mq-stress-tester
  468. github.com/haruio/haru-golang-AnalysisWorker
  469. github.com/haruio/haru-golang-EmailServer
  470. github.com/haruio/haru-golang-MongoDBExport
  471. github.com/haruio/haru-golang-helpcenter/src/controllers
  472. github.com/haruio/haru-golang-helpcenter/src/models
  473. github.com/hassansin/amqptools/cmd
  474. github.com/heryvictor/sysdist-server/rabbit
  475. github.com/hirolovesbeer/golang-memo
  476. github.com/hlandau/degoutils/net/amqprpc
  477. github.com/hongster/message-forwarder
  478. github.com/hongster/message-forwarder/worker
  479. github.com/hourback/heka/plugins/amqp
  480. github.com/husobee/heka/plugins/amqp
  481. github.com/hynd/heka/plugins/amqp
  482. github.com/hyperboloide/dispatch
  483. github.com/hyperboloide/dispatch/amqp
  484. github.com/ian-lewis-cs/rabbitmq-tutorials/go
  485. github.com/ibmendoza/armor/examples/armor-producer
  486. github.com/ibmendoza/dgtk/amqp
  487. github.com/ibukanov/boulder/rpc
  488. github.com/idada/grafana/pkg/services/eventpublisher
  489. github.com/idcrosby/microservices-demo/sockshop/worker
  490. github.com/idkravitz/contra_api
  491. github.com/idkravitz/contra_exec
  492. github.com/idkravitz/contra_lib/db
  493. github.com/ilgooz/cap
  494. github.com/ilgooz/rabbitmq
  495. github.com/ilgooz/rabbitmq/examples
  496. github.com/ilgooz/samqp
  497. github.com/ilgooz/samqp/example
  498. github.com/ilgooz/xamqp
  499. github.com/imgix/heka/plugins/amqp
  500. github.com/imjoshholloway/platform/client
  501. github.com/imjoshholloway/platform/raven
  502. github.com/imjoshholloway/platform/server
  503. github.com/index0h/go-porter
  504. github.com/index0h/go-porter/example
  505. github.com/index0h/go-porter/message
  506. github.com/index0h/go-porter/porter
  507. github.com/influxdata/telegraf/plugins/inputs/amqp_consumer
  508. github.com/influxdata/telegraf/plugins/outputs/amqp
  509. github.com/influxdb/telegraf/plugins/inputs/amqp_consumer
  510. github.com/influxdb/telegraf/plugins/outputs/amqp
  511. github.com/intelsdi-x/snap-plugin-publisher-rabbitmq/rmq
  512. github.com/intoximeters/heka/plugins/amqp
  513. github.com/ipfs-search/ipfs-search/crawler/factory
  514. github.com/ipfs-search/ipfs-search/queue
  515. github.com/irom77/go-syslog-rabbit/rabbit
  516. github.com/it-man-cn/go-acs/acs
  517. github.com/ivanfoo/grafana/pkg/services/eventpublisher
  518. github.com/iyidan/http-proxy-amqp/pool
  519. github.com/j-musca/http-to-rabbit-golang
  520. github.com/jacobgreenleaf/grafana/pkg/services/eventpublisher
  521. github.com/jaehue/anyq
  522. github.com/jakedahn/thingschange/producer
  523. github.com/jakedahn/thingschange/worker
  524. github.com/jameswei/anyq
  525. github.com/jansplichal/commander/queue
  526. github.com/jansplichal/commander/scrap
  527. github.com/jasonrichardsmith/microservices-demo/sockshop/worker
  528. github.com/jaxi/dj/client
  529. github.com/jaxi/dj/server
  530. github.com/jbking/gohan/server
  531. github.com/jbochi/heka/pipeline
  532. github.com/jeffbmartinez/grafana/pkg/services/eventpublisher
  533. github.com/jenrik/golem
  534. github.com/jeroenjanssens/streamtools/st/library
  535. github.com/jesselucas/minio
  536. github.com/jessfraz/boulder/rpc
  537. github.com/jfrazelle/boulder/rpc
  538. github.com/jgeiger/grafana/pkg/services/eventpublisher
  539. github.com/jhcook/miscellaneous/rabbit_mongo
  540. github.com/jianyuan/nori/amqp
  541. github.com/jianyuan/nori/transport
  542. github.com/jipperinbham/telegraf/outputs/amqp
  543. github.com/jlabath/postamqp
  544. github.com/jmartin82/mmock/amqp
  545. github.com/jmcfarlane/grafana/pkg/services/eventpublisher
  546. github.com/jmprusi/caronte
  547. github.com/joelanford/grafana/pkg/services/eventpublisher
  548. github.com/johnworth/condor-launcher
  549. github.com/joliva-ob/rabbit-go-test
  550. github.com/jonahglover/hungry
  551. github.com/jondot/armor/examples/armor-producer
  552. github.com/josedonizetti/heka/plugins/amqp
  553. github.com/josemrobles/asset-processing-poc/api
  554. github.com/josemrobles/asset-processing-poc/worker
  555. github.com/josemrobles/conejo
  556. github.com/josemrobles/data-ingestion-poc/api
  557. github.com/josemrobles/data-ingestion-poc/worker
  558. github.com/josemrobles/distributed-processing-skel/api
  559. github.com/josemrobles/distributed-processing-skel/worker
  560. github.com/josemrobles/rmq-go
  561. github.com/josepharceneaux/rabbitmq-tutorials/go
  562. github.com/joshk/travis-logs-in-go
  563. github.com/jozan/mq-worker
  564. github.com/jpwilliams/go-remit
  565. github.com/jpwilliams/remit-go
  566. github.com/jroimartin/rpcmq
  567. github.com/jrxFive/telegraf/outputs/amqp
  568. github.com/jsha/boulder/cmd/rabbitmq-setup
  569. github.com/jspc/enc_mess
  570. github.com/jspc/gusha
  571. github.com/jspc/workflow-engine/node
  572. github.com/jsternberg/grafana/pkg/services/eventpublisher
  573. github.com/juliusv/grafana/pkg/services/eventpublisher
  574. github.com/justone/pmb/api
  575. github.com/jvehent/go-toybox
  576. github.com/jvehent/gozdef
  577. github.com/jvehent/mig/mig-agent
  578. github.com/jvehent/mig/mig-scheduler
  579. github.com/jvehent/mig/workers
  580. github.com/jvgutierrez/rpcmq
  581. github.com/k4s/pika/broker
  582. github.com/kaey/telegraf/plugins/outputs/amqp
  583. github.com/kakilangit/observer
  584. github.com/karamani/amqphlp
  585. github.com/karamani/amqptool
  586. github.com/katsutomu/go-event
  587. github.com/kavu/AyeAye
  588. github.com/kavu/AyeAye/processor
  589. github.com/kavu/ayeaye/processor
  590. github.com/kbudde/rabbitmq_exporter/testenv
  591. github.com/keithballdotnet/cqrs/rabbit
  592. github.com/kenshinx/amqp/examples/simple-consumer
  593. github.com/kenshinx/amqp/examples/simple-producer
  594. github.com/kevinmichaelchen/my-go-utils/rabbitmq
  595. github.com/kf8a/raingauge-loader
  596. github.com/king-jam/mq2http
  597. github.com/kirecek/celerygo
  598. github.com/kirk91/machinery/v1/backends
  599. github.com/kirk91/machinery/v1/brokers
  600. github.com/klauspost/heka/plugins/amqp
  601. github.com/koding/broker
  602. github.com/koding/rabbitmq
  603. github.com/koding/rabbitmq/examples
  604. github.com/konjoot/benches-1/pubsub
  605. github.com/kravitz/contra_api
  606. github.com/kravitz/contra_exec
  607. github.com/kravitz/contra_lib/db
  608. github.com/kravitz/contra_mailer
  609. github.com/kumarcv/openstack-performance-test
  610. github.com/kumarcv/rabbitmq-utilities
  611. github.com/kura/grafana/pkg/services/eventpublisher
  612. github.com/kylebrandt/grafana/pkg/services/eventpublisher
  613. github.com/lagilaper/logrus_amqp
  614. github.com/lann/heka/plugins/amqp
  615. github.com/laohanlinux/LearnSomething/go
  616. github.com/lasaris/gomatch/src
  617. github.com/lastbackend/rpc
  618. github.com/leandro-lugaresi/message-cannon/rabbit
  619. github.com/leominov/go-web-amqp
  620. github.com/leonsas/gocelery
  621. github.com/letsencrypt/anvil/rpc
  622. github.com/letsencrypt/boulder/cmd/rabbitmq-setup
  623. github.com/letsencrypt/boulder/rpc
  624. github.com/lewgun/go/Amqp
  625. github.com/liangdas/mqant/rpc/base
  626. github.com/lidaobing/amqp/examples/simple-consumer
  627. github.com/lidaobing/amqp/examples/simple-producer
  628. github.com/liu-rui/mq-benchmarking/benchmark/mq
  629. github.com/liudch/amqp/examples/simple-consumer
  630. github.com/liudch/amqp/examples/simple-producer
  631. github.com/liutaihua/hera/go-hera/hera
  632. github.com/liuyuhang/gocloud
  633. github.com/liuyuhang/gocloud/api
  634. github.com/ljagiello/grafana/pkg/services/eventpublisher
  635. github.com/ljagiello/telegraf/plugins/inputs/amqp_consumer
  636. github.com/ljagiello/telegraf/plugins/outputs/amqp
  637. github.com/lmx1989219/telegraf/outputs/amqp
  638. github.com/lsaint/gocelery
  639. github.com/lucastorri/doc-dryer/queue
  640. github.com/lukasmartinelli/pipecat
  641. github.com/lukebakken/rabbitmq-users-hgRmhpL8Y6o
  642. github.com/lvzhihao/go-rmqtool
  643. github.com/lynxbat/snap-plugin-publisher-rabbitmq/rmq
  644. github.com/mackross/go-relay
  645. github.com/mak73kur/qron
  646. github.com/makarski/samodelkin/mock/amqpmock
  647. github.com/maleck13/photoProcessor/messaging
  648. github.com/maleck13/photoprocessor/messaging
  649. github.com/mandolyte/rabbitmq-tutorials/go
  650. github.com/manuelkiessling/grafana/pkg/services/eventpublisher
  651. github.com/markstory/go-consumer
  652. github.com/martinhoefling/gotosyslog
  653. github.com/mattkanwisher/microservices-book-code/queue/pubsub/pub
  654. github.com/mattkanwisher/microservices-book-code/queue/pubsub/sub
  655. github.com/mattkanwisher/microservices-book-code/queue/workqueue/push
  656. github.com/mattkanwisher/microservices-book-code/queue/workqueue/worker
  657. github.com/mattrobenolt/go-celery
  658. github.com/maxwell92/go-cf-autoscaler/producer
  659. github.com/maxwell92/go-cf-autoscaler/worker
  660. github.com/mcgodes/goworker
  661. github.com/mcgodes/goworker/examples
  662. github.com/mcilloni/go-openbaton/plugin
  663. github.com/mcilloni/go-openbaton/vnfm/amqp
  664. github.com/mcilloni/openbaton-docker/cmd/mgmt-gvnfmd
  665. github.com/mcilloni/openbaton-docker/mgmt
  666. github.com/mcqueenorama/open-ocr
  667. github.com/md14454/telegraf/plugins/outputs/amqp
  668. github.com/mergermarket/run-amqp
  669. github.com/mergermarket/run-amqp/connection
  670. github.com/metaleap/go-ezmq
  671. github.com/mgalgs/rafty
  672. github.com/mhenderson-so/grafana/pkg/services/eventpublisher
  673. github.com/michaeldowling/neimodian/executables/node_gateway
  674. github.com/mickelsonm/GoQueue
  675. github.com/mickelsonm/go-helpers/rabbitmq
  676. github.com/micro/go-plugins/broker/rabbitmq
  677. github.com/micro/go-plugins/transport/rabbitmq
  678. github.com/microplatform-io/platform/amqp
  679. github.com/mikechack/bootstrap/rabbitmq
  680. github.com/mikif70/telegraf/plugins/outputs/amqp
  681. github.com/minio/minio/cmd
  682. github.com/minio/minio/pkg/event/target
  683. github.com/miolini/amqp/examples/simple-consumer
  684. github.com/miolini/amqp/examples/simple-producer
  685. github.com/miolini/godaemon
  686. github.com/miolini/rabbitmq-graphite-tool
  687. github.com/miolini/rabbitmq-simpletcp
  688. github.com/mirdhyn/processors/input-amqp
  689. github.com/mirdhyn/processors/output-rabbitmq
  690. github.com/mishudark/eventhus/eventbus/rabbitmq
  691. github.com/mission-liao/dingo/amqp
  692. github.com/mitadmin/heka/pipeline
  693. github.com/mjdilworth/consumer
  694. github.com/mkabischev/grafana/pkg/services/eventpublisher
  695. github.com/mkuzmin/telegraf/plugins/inputs/amqp_consumer
  696. github.com/mkuzmin/telegraf/plugins/outputs/amqp
  697. github.com/mmanjoura/utm-admin-v0.8/service/server
  698. github.com/mmb/amqpcastd/amqpcast
  699. github.com/modcloth-labs/amqp-tee
  700. github.com/modcloth-labs/amqp-tee/amqp-tee
  701. github.com/modcloth-labs/phazon
  702. github.com/modcloth/amqp-tools
  703. github.com/modcloth/amqp-tools/amqp-consume-cat
  704. github.com/modcloth/amqp-tools/amqp-publish-files
  705. github.com/modcloth/amqp-tools/amqp-replay-ninja
  706. github.com/modcloth/mithril
  707. github.com/moensch/fbbotscan/pubsub
  708. github.com/molibei/open-ocr
  709. github.com/mondough/telegraf/plugins/outputs/amqp
  710. github.com/monzo/telegraf/plugins/outputs/amqp
  711. github.com/moonshadowmobile/go_common/mq
  712. github.com/motain/amqp/examples/pubsub
  713. github.com/motain/amqp/examples/simple-consumer
  714. github.com/motain/amqp/examples/simple-producer
  715. github.com/mouadino/go-nano/transport/amqp
  716. github.com/movableink/brutus
  717. github.com/mozilla-services/heka/plugins/amqp
  718. github.com/mozilla/TLS-Observer/tools
  719. github.com/mozilla/mig/mig-agent
  720. github.com/mozilla/mig/mig-scheduler
  721. github.com/mozilla/mig/workers
  722. github.com/mozilla/tls-observatory/tools
  723. github.com/mrkaspa/amqputils
  724. github.com/mroote/pingo
  725. github.com/mroote/pingo/server
  726. github.com/msgbox/queue
  727. github.com/msgbox/relay
  728. github.com/msgbox/relay/relay
  729. github.com/msgbox/submission-agent
  730. github.com/msgbox/submission-agent/submission_agent
  731. github.com/msgbox/workers
  732. github.com/msgbox/workers/workers
  733. github.com/mstine/go-cf-autoscaler/producer
  734. github.com/mstine/go-cf-autoscaler/worker
  735. github.com/nabeken/delayd
  736. github.com/nabeken/delayd/testutil
  737. github.com/nabil-s/rabbitmq-tutorials/go
  738. github.com/nati/gohan/server
  739. github.com/nbari/go-sandbox/rabbitmq
  740. github.com/ncode/gogix/broker
  741. github.com/neilcwilkinson/rabbit/consumer
  742. github.com/neilcwilkinson/rabbit/producer
  743. github.com/nerdalert/rabbitmq-client-it
  744. github.com/nerfmiester/gagg
  745. github.com/nerfmiester/gagg-worker
  746. github.com/netlify/messaging
  747. github.com/netlify/messaging/rabbit-client/cmd
  748. github.com/netlify/rabbit-client
  749. github.com/netlify/rabbit-client/tools
  750. github.com/nickalie/go-queue
  751. github.com/nikitasmall/micro-todo/master
  752. github.com/nikitasmall/micro-todo/storage
  753. github.com/ninhdh0/zimo
  754. github.com/ninnemana/API/helpers/rabbitmq
  755. github.com/nirbhayc/grafana/pkg/services/eventpublisher
  756. github.com/nitro/heka/plugins/amqp
  757. github.com/nkcraddock/smsgs/queue
  758. github.com/noise/telegraf/plugins/outputs/amqp
  759. github.com/nothingelsematters7/golang_proto/producer
  760. github.com/nothingelsematters7/golang_proto/receive
  761. github.com/noxer/telegraf/plugins/outputs/amqp
  762. github.com/nvisibleinc/go-ari-library
  763. github.com/nwolber/grafana/pkg/services/eventpublisher
  764. github.com/nytlabs/streamtools/st/library
  765. github.com/obeattie/typhon/rabbit
  766. github.com/okruhlica/rabbitmq-tutorials/go
  767. github.com/olegfedoseev/amqpc
  768. github.com/openasm/openasm/listener
  769. github.com/openbaton/go-openbaton/pluginsdk
  770. github.com/openbaton/go-openbaton/sdk
  771. github.com/openbaton/go-openbaton/vnfmsdk
  772. github.com/opensciencegrid/gracc-collector
  773. github.com/opentracing-contrib/go-amqp/amqptracer
  774. github.com/opiuman/rabbitrun
  775. github.com/ornl-sava/l2r
  776. github.com/ottogiron/ferrariworker/processor/rabbit
  777. github.com/ottogiron/metricsworker/worker/rabbit
  778. github.com/outbrain/grafana/pkg/services/eventpublisher
  779. github.com/pamidu/Rabbitrest
  780. github.com/pamidu/scheduler
  781. github.com/paperstreet/gothings/rabbit
  782. github.com/patito/cony
  783. github.com/patito/cony/examples/basic/producer
  784. github.com/patito/cony/examples/email/producer
  785. github.com/patito/cony/examples/web/producer
  786. github.com/patito/go-adventure/rabbitmq
  787. github.com/patyx7/telegraf/plugins/outputs/amqp
  788. github.com/paulstuart/telegraf/plugins/outputs/amqp
  789. github.com/paypal/openstack-performance-test
  790. github.com/pchojnacki/heka/pipeline
  791. github.com/pchojnacki/piper
  792. github.com/pegasuskim/haru-golang-EmailServer
  793. github.com/peggyl/grafana/pkg/services/eventpublisher
  794. github.com/penlook/service/module/rabit
  795. github.com/petemoore/pulse-go/pulse
  796. github.com/petemoore/tc-gecko-metrics-go
  797. github.com/phemmer/telegraf/plugins/outputs/amqp
  798. github.com/phoenix24/celery
  799. github.com/phonkee/ergoq
  800. github.com/piffio/owm/amqp
  801. github.com/pilt/grafana/pkg/services/eventpublisher
  802. github.com/pjwerneck/celery
  803. github.com/pjwerneck/go-starbuck
  804. github.com/plar/movie-service/rest
  805. github.com/plimble/kuja/broker/rabbitmq
  806. github.com/porthos-rpc/porthos-go
  807. github.com/pr8kerl/telegraf/plugins/outputs/amqp
  808. github.com/pranked/queue
  809. github.com/pranked/queue/pubsub
  810. github.com/pranked/queue/rpc
  811. github.com/presbrey/http2mq/lib
  812. github.com/presbrey/mqslice
  813. github.com/presbrey/pipe2mq
  814. github.com/primait/go-bin/dlx
  815. github.com/project8/dripline-go/dripline
  816. github.com/project8/dripline/go/dripline
  817. github.com/project8/hornet/hornet
  818. github.com/promptcloud/amqp/examples/simple-consumer
  819. github.com/promptcloud/amqp/examples/simple-producer
  820. github.com/prusov/rabbitmq-cli-consumer/consumer
  821. github.com/purak/redialer/amqpredialer
  822. github.com/pydima/go-thumbnailer/tasks
  823. github.com/qianlnk/grafana/pkg/services/eventpublisher
  824. github.com/qmsk/telegraf/outputs/amqp
  825. github.com/r3boot/go-rtbh/lib/amqp
  826. github.com/r3boot/logshipper/outputs
  827. github.com/rafaeljesus/rabbus
  828. github.com/rafaeljesus/rabbus/internal/amqp
  829. github.com/rafecolton/gem-server-manager
  830. github.com/rafecolton/gem-server-manager/gsm-server
  831. github.com/raintank/raintank-apps/task-server/event
  832. github.com/raintank/worldping-api/pkg/alerting/jobqueue
  833. github.com/raintank/worldping-api/pkg/events
  834. github.com/randomtask1155/rabbitmq-pcf-example
  835. github.com/rare/push/mq
  836. github.com/ratherdumb/grafana/pkg/services/eventpublisher
  837. github.com/ravikumar10/RabbitMq_Go
  838. github.com/rdallman/iron-maiden
  839. github.com/rday/celery
  840. github.com/reginaldosousa/telegraf/plugins/outputs/amqp
  841. github.com/reiver/turtledq
  842. github.com/relops/rmq/work
  843. github.com/remind101/amqp
  844. github.com/remydb/go_fiddles
  845. github.com/replaygaming/amqp-consumer
  846. github.com/retzkek/bunnyhop
  847. github.com/retzkek/gracc-collector
  848. github.com/retzkek/grafana/pkg/services/eventpublisher
  849. github.com/retzkek/rabbitbeat/beater
  850. github.com/ricbra/rabbitmq-cli-consumer/consumer
  851. github.com/richardbowden/relay
  852. github.com/richardiux/rabbitmq-to-resque
  853. github.com/rikaardhosein/telegraf/plugins/outputs/amqp
  854. github.com/rinq/rinq-go/src/internal/functest
  855. github.com/rinq/rinq-go/src/rinqamqp
  856. github.com/rinq/rinq-go/src/rinqamqp/internal/amqputil
  857. github.com/rinq/rinq-go/src/rinqamqp/internal/commandamqp
  858. github.com/rinq/rinq-go/src/rinqamqp/internal/notifyamqp
  859. github.com/rjrobinson/go-powerplant
  860. github.com/rjrobinson/go-powerplant/qutils
  861. github.com/rjrobinson/go-powerplant/sensors
  862. github.com/rmorriso/metrix
  863. github.com/rmorriso/sensu-client/checks
  864. github.com/rmorriso/sensu-client/sensu
  865. github.com/roamz/gocelery
  866. github.com/robinpercy/amqpbeat-proto
  867. github.com/robinpercy/amqpbeat-proto/beat
  868. github.com/robinpercy/amqpbeat/beat
  869. github.com/robinpercy/amqpbeat/scripts
  870. github.com/robinpercy/melllvar
  871. github.com/robinpercy/melllvar/beat
  872. github.com/robinpercy/telegraf/plugins/outputs/amqp
  873. github.com/robmorgan/dgtk/amqp
  874. github.com/robmorgan/dgtk/logging
  875. github.com/rodrigosaito/amqpsender
  876. github.com/rodrigosaito/amqpworker
  877. github.com/roeepolegfiverr/gofiverr/connectors
  878. github.com/roeepolegfiverr/gofiverr/worker
  879. github.com/ronna-s/scheduler/channels
  880. github.com/rpedde/amqplib
  881. github.com/rtucker-mozilla/chorizo
  882. github.com/runcom/rmqup/consumer
  883. github.com/runner-mei/grafana/pkg/services/eventpublisher
  884. github.com/russellchadwick/xmpptoamqp
  885. github.com/rvolosatovs/ttn/amqp
  886. github.com/samuelramond/autoscaler
  887. github.com/sassoftware/relic/cmdline/auditor
  888. github.com/sassoftware/relic/lib/audit
  889. github.com/scalegray/sg-golib/amqp
  890. github.com/sebastienfr/cony
  891. github.com/sebastienfr/cony/examples/basic/producer
  892. github.com/sebastienfr/cony/examples/email/producer
  893. github.com/sebastienfr/cony/examples/web/producer
  894. github.com/secmask/rbmassive
  895. github.com/sedarasecurity/gocbapi/serverapi
  896. github.com/seiflotfy/telegraf/plugins/outputs/amqp
  897. github.com/sent-hil/learn/rabbitmq
  898. github.com/seppestas/croft
  899. github.com/sethgrid/hart/service
  900. github.com/shanesawyer-wf/voting-machine
  901. github.com/shaogx/govuk_crawler_worker
  902. github.com/shaogx/govuk_crawler_worker/queue
  903. github.com/shavit/crawlero
  904. github.com/sheepbao/pando-cloud/pkg/queue
  905. github.com/shicky/gocelery
  906. github.com/shicky/machinery/v1/backends
  907. github.com/shicky/machinery/v1/brokers
  908. github.com/shidenggui/machinery/v1/backends
  909. github.com/shidenggui/machinery/v1/brokers
  910. github.com/shish/elasticjiffy
  911. github.com/shokunin/telegraf/outputs/amqp
  912. github.com/shuaiming/grafana/pkg/services/eventpublisher
  913. github.com/sideb0ard/Craxx
  914. github.com/sideb0ard/Kingpin
  915. github.com/silentfl-code/bycode
  916. github.com/silentfl-code/bycode/tools
  917. github.com/silentfl/bycode
  918. github.com/silentfl/bycode/tools
  919. github.com/silentred/learning-path/golang/rabbitmq
  920. github.com/sinopower/push/mq
  921. github.com/skbkontur/csp_reporter
  922. github.com/skbkontur/cspreport/amqp
  923. github.com/slok/celery-go/celery/broker
  924. github.com/smallfish/rabbitmq-http
  925. github.com/smartystreets/messaging/rabbit
  926. github.com/smartystreets/messaging/rabbit/mq
  927. github.com/smartystreets/pipeline/messaging/rabbit
  928. github.com/smartystreets/pipeline/messaging/rabbit/mq
  929. github.com/snail007/wmq
  930. github.com/snormore/go.io/consumer/transport
  931. github.com/solarcity/ftb/publishers
  932. github.com/solarcity/ftb_milestoneapi/services
  933. github.com/solarcity/ftb_task-api/services
  934. github.com/solarcity/ftb_timelineservice/rabbitmq-receive
  935. github.com/solarcity/ftb_timelineservice/rabbitmq-send
  936. github.com/solarcity/ftb_wqservice/services
  937. github.com/soma5mbaas/haru-golang-AnalysisWorker
  938. github.com/soma5mbaas/haru-golang-EmailServer
  939. github.com/soma5mbaas/haru-golang-MongoDBExport
  940. github.com/soma5mbaas/haru-golang-helpcenter/src/controllers
  941. github.com/soma5mbaas/haru-golang-helpcenter/src/models
  942. github.com/soma5mbaas/schemaworker
  943. github.com/soma5mbaas/writeworker
  944. github.com/souled3000/base/rmqs
  945. github.com/soundtrackyourbrand/gaeamqp
  946. github.com/soundtrackyourbrand/rabbit
  947. github.com/sparrc/telegraf/outputs/amqp
  948. github.com/sprungknoedl/kogia
  949. github.com/st3v/cfkit/service
  950. github.com/st3v/go-plugins/broker/rabbitmq
  951. github.com/st3v/go-plugins/transport/rabbitmq
  952. github.com/steam-authority/steam-authority/queue
  953. github.com/straumur/amqpfeed
  954. github.com/stuartaroth/cueball
  955. github.com/subuk/rabbitmq-dump-queue
  956. github.com/supershal/telegraf/plugins/outputs/amqp
  957. github.com/tangentspace/telegraf-cloudwatch-plugin/outputs/amqp
  958. github.com/tanji/telegraf/outputs/amqp
  959. github.com/taoh/gocelery/broker/rabbitmq
  960. github.com/taskcluster/pulse-go
  961. github.com/taskcluster/pulse-go/pulse
  962. github.com/taskcluster/pulse-go/pulsesniffer
  963. github.com/taskcluster/taskcluster-worker/worker/workertest/fakequeue
  964. github.com/tcard/amqptest
  965. github.com/teivah/gosiris/gosiris
  966. github.com/terryh/mq-benchmarking/benchmark/mq
  967. github.com/tgermain/telegraf/plugins/outputs/amqp
  968. github.com/tgulacsi/rpi/amqpc
  969. github.com/thejsj/enco/server
  970. github.com/thejsj/enco/worker
  971. github.com/therahulprasad/blitz
  972. github.com/thethingsnetwork/croft
  973. github.com/thethingsnetwork/jolie
  974. github.com/thetonymaster/go-ios-notification-server/channels
  975. github.com/thoas/observr/broker
  976. github.com/thoj/grafana/pkg/services/eventpublisher
  977. github.com/thomasmodeneis/Flotilla/flotilla-server/daemon/broker/amqp
  978. github.com/threatgrid/heka/plugins/amqp
  979. github.com/tiabc/amqp-http-benchmark/GoHttpServer
  980. github.com/tiago4orion/wabbit/amqp
  981. github.com/tiago4orion/wabbit/utils
  982. github.com/tjyang/Flotilla/flotilla-server/daemon/broker/amqp
  983. github.com/tleyden/open-ocr
  984. github.com/tlrx/heka/pipeline
  985. github.com/toddproject/todd/comms
  986. github.com/tombooth/masterslave
  987. github.com/tompao/telegraf/plugins/outputs/amqp
  988. github.com/tonyluj/grafana/pkg/services/eventpublisher
  989. github.com/torkale/amqp/examples/simple-consumer
  990. github.com/torkale/amqp/examples/simple-producer
  991. github.com/torkale/go_ahead/facebook_service
  992. github.com/tracyde/cf-powerhour/cf-consumer
  993. github.com/tracyde/cf-powerhour/cf-producer
  994. github.com/transcovo/go-chpr-worker
  995. github.com/travis-ci/worker
  996. github.com/trevorprater/machinery/v1
  997. github.com/tristanls/boulder/rpc
  998. github.com/tsaikd/gogstash/output/amqp
  999. github.com/tsingson/grafana/pkg/services/eventpublisher
  1000. github.com/turn/grafana/pkg/services/eventpublisher
  1001. github.com/tylertreat/Flotilla/flotilla-server/daemon/broker/amqp
  1002. github.com/tylertreat/bench/requester
  1003. github.com/tylertreat/mq-benchmarking/benchmark/mq
  1004. github.com/tyrm/ph-events
  1005. github.com/udistrital/auditoria
  1006. github.com/ujanssen/learning-go-lang/rabbitmq/receive
  1007. github.com/ujanssen/learning-go-lang/rabbitmq/send
  1008. github.com/ulule/celery
  1009. github.com/upfluence/goutils/amqputil
  1010. github.com/upfluence/goutils/thrift/builder
  1011. github.com/upfluence/pkg/amqputil
  1012. github.com/upfluence/pkg/thrift/builder
  1013. github.com/upfluence/sensu-coreos/clients/sensu-thrift-client
  1014. github.com/upfluence/thrift-amqp-go/amqp_thrift
  1015. github.com/urjitbhatia/rabbitbeans/rabbit
  1016. github.com/utilitywarehouse/go-pubsub/amqp
  1017. github.com/utilitywarehouse/proximo/proximo-server
  1018. github.com/uw-labs/proximo/proximo-server
  1019. github.com/vCabbage/todd/comms
  1020. github.com/vanillahsu/telegraf/plugins/outputs/amqp
  1021. github.com/vcabbage/todd/comms
  1022. github.com/veino/processors/input-rabbitmq
  1023. github.com/veino/processors/output-rabbitmq
  1024. github.com/veino/veino/processors/input-rabbitmq
  1025. github.com/veino/veino/processors/output-rabbitmq
  1026. github.com/vermoudakias/mgpsrv/empty-queue
  1027. github.com/vermoudakias/mgpsrv/fill-queue
  1028. github.com/vertexclique/grafana/pkg/services/eventpublisher
  1029. github.com/vexor/ssh-proxy/agent
  1030. github.com/vexor/ssh-proxy/server
  1031. github.com/vgarvardt/rabbit-mq-stress-tester
  1032. github.com/vibhavp/amqp-rpc
  1033. github.com/viki-org/amqp/examples/simple-consumer
  1034. github.com/viki-org/amqp/examples/simple-producer
  1035. github.com/viktorasm/grafana/pkg/services/eventpublisher
  1036. github.com/vincentcr/tormgr
  1037. github.com/vjeantet/bitfan/processors/input-rabbitmq
  1038. github.com/vjeantet/bitfan/processors/output-rabbitmq
  1039. github.com/vladoatanasov/logrus_amqp
  1040. github.com/vsayer/pipecat
  1041. github.com/vvv-v13/go-snippets
  1042. github.com/vwiart/crawler
  1043. github.com/vwiart/crawler/crawler
  1044. github.com/vwiart/crawler/rabbitmq
  1045. github.com/vwiart/rabbitmq-client
  1046. github.com/waieez/mdth/api
  1047. github.com/waieez/mdth/fetcher
  1048. github.com/wangbinxiang/rabbitmq-http
  1049. github.com/wdxxs2z/go-cf-autoscaler/producer
  1050. github.com/wdxxs2z/go-cf-autoscaler/worker
  1051. github.com/weave-lab/phone-system-tests/registrar
  1052. github.com/weppos/boulder/cmd/rabbitmq-setup
  1053. github.com/weppos/boulder/rpc
  1054. github.com/wheelcomplex/amqpc
  1055. github.com/williambailey/cony
  1056. github.com/williambailey/rabbitmq-tutorials/go
  1057. github.com/wolfeidau/punter
  1058. github.com/wppurking/event
  1059. github.com/wricardo/rabbitevent
  1060. github.com/wricardo/rabbitworker
  1061. github.com/wuhp/examples/go/mbus
  1062. github.com/wuhp/rabbitmq-tutorials/go
  1063. github.com/wurkhappy/Rabbitmq-go-wrapper
  1064. github.com/wurkhappy/WH-Email
  1065. github.com/wurkhappy/WH-Transactions
  1066. github.com/xbarrufet/QueueLibrary
  1067. github.com/xbarrufet/gotasksimple
  1068. github.com/xentek/pikaq
  1069. github.com/xert/telegraf/plugins/outputs/amqp
  1070. github.com/xianmau/heka/plugins/amqp
  1071. github.com/xozrc/eventsourcing/messaging/rabbitmq
  1072. github.com/xsandr/notifier
  1073. github.com/xthexder/heka/plugins/amqp
  1074. github.com/xuyi/heka/plugins/amqp
  1075. github.com/yeahnoob/grafana/pkg/services/eventpublisher
  1076. github.com/yetis-br/tp-server/apigateway
  1077. github.com/yetis-br/tp-server/mq
  1078. github.com/yext/grafana/pkg/services/eventpublisher
  1079. github.com/yml/degoutils/net/amqprpc
  1080. github.com/yokoi-h/gohan/server
  1081. github.com/yookoala/boulder/cmd/rabbitmq-setup
  1082. github.com/yookoala/boulder/rpc
  1083. github.com/ypyf/machinery/v1/backends
  1084. github.com/ypyf/machinery/v1/brokers
  1085. github.com/zbindenren/telegraf/plugins/outputs/amqp
  1086. github.com/zdavep/dozer/proto/amqp
  1087. github.com/zensqlmonitor/grafana/pkg/services/eventpublisher
  1088. github.com/zensqlmonitor/telegraf/plugins/inputs/amqp_consumer
  1089. github.com/zensqlmonitor/telegraf/plugins/outputs/amqp
  1090. github.com/zerosvc/go-zerosvc
  1091. github.com/zhengzhiren/gibbon/mq
  1092. github.com/zhengzhiren/push/mq
  1093. github.com/zstyblik/grafana/pkg/services/eventpublisher
  1094. github.com/zubairhamed/croft
  1095. gopkg.in/amqprpc.v0
  1096. gopkg.in/entropyx/rabbitgo.v0
  1097. gopkg.in/entropyx/rabbitgo.v1
  1098. gopkg.in/jmartin82/mmock.v1/amqp
  1099. gopkg.in/mbogus/amqprpc.v0
  1100. gopkg.in/mozilla-services/heka.v0/plugins/amqp

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