Skip to content

Commit f6d1761

Browse files
committed
was adding streaming operations to correlation token business. It has no business there.
1 parent c33ec62 commit f6d1761

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

source/request-response/request_response_client.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1713,7 +1713,7 @@ static void s_mqtt_rr_client_submit_operation(struct aws_task *task, void *arg,
17131713

17141714
// If a correlation token is used with the operation, check if it's already in use. Fail the operation if it is,
17151715
// store the correlation token if it isn't.
1716-
if (operation->storage.request_storage.options.correlation_token.len > 0) {
1716+
if (operation->type == AWS_MRROT_REQUEST && operation->storage.request_storage.options.correlation_token.len > 0) {
17171717
if (s_is_correlation_token_in_use(client, &operation->storage.request_storage.options.correlation_token)) {
17181718
s_request_response_fail_operation(operation, AWS_ERROR_MQTT_REQUEST_RESPONSE_DUPLICATE_CORRELATION_TOKEN);
17191719
goto done;

0 commit comments

Comments
 (0)