达瓦平措的致富路：靠山不能吃山 靠水不能吃水

W/o Durability

@import(io, [fwrite/2])
@import(stomp, [connect/4, disconnect/1, on_message/2, subscribe/2])

fn main @public case:
  Conn = connect("localhost", 61613, "", "")

  subscribe("/topic/SampleTopic", Conn)

  F = fn case Msg: fwrite("~p~n", [Msg]) end

  on_message(F, Conn)

  disconnect(Conn)
end

W/ Durability

@import(io, [fwrite/2])
@import(stomp, [connect/5, disconnect/1, on_message/2, subscribe/3])

fn main @public case:
  Conn = connect("localhost", 61613, "", "", [{"client-id", "SampleClient"}])

  subscribe("SampleQueue", Conn, [{"activemq.subscriptionName", "SampleSubscription"}])

  F = fn case Msg: fwrite("~p~n", [Msg]) end

  on_message(F, Conn)

  disconnect(Conn)
end