generated

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

type AppSubscriber interface {
	// BooksListRequest
	BooksListRequest(msg BooksListRequestMessage)
}

type Book struct {
	// Title
	Title string `json:"title"`
}

type BooksListRequestMessage struct {
	// Headers will be used to fill the message headers
	Headers struct {
		// Correlation ID set by client
		CorrelationID string `json:"correlation_id"`
	}

	// Payload will be inserted in the message payload
	Payload struct {
		// Genre
		Genre string `json:"genre"`
	}
}

type BooksListResponseMessage struct {
	// Headers will be used to fill the message headers
	Headers struct {
		// Correlation ID set by client on corresponding request
		CorrelationID string `json:"correlation_id"`
	}

	// Payload will be inserted in the message payload
	Payload struct {
		// Books list
		Books []Book `json:"books"`
	}
}

type BrokerController interface {
	// Publish a message to the broker
	Publish(channel string, mw UniversalMessage) error

	// Subscribe to messages from the broker
	Subscribe(channel string) (msgs chan UniversalMessage, stop chan interface{}, err error)
}

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

type UniversalMessage struct {
	CorrelationID string
	Payload       []byte
}