Kombu.Transport.Virtual.Exchange (Kombu v0.1.0)

Virtual AMQ Exchange type implementations (direct, topic, fanout), ported from kombu.transport.virtual.exchange.

Summary

Checks if prev exchange metadata is equivalent to the new declaration parameters.

Returns the map of standard exchange types ("direct", "topic", "fanout").

Returns the exchange module for type (defaulting to Direct).

@spec equivalent?(map(), String.t(), String.t(), boolean(), boolean(), map() | nil) ::
  boolean()

Checks if prev exchange metadata is equivalent to the new declaration parameters.

@spec standard_exchange_types() :: %{required(String.t()) => module()}

Returns the map of standard exchange types ("direct", "topic", "fanout").

@spec type_module(String.t() | nil) :: module()

Returns the exchange module for type (defaulting to Direct).