railway_ipc

v0.1.6

railway_ipc v0.1.6 RailwayIpcBehaviour behaviour

Link to this section Summary

Callbacks

process_consumed_message(arg1, arg2, arg3, arg4, atom)
process_consumed_message(arg1, arg2, arg3, arg4, atom)
process_published_message(arg1, arg2)

Link to this section Callbacks

Link to this callback

process_consumed_message(arg1, arg2, arg3, arg4, atom)

process_consumed_message(
  String.t(),
  String.t(),
  String.t(),
  String.t(),
  RailwayIpc.Core.EventMessage
) :: tuple()
process_consumed_message(
  String.t(),
  String.t(),
  String.t(),
  String.t(),
  RailwayIpc.Core.CommandMessage
) :: tuple()
Link to this callback

process_consumed_message(arg1, arg2, arg3, arg4, atom)

process_consumed_message(
  String.t(),
  String.t(),
  String.t(),
  String.t(),
  RailwayIpc.Core.EventMessage
) :: tuple()
process_consumed_message(
  String.t(),
  String.t(),
  String.t(),
  String.t(),
  RailwayIpc.Core.CommandMessage
) :: tuple()
Link to this callback

process_published_message(arg1, arg2)

process_published_message(Map.t(), String.t()) :: tuple()