Skip to content

Commit 6ae4b9a

Browse files
authored
Merge pull request #175 from rabbitmq/open-and-give-credits
Transition to open state before giving credits
2 parents 36016b9 + 8980e34 commit 6ae4b9a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/com/rabbitmq/client/amqp/impl/AmqpConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -130,14 +130,14 @@ final class AmqpConsumer extends ResourceBase implements Consumer {
130130
this.nativeCloseHandler);
131131
this.initStateFromNativeReceiver(this.nativeReceiver);
132132
this.metricsCollector = this.connection.metricsCollector();
133+
this.state(OPEN);
133134
try {
134135
this.nativeReceiver.addCredit(this.initialCredits);
135136
} catch (ClientException e) {
136137
AmqpException ex = ExceptionUtils.convert(e);
137138
this.close(ex);
138139
throw ex;
139140
}
140-
this.state(OPEN);
141141
this.metricsCollector.openConsumer();
142142
}
143143

0 commit comments

Comments
 (0)