Packages

nats_streaming

0.0.1
0.0.3 retired 0.0.2 retired 0.0.1 retired

BETA support for interacting with a NATS streaming server

Retired package: Renamed - Merged into the main nats.ex (gnat) library. Use Gnat.Jetstream from the :gnat package instead.
HexDocs

Current section

Files

Jump to
Readme
3 Versions
2 Dependencies
Dependants
Files
Activity
nats_streaming lib gnat streaming message.ex
Raw

lib/gnat/streaming/message.ex 

defmodule Gnat.Streaming.Message do

  @enforce_keys [

    :ack_subject,

    :connection_pid,

    :data,

    :redelivered,

    :reply,

    :sequence,

    :subject,

    :timestamp

  ]

  defstruct [

    :ack_subject,

    :connection_pid,

    :data,

    :redelivered,

    :reply,

    :sequence,

    :subject,

    :timestamp

  ]



  alias Gnat.Streaming.Protocol.Ack



  def ack(%__MODULE__{} = message) do

    %__MODULE__{

      ack_subject: ack_subject,

      connection_pid: pid,

      sequence: sequence,

      subject: subject

    } = message



    ack = Ack.new(subject: subject, sequence: sequence) |> Ack.encode()

    Gnat.pub(pid, ack_subject, ack)

  end

end