Skip to content

Commit 056b0f7

Browse files
committed
Fixing API usage
Signed-off-by: Edward Payzant <adam@synadia.com>
1 parent c8bfbb0 commit 056b0f7

3 files changed

Lines changed: 2 additions & 11 deletions

File tree

src/jsm.c

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3583,7 +3583,6 @@ _unmarshalConsumerResetResp(jsConsumerResetResponse **new_crr, natsMsg *resp, js
35833583
else
35843584
{
35853585
s = nats_JSONGetULong(json, "reset_seq", &(crr->ResetSeq));
3586-
IFOK(s, js_unmarshalConsumerInfo(json, &(crr->Consumer)));
35873586
if (s == NATS_OK)
35883587
*new_crr = crr;
35893588
else
@@ -3603,7 +3602,6 @@ jsConsumerResetResponse_Destroy(jsConsumerResetResponse *crr)
36033602
if (crr == NULL)
36043603
return;
36053604

3606-
jsConsumerInfo_Destroy(crr->Consumer);
36073605
NATS_FREE(crr);
36083606
}
36093607

src/nats.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1191,8 +1191,8 @@ typedef struct jsConsumerPauseResponse
11911191
*/
11921192
typedef struct jsConsumerResetResponse
11931193
{
1194-
jsConsumerInfo *Consumer; ///< Consumer info after the reset.
11951194
uint64_t ResetSeq; ///< Stream sequence the consumer was reset to.
1195+
11961196
} jsConsumerResetResponse;
11971197

11981198
/**

test/test.c

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -34199,14 +34199,7 @@ void test_JetStreamConsumerReset(void)
3419934199
test("Reset consumer (no seq): ");
3420034200
s = js_ResetConsumer(&crr, js, "s1", "c1", 0, NULL, &jerr);
3420134201
testCond((s == NATS_OK) && (jerr == 0)
34202-
&& (crr != NULL)
34203-
&& (crr->Consumer != NULL)
34204-
&& (crr->Consumer->Name != NULL)
34205-
&& (strcmp(crr->Consumer->Name, "c1") == 0)
34206-
&& (crr->Consumer->Stream != NULL)
34207-
&& (strcmp(crr->Consumer->Stream, "s1") == 0)
34208-
&& (crr->Consumer->Delivered.Consumer == 0)
34209-
&& (crr->Consumer->NumRedelivered == 0));
34202+
&& (crr != NULL));
3421034203
jsConsumerResetResponse_Destroy(crr);
3421134204
crr = NULL;
3421234205

0 commit comments

Comments
 (0)