Sha256: c0419c36c3668e497a1a1fe9f259580e6881341d661edf31f5f66f3ec52bfc8b

Contents?: true

Size: 505 Bytes

Versions: 4

Compression:

Stored size: 505 Bytes

Contents

module ListingHelper
	def select_queues(client, vhost)
		client.list_queues(vhost).select do |queue|
			!is_default_entity?(queue.name)
		end
	end

	def select_exchanges(client, vhost)
		client.list_exchanges(vhost).select do |exchange|
			!is_default_entity?(exchange.name)
		end
	end

	def select_bindings(client, vhost)
		client.list_bindings(vhost).select do |binding|
			!is_default_entity?(binding.source)
		end
	end

	def is_default_entity?(name)
		name.empty? || name.start_with?("amq.")
	end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
rabbitmq-definition-0.1.3 spec/helpers/listing_helper.rb
rabbitmq-definition-0.1.2 spec/helpers/listing_helper.rb
rabbitmq-definition-0.1.1 spec/helpers/listing_helper.rb
rabbitmq-definition-0.1.0 spec/helpers/listing_helper.rb