Toggle navigation
Home
org.apache.pulsar.client.impl.MessageIdImpl to org.apache.pulsar.client.api.MessageId
No. of Instances - 18
No. of Commits - 4
No. of Projects - {'pulsar'}
Hierarchy/Composition: R_SUPER_T
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Similar)
ConcurrentOpenHashSet<MessageIdImpl>
to
ConcurrentOpenHashSet<MessageId>
ConcurrentOpenHashSet<MessageIdImpl>
to
ConcurrentOpenHashSet<MessageId>
Add or Remove Method invocation
messageIds.contains((MessageIdImpl)peek.getMessageId())
to
messageIds.contains(peek.getMessageId())
messageIds.stream().collect(Collectors.groupingBy(MessageIdImpl::getPartitionIndex,Collectors.toSet()))
to
messageIds.stream().map(messageId -> (MessageIdImpl)messageId).collect(Collectors.groupingBy(MessageIdImpl::getPartitionIndex,Collectors.toSet()))
consumers.get(partitionIndex).redeliverUnacknowledgedMessages(messageIds1)
to
consumers.get(partitionIndex).redeliverUnacknowledgedMessages(messageIds1.stream().map(mid -> (MessageId)mid).collect(Collectors.toSet()))