diff options
| -rw-r--r-- | src/t_stream.c | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/t_stream.c b/src/t_stream.c index dd83f2b1d..f51f6c46b 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -1025,7 +1025,7 @@ size_t streamReplyWithRangeFromConsumerPEL(client *c, stream *s, streamID *start if (end && memcmp(ri.key,end,ri.key_len) > 0) break; streamID thisid; streamDecodeID(ri.key,&thisid); - if (streamReplyWithRange(c,s,&thisid,NULL,1,0,NULL,NULL, + if (streamReplyWithRange(c,s,&thisid,&thisid,1,0,NULL,NULL, STREAM_RWR_RAWENTRIES,NULL) == 0) { /* Note that we may have a not acknowledged entry in the PEL |