Method exchangeMessage

tq/custom.go:204–210

exchangeMessage sends a message to a process and reads a response if resp != nil Only fatal errors to communicate return an error, errors may be embedded in reply

(ctx *customAdapterWorkerContext, req interface{})

// exchangeMessage sends a message to a process and reads a response if resp != nil
// Only fatal errors to communicate return an error, errors may be embedded in reply
func (a *customAdapter) exchangeMessage(ctx *customAdapterWorkerContext, req interface{}) (*customAdapterResponseMessage, error) {
	err := a.sendMessage(ctx, req)
	if err != nil {
		return nil, err
	}
	return a.readResponse(ctx)
}

// shutdownWorkerProcess terminates gracefully a custom adapter process
// returns an error if it couldn't shut down gracefully (caller may abortWorkerProcess)