Current section
Files
Jump to
Current section
Files
lib/bolty/bolt_protocol/message/ack_failure_message.ex
defmodule Bolty.BoltProtocol.Message.AckFailureMessage do
@moduledoc false
alias Bolty.BoltProtocol.MessageEncoder
@signature 0x0E
def encode(bolt_version) when is_float(bolt_version) and bolt_version <= 2.0 do
MessageEncoder.encode(@signature, [])
end
def encode(_) do
{:error,
Bolty.Error.wrap(__MODULE__, %{
code: :unsupported_message_version,
message: "ACK FAILURE message version not supported"
})}
end
end