package ctrl

// jetstreamsConsumers will start up the netstream consumers.
// The consumer logic are put in the procFunc.
func jetstreamsConsumers(proc process, message Message, node string) ([]byte, error) {

	return []byte{}, nil
}

// jetstreamPublishers will start up the netstream publishers.
// The publisher logic are put in the procFunc.
func jetstreamPublishers(proc process, message Message, node string) ([]byte, error) {

	return []byte{}, nil
}