Class: Bunny::TopologyRecoveryFilter Abstract

Inherits:

Object

• Object
• Bunny::TopologyRecoveryFilter

Defined in:

lib/bunny/topology_recovery_filter.rb

Overview

This class is abstract.

Override to implement the filtering functions.

Passed to [Bunny::TopologyRegistry] to filter entities during topology recovery.

See Also:

• TopologyRegistry

Direct Known Subclasses

DefaultTopologyRecoveryFilter

Instance Method Summary

• #filter_consumers(bs) ⇒ Array<Bunny::RecordedConsumer> abstract

  Returns a collection of consumers that should be recovered during topology recovery.

• #filter_exchange_bindings(bs) ⇒ Array<Bunny::RecordedExchangeBinding>, Set<Bunny::RecordedExchangeBinding> abstract

  Returns a collection of exchange bindings that should be recovered during topology recovery.

• #filter_exchanges(xs) ⇒ Array<Bunny::RecordedExchange> abstract

  Returns a collection of exchanges that should be recovered during topology recovery.

• #filter_queue_bindings(bs) ⇒ Array<Bunny::RecordedQueueBinding>, Set<Bunny::RecordedQueueBinding> abstract

  Returns a collection of queue bindings that should be recovered during topology recovery.

• #filter_queues(qs) ⇒ Array<Bunny::RecordedQueue> abstract

  Returns a collection of queues that should be recovered during topology recovery.

Instance Method Details

#filter_consumers(bs) ⇒ Array<Bunny::RecordedConsumer>

This method is abstract.

Override to implement consumer filtering

Returns a collection of consumers that should be recovered during topology recovery.

Parameters:

• bs (Array<Bunny::RecordedConsumer>)

Returns:

• (Array<Bunny::RecordedConsumer>)

Raises:

• (NotImplementedError)

# File 'lib/bunny/topology_recovery_filter.rb', line 40

def filter_consumers(bs); raise NotImplementedError; end

#filter_exchange_bindings(bs) ⇒ Array<Bunny::RecordedExchangeBinding>, Set<Bunny::RecordedExchangeBinding>

This method is abstract.

Override to implement exchange binding filtering

Returns a collection of exchange bindings that should be recovered during topology recovery.

Parameters:

• bs (Set<Bunny::RecordedExchangeBinding>)

Returns:

• (Array<Bunny::RecordedExchangeBinding>, Set<Bunny::RecordedExchangeBinding>)

Raises:

• (NotImplementedError)

# File 'lib/bunny/topology_recovery_filter.rb', line 28

def filter_exchange_bindings(bs); raise NotImplementedError; end

#filter_exchanges(xs) ⇒ Array<Bunny::RecordedExchange>

This method is abstract.

Override to implement exchange filtering

Returns a collection of exchanges that should be recovered during topology recovery.

Parameters:

• xs (Array<Bunny::RecordedExchange>)

Returns:

• (Array<Bunny::RecordedExchange>)

Raises:

• (NotImplementedError)

# File 'lib/bunny/topology_recovery_filter.rb', line 16

def filter_exchanges(xs); raise NotImplementedError; end

#filter_queue_bindings(bs) ⇒ Array<Bunny::RecordedQueueBinding>, Set<Bunny::RecordedQueueBinding>

This method is abstract.

Override to implement queue binding filtering

Returns a collection of queue bindings that should be recovered during topology recovery.

Parameters:

• bs (Set<Bunny::RecordedQueueBinding>)

Returns:

• (Array<Bunny::RecordedQueueBinding>, Set<Bunny::RecordedQueueBinding>)

Raises:

• (NotImplementedError)

# File 'lib/bunny/topology_recovery_filter.rb', line 34

def filter_queue_bindings(bs); raise NotImplementedError; end

#filter_queues(qs) ⇒ Array<Bunny::RecordedQueue>

This method is abstract.

Override to implement queue filtering.

Returns a collection of queues that should be recovered during topology recovery.

Parameters:

• qs (Array<Bunny::RecordedQueue>)

Returns:

• (Array<Bunny::RecordedQueue>)

Raises:

• (NotImplementedError)

# File 'lib/bunny/topology_recovery_filter.rb', line 22

def filter_queues(qs); raise NotImplementedError; end