activity

type AMQPMessage struct {
	// contains filtered or unexported fields
}

type AMQPTransport struct {
	// contains filtered or unexported fields
}

type MemoryMessage struct {
	Acknowledged bool
	// contains filtered or unexported fields
}

type MemoryTransport struct {
	// contains filtered or unexported fields
}

type Message interface {
	Activity() *domain.Activity
	Acknowledge() error
}

type Sink interface {
	Publish(activity *domain.Activity) error
	Close() error
}

type Source interface {
	Consume() (chan Message, error)
	Close() error
}