marshal

README

Marshal

---

Marshal is a marshaller for watermill that just passes the message. To be used when interacting with Core

Usage:

    //Create marshaller
    marshaller := marshal.NewMarshalerUnmarshaler()

Documentation

Index

• type Marshaler
  • func NewMarshalerUnmarshaler() *Marshaler
  • func (m *Marshaler) Marshal(topic string, msg *message.Message) ([]byte, error)
  • func (m *Marshaler) Unmarshal(stanMsg *stan.Msg) (*message.Message, error)

Types

type Marshaler

type Marshaler struct{}

func NewMarshalerUnmarshaler

func NewMarshalerUnmarshaler() *Marshaler

func (*Marshaler) Marshal

func (m *Marshaler) Marshal(topic string, msg *message.Message) ([]byte, error)

Marshal implements nats.MarshalerUnmarshaler

func (*Marshaler) Unmarshal

func (m *Marshaler) Unmarshal(stanMsg *stan.Msg) (*message.Message, error)

Unmarshal implements nats.MarshalerUnmarshaler