[FIXED] Fix compiler errors after rebase

Signed-off-by: Piotr Piotrowski <[email protected]>

Author: piotrpio

jetstream/consumer.go

@@ -329,14 +329,14 @@ func deleteConsumer(ctx context.Context, js *jetStream, stream, consumer string)
 }
 
 func pauseConsumer(ctx context.Context, js *jetStream, stream, consumer string, pauseUntil *time.Time) (*ConsumerPauseResponse, error) {
-	ctx, cancel := wrapContextWithoutDeadline(ctx)
+	ctx, cancel := js.wrapContextWithoutDeadline(ctx)
 	if cancel != nil {
 		defer cancel()
 	}
 	if err := validateConsumerName(consumer); err != nil {
 		return nil, err
 	}
-	subject := apiSubj(js.apiPrefix, fmt.Sprintf(apiConsumerPauseT, stream, consumer))
+	subject := fmt.Sprintf(apiConsumerPauseT, stream, consumer)
 
 	var resp consumerPauseApiResponse
 	req, err := json.Marshal(consumerPauseRequest{

jetstream/stream.go

@@ -322,12 +322,12 @@ func (s *stream) DeleteConsumer(ctx context.Context, name string) error {
 
 // PauseConsumer pauses a consumer.
 func (s *stream) PauseConsumer(ctx context.Context, name string, pauseUntil time.Time) (*ConsumerPauseResponse, error) {
-	return pauseConsumer(ctx, s.jetStream, s.name, name, &pauseUntil)
+	return pauseConsumer(ctx, s.js, s.name, name, &pauseUntil)
 }
 
 // ResumeConsumer resumes a consumer.
 func (s *stream) ResumeConsumer(ctx context.Context, name string) (*ConsumerPauseResponse, error) {
-	return resumeConsumer(ctx, s.jetStream, s.name, name)
+	return resumeConsumer(ctx, s.js, s.name, name)
 }
 
 // Info returns StreamInfo from the server.