Skip to content

Commit 970d22e

Browse files
committed
Fix typo
1 parent d426a12 commit 970d22e

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -130,9 +130,9 @@ final class AmqpConnection extends ResourceBase implements Connection {
130130
ConnectionUtils.NO_RETRY_STRATEGY,
131131
this.name());
132132
this.sync(ncw);
133-
String brokerVesion = brokerVersion(this.nativeConnection);
134-
this.filterExpressionsSupported = supportFilterExpressions(brokerVesion);
135-
this.setTokenSupported = supportSetToken(brokerVesion);
133+
String brokerVersion = brokerVersion(this.nativeConnection);
134+
this.filterExpressionsSupported = supportFilterExpressions(brokerVersion);
135+
this.setTokenSupported = supportSetToken(brokerVersion);
136136
LOGGER.debug("Opened connection '{}' on node '{}'.", this.name(), this.connectionNodename());
137137
this.state(OPEN);
138138
this.environment.metricsCollector().openConnection();

0 commit comments

Comments
 (0)