Project

telemetry-amqp

0.0
No release in over a year
telemetry-amqpoptum/telemetry-amqpHomepageDocumentationSource CodeBug TrackerWiki
A base Telemetry gem for connecting to AMQP services for transport
2005
2006
2007
2008
2009
2010
2011
2012
2013
2014
2015
2016
2017
2018
2019
2020
2021
2022
2023
2024
 Popularity
Downloads
4,200
Stars
1
Forks
2
Watchers
4
 Releases
Current version
0.2.0
Total releases
2
First release
2021-07-19
Latest release
2022-03-17
 Development
Primary Language
Ruby
Licenses
Apache-2.0
Average date of last 50 commits
2021-07-31
Reverse Dependencies
1

 Dependencies

Runtime

bunny
>= 0
concurrent-ruby
>= 1.1.7
concurrent-ruby-ext
>= 1.1.7
faraday
>= 2
multi_json
>= 0
oj
>= 3.11
telemetry-logger
>= 0
 Project Readme

Telemetry::AMQP

A ruby gem used to connect to RabbitMQ.

Examples

require 'telemetry/amqp'

Telemetry::AMQP.connect!(username: 'guest', password: 'guest', node: '127.0.0.1')
Telemetry::AMQP.session # => Bunny::Session
Telemetry::AMQP.channel # => Bunny::Channel

You can also initiate multiple connections using the Base class

rmq = Telemetry::AMQP::Base.new(username: 'guest', vhost: 'custom_vhost')
rmq.session # => Bunny:Session
rmq.channel # => Bunny::Channel

Connection Options

These are the configurable options and their defaults

{
  username: 'guest',
  password: 'guest',
  nodes: ['127.0.0.1'],
  port: 5672,
  use_ssl: false,
  connection_name: '',
  automatically_recover: true,
  verify_peer: true,
  application: 'telemetry::amqp',
  app_version: Telemetry::AMQP::VERSION,
  connection_name: 'telemetry_amqp:0.1.0'
}

Channels

Currently channels within Telemetry::AMQP use the concurrent-ruby class of Concurrent::ThreadLocalVar so that we use a different channel for each Ruby thread automatically. This is per the bunny docs

Parts of the library (most notably Bunny::Channel) are designed to assume they are not shared between threads.