generated

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 ClientController struct {
	// contains filtered or unexported fields
}

type ClientSubscriber interface {
	// BooksListResponse
	BooksListResponse(msg BooksListResponseMessage)
}

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

type UniversalMessage struct {
	CorrelationId string
	Payload       []byte
}