public class org.apache.kafkaesqueesque.clients.consumer.MockConsumer extends java.lang.Object implements org.apache.kafkaesqueesque.clients.consumer.Consumer
{
private final java.util.Map partitions;
private final org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions;
private final java.util.Map beginningOffsets;
private final java.util.Map endOffsets;
private final java.util.Map committed;
private final java.util.Queue pollTasks;
private final java.util.Set paused;
private java.util.Map records;
private org.apache.kafkaesqueesque.common.KafkaException pollException;
private org.apache.kafkaesqueesque.common.KafkaException offsetsException;
private java.util.concurrent.atomic.AtomicBoolean wakeup;
private boolean closed;
public void <init>(org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy)
{
org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy v;
java.util.concurrent.atomic.AtomicBoolean v;
java.util.HashMap v, v, v, v, v;
org.apache.kafkaesqueesque.common.utils.LogContext v;
java.util.HashSet v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.LinkedList v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState;
v = new org.apache.kafkaesqueesque.common.utils.LogContext;
specialinvoke v.<org.apache.kafkaesqueesque.common.utils.LogContext: void <init>()>();
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: void <init>(org.apache.kafkaesqueesque.common.utils.LogContext,org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy)>(v, v);
v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map partitions> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map records> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Set paused> = v;
v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: boolean closed> = 0;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map beginningOffsets> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map endOffsets> = v;
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Queue pollTasks> = v;
v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.common.KafkaException pollException> = null;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.concurrent.atomic.AtomicBoolean wakeup> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map committed> = v;
return;
}
public synchronized java.util.Set assignment()
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.Set v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: java.util.Set assignedPartitions()>();
return v;
}
public synchronized void rebalance(java.util.Collection)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.Collection v;
java.util.Map v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Collection;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map records>;
interfaceinvoke v.<java.util.Map: void clear()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: void assignFromSubscribed(java.util.Collection)>(v);
return;
}
public synchronized java.util.Set subscription()
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.Set v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: java.util.Set subscription()>();
return v;
}
public synchronized void subscribe(java.util.Collection)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.clients.consumer.internals.NoOpConsumerRebalanceListener v;
java.util.Collection v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Collection;
v = new org.apache.kafkaesqueesque.clients.consumer.internals.NoOpConsumerRebalanceListener;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.NoOpConsumerRebalanceListener: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void subscribe(java.util.Collection,org.apache.kafkaesqueesque.clients.consumer.ConsumerRebalanceListener)>(v, v);
return;
}
public synchronized void subscribe(java.util.regex.Pattern, org.apache.kafkaesqueesque.clients.consumer.ConsumerRebalanceListener)
{
java.util.HashSet v, v;
org.apache.kafkaesqueesque.common.TopicPartition v;
java.util.regex.Matcher v;
java.util.Map v, v, v;
int v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v, v, v, v;
boolean v, v, v, v, v;
java.util.Iterator v, v, v;
org.apache.kafkaesqueesque.clients.consumer.ConsumerRebalanceListener v;
java.util.Set v, v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.lang.Object v, v, v, v;
java.util.regex.Pattern v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.regex.Pattern;
v := @parameter: org.apache.kafkaesqueesque.clients.consumer.ConsumerRebalanceListener;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map committed>;
interfaceinvoke v.<java.util.Map: void clear()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: void subscribe(java.util.regex.Pattern,org.apache.kafkaesqueesque.clients.consumer.ConsumerRebalanceListener)>(v, v);
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map partitions>;
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: java.util.Set subscription()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
goto label;
label:
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: boolean subscribeFromPattern(java.util.Set)>(v);
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map partitions>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new org.apache.kafkaesqueesque.common.TopicPartition;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.PartitionInfo: int partition()>();
specialinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: void <init>(java.lang.String,int)>(v, v);
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: void assignFromSubscribed(java.util.Collection)>(v);
return;
}
public synchronized void subscribe(java.util.regex.Pattern)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.regex.Pattern v;
org.apache.kafkaesqueesque.clients.consumer.internals.NoOpConsumerRebalanceListener v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.regex.Pattern;
v = new org.apache.kafkaesqueesque.clients.consumer.internals.NoOpConsumerRebalanceListener;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.NoOpConsumerRebalanceListener: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void subscribe(java.util.regex.Pattern,org.apache.kafkaesqueesque.clients.consumer.ConsumerRebalanceListener)>(v, v);
return;
}
public synchronized void subscribe(java.util.Collection, org.apache.kafkaesqueesque.clients.consumer.ConsumerRebalanceListener)
{
java.util.HashSet v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.Collection v;
java.util.Map v;
org.apache.kafkaesqueesque.clients.consumer.ConsumerRebalanceListener v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Collection;
v := @parameter: org.apache.kafkaesqueesque.clients.consumer.ConsumerRebalanceListener;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map committed>;
interfaceinvoke v.<java.util.Map: void clear()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: boolean subscribe(java.util.Set,org.apache.kafkaesqueesque.clients.consumer.ConsumerRebalanceListener)>(v, v);
return;
}
public synchronized void assign(java.util.Collection)
{
java.util.HashSet v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.Collection v;
java.util.Map v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Collection;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map committed>;
interfaceinvoke v.<java.util.Map: void clear()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: boolean assignFromUser(java.util.Set)>(v);
return;
}
public synchronized void unsubscribe()
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map committed>;
interfaceinvoke v.<java.util.Map: void clear()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: void unsubscribe()>();
return;
}
public synchronized org.apache.kafkaesqueesque.clients.consumer.ConsumerRecords poll(long)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.time.Duration v;
long v;
org.apache.kafkaesqueesque.clients.consumer.ConsumerRecords v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: long;
v = <java.time.Duration: java.time.Duration ZERO>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.ConsumerRecords poll(java.time.Duration)>(v);
return v;
}
public synchronized org.apache.kafkaesqueesque.clients.consumer.ConsumerRecords poll(java.time.Duration)
{
byte v, v;
java.lang.Long v;
java.time.Duration v;
java.util.Map v, v, v, v;
java.util.Set v, v, v;
org.apache.kafkaesqueesque.clients.consumer.ConsumerRecords v;
java.lang.Throwable v;
long v, v, v, v, v;
java.util.ArrayList v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v, v, v, v, v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition v, v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.clients.Metadata$LeaderAndEpoch v;
boolean v, v, v, v, v, v, v;
java.util.Optional v, v, v;
java.util.Queue v, v;
java.util.concurrent.atomic.AtomicBoolean v, v;
java.util.HashMap v;
java.util.function.Function v;
org.apache.kafkaesqueesque.clients.consumer.OffsetOutOfRangeException v;
org.apache.kafkaesqueesque.common.errors.WakeupException v;
java.util.Iterator v, v, v;
java.util.function.Consumer v;
org.apache.kafkaesqueesque.common.KafkaException v, v;
java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.time.Duration;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Queue pollTasks>;
entermonitor v;
label:
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Queue pollTasks>;
v = interfaceinvoke v.<java.util.Queue: java.lang.Object poll()>();
if v == null goto label;
interfaceinvoke v.<java.lang.Runnable: void run()>();
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.concurrent.atomic.AtomicBoolean wakeup>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.concurrent.atomic.AtomicBoolean wakeup>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(0);
v = new org.apache.kafkaesqueesque.common.errors.WakeupException;
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.WakeupException: void <init>()>();
throw v;
label:
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.common.KafkaException pollException>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.common.KafkaException pollException>;
v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.common.KafkaException pollException> = null;
throw v;
label:
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: java.util.Set assignedPartitions()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: boolean hasValidPosition(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
if v != 0 goto label;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void updateFetchPosition(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
goto label;
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map records>;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: boolean isPaused(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
if v != 0 goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition position(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition: long offset>;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map beginningOffsets>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map beginningOffsets>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v cmp v;
if v <= 0 goto label;
v = new org.apache.kafkaesqueesque.clients.consumer.OffsetOutOfRangeException;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.OffsetOutOfRangeException: void <init>(java.util.Map)>(v);
throw v;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Set assignment()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.ConsumerRecord: long offset()>();
v = v cmp v;
if v < 0 goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = staticinvoke <org.apache.kafkaesqueesque.clients.consumer.MockConsumer$lambda_poll_0__541: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object computeIfAbsent(java.lang.Object,java.util.function.Function)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = new org.apache.kafkaesqueesque.clients.Metadata$LeaderAndEpoch;
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.ConsumerRecord: java.util.Optional leaderEpoch()>();
specialinvoke v.<org.apache.kafkaesqueesque.clients.Metadata$LeaderAndEpoch: void <init>(java.util.Optional,java.util.Optional)>(v, v);
v = new org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.ConsumerRecord: long offset()>();
v = v + 1L;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.ConsumerRecord: java.util.Optional leaderEpoch()>();
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition: void <init>(long,java.util.Optional,org.apache.kafkaesqueesque.clients.Metadata$LeaderAndEpoch)>(v, v, v);
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: void position(org.apache.kafkaesqueesque.common.TopicPartition,org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition)>(v, v);
goto label;
label:
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = staticinvoke <org.apache.kafkaesqueesque.clients.consumer.MockConsumer$lambda_poll_1__540: java.util.function.Consumer bootstrap$(org.apache.kafkaesqueesque.clients.consumer.MockConsumer)>(v);
interfaceinvoke v.<java.util.List: void forEach(java.util.function.Consumer)>(v);
v = new org.apache.kafkaesqueesque.clients.consumer.ConsumerRecords;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.ConsumerRecords: void <init>(java.util.Map)>(v);
return v;
catch java.lang.Throwable from label to label with label;
}
public synchronized void addRecord(org.apache.kafkaesqueesque.clients.consumer.ConsumerRecord)
{
java.lang.IllegalStateException v;
org.apache.kafkaesqueesque.clients.consumer.ConsumerRecord v;
java.util.Set v;
java.util.function.Function v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.common.TopicPartition v;
java.util.Map v;
int v;
java.lang.Object v;
java.lang.String v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
boolean v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: org.apache.kafkaesqueesque.clients.consumer.ConsumerRecord;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = new org.apache.kafkaesqueesque.common.TopicPartition;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.ConsumerRecord: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.ConsumerRecord: int partition()>();
specialinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: void <init>(java.lang.String,int)>(v, v);
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: java.util.Set assignedPartitions()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Cannot add records for a partition that is not assigned to the consumer");
throw v;
label:
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map records>;
v = staticinvoke <org.apache.kafkaesqueesque.clients.consumer.MockConsumer$lambda_addRecord_2__542: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object computeIfAbsent(java.lang.Object,java.util.function.Function)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return;
}
public synchronized void setException(org.apache.kafkaesqueesque.common.KafkaException)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.common.KafkaException v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: org.apache.kafkaesqueesque.common.KafkaException;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void setPollException(org.apache.kafkaesqueesque.common.KafkaException)>(v);
return;
}
public synchronized void setPollException(org.apache.kafkaesqueesque.common.KafkaException)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.common.KafkaException v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: org.apache.kafkaesqueesque.common.KafkaException;
v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.common.KafkaException pollException> = v;
return;
}
public synchronized void setOffsetsException(org.apache.kafkaesqueesque.common.KafkaException)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.common.KafkaException v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: org.apache.kafkaesqueesque.common.KafkaException;
v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.common.KafkaException offsetsException> = v;
return;
}
public synchronized void commitAsync(java.util.Map, org.apache.kafkaesqueesque.clients.consumer.OffsetCommitCallback)
{
java.util.Iterator v;
java.util.Set v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.clients.consumer.OffsetCommitCallback v;
java.util.Map v, v;
java.lang.Object v, v, v;
boolean v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Map;
v := @parameter: org.apache.kafkaesqueesque.clients.consumer.OffsetCommitCallback;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map committed>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
if v == null goto label;
interfaceinvoke v.<org.apache.kafkaesqueesque.clients.consumer.OffsetCommitCallback: void onComplete(java.util.Map,java.lang.Exception)>(v, null);
label:
return;
}
public synchronized void commitSync(java.util.Map)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Map;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void commitAsync(java.util.Map,org.apache.kafkaesqueesque.clients.consumer.OffsetCommitCallback)>(v, null);
return;
}
public synchronized void commitAsync()
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void commitAsync(org.apache.kafkaesqueesque.clients.consumer.OffsetCommitCallback)>(null);
return;
}
public synchronized void commitAsync(org.apache.kafkaesqueesque.clients.consumer.OffsetCommitCallback)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.clients.consumer.OffsetCommitCallback v;
java.util.Map v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: org.apache.kafkaesqueesque.clients.consumer.OffsetCommitCallback;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: java.util.Map allConsumed()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void commitAsync(java.util.Map,org.apache.kafkaesqueesque.clients.consumer.OffsetCommitCallback)>(v, v);
return;
}
public synchronized void commitSync()
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: java.util.Map allConsumed()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void commitSync(java.util.Map)>(v);
return;
}
public synchronized void commitSync(java.time.Duration)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.time.Duration v;
java.util.Map v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.time.Duration;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: java.util.Map allConsumed()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void commitSync(java.util.Map)>(v);
return;
}
public void commitSync(java.util.Map, java.time.Duration)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.time.Duration v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Map;
v := @parameter: java.time.Duration;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void commitSync(java.util.Map)>(v);
return;
}
public synchronized void seek(org.apache.kafkaesqueesque.common.TopicPartition, long)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.common.TopicPartition v;
long v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: org.apache.kafkaesqueesque.common.TopicPartition;
v := @parameter: long;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: void seek(org.apache.kafkaesqueesque.common.TopicPartition,long)>(v, v);
return;
}
public void seek(org.apache.kafkaesqueesque.common.TopicPartition, org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.common.TopicPartition v;
org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata v;
long v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: org.apache.kafkaesqueesque.common.TopicPartition;
v := @parameter: org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata: long offset()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: void seek(org.apache.kafkaesqueesque.common.TopicPartition,long)>(v, v);
return;
}
public synchronized org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata committed(org.apache.kafkaesqueesque.common.TopicPartition)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.common.TopicPartition v;
java.util.Map v;
java.util.Set v;
java.lang.Object v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: org.apache.kafkaesqueesque.common.TopicPartition;
v = staticinvoke <java.util.Collections: java.util.Set singleton(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map committed(java.util.Set)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata committed(org.apache.kafkaesqueesque.common.TopicPartition, java.time.Duration)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.common.TopicPartition v;
java.time.Duration v;
org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: org.apache.kafkaesqueesque.common.TopicPartition;
v := @parameter: java.time.Duration;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata committed(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
return v;
}
public synchronized java.util.Map committed(java.util.Set)
{
java.util.function.Predicate v;
java.util.Set v;
java.util.function.Function v, v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.stream.Stream v, v;
java.util.Map v;
java.lang.Object v;
java.util.stream.Collector v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Set;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = interfaceinvoke v.<java.util.Set: java.util.stream.Stream stream()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map committed>;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.apache.kafkaesqueesque.clients.consumer.MockConsumer$containsKey__543: java.util.function.Predicate bootstrap$(java.util.Map)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <org.apache.kafkaesqueesque.clients.consumer.MockConsumer$lambda_committed_3__544: java.util.function.Function bootstrap$()>();
v = staticinvoke <org.apache.kafkaesqueesque.clients.consumer.MockConsumer$lambda_committed_4__545: java.util.function.Function bootstrap$(org.apache.kafkaesqueesque.clients.consumer.MockConsumer)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toMap(java.util.function.Function,java.util.function.Function)>(v, v);
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
return v;
}
public synchronized java.util.Map committed(java.util.Set, java.time.Duration)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.time.Duration v;
java.util.Map v;
java.util.Set v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Set;
v := @parameter: java.time.Duration;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map committed(java.util.Set)>(v);
return v;
}
public synchronized long position(org.apache.kafkaesqueesque.common.TopicPartition)
{
long v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition v;
java.lang.IllegalArgumentException v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.common.TopicPartition v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v, v, v;
boolean v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: org.apache.kafkaesqueesque.common.TopicPartition;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: boolean isAssigned(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
if v != 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("You can only check the position for partitions assigned to this consumer.");
throw v;
label:
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition position(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
if v != null goto label;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void updateFetchPosition(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition position(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
label:
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition: long offset>;
return v;
}
public synchronized long position(org.apache.kafkaesqueesque.common.TopicPartition, java.time.Duration)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.common.TopicPartition v;
java.time.Duration v;
long v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: org.apache.kafkaesqueesque.common.TopicPartition;
v := @parameter: java.time.Duration;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: long position(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
return v;
}
public synchronized void seekToBeginning(java.util.Collection)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy v;
java.util.Collection v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Collection;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = <org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy: org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy EARLIEST>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: void requestOffsetReset(java.util.Collection,org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy)>(v, v);
return;
}
public synchronized void updateBeginningOffsets(java.util.Map)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.Map v, v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Map;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map beginningOffsets>;
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
return;
}
public synchronized void seekToEnd(java.util.Collection)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy v;
java.util.Collection v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Collection;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = <org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy: org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy LATEST>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: void requestOffsetReset(java.util.Collection,org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy)>(v, v);
return;
}
public synchronized void addEndOffsets(java.util.Map)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Map;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void innerUpdateEndOffsets(java.util.Map,boolean)>(v, 0);
return;
}
public synchronized void updateEndOffsets(java.util.Map)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Map;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void innerUpdateEndOffsets(java.util.Map,boolean)>(v, 1);
return;
}
private void innerUpdateEndOffsets(java.util.Map, boolean)
{
java.util.Iterator v;
java.util.Set v;
java.util.ArrayList v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.Map v, v, v;
java.lang.Object v, v, v, v, v;
boolean v, v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Map;
v := @parameter: boolean;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map endOffsets>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != 0 goto label;
if v != null goto label;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v;
label:
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map endOffsets>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
return;
}
public synchronized java.util.Map metrics()
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = staticinvoke <java.util.Collections: java.util.Map emptyMap()>();
return v;
}
public synchronized java.util.List partitionsFor(java.lang.String)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.Map v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.lang.String;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map partitions>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public synchronized java.util.Map listTopics()
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map partitions>;
return v;
}
public synchronized void updatePartitions(java.lang.String, java.util.List)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.List v;
java.util.Map v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void ensureNotClosed()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map partitions>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public synchronized void pause(java.util.Collection)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.Iterator v;
java.util.Collection v;
java.util.Set v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
boolean v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Collection;
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: void pause(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Set paused>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
goto label;
label:
return;
}
public synchronized void resume(java.util.Collection)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.Iterator v;
java.util.Collection v;
java.util.Set v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
boolean v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Collection;
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: void resume(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Set paused>;
interfaceinvoke v.<java.util.Set: boolean remove(java.lang.Object)>(v);
goto label;
label:
return;
}
public synchronized java.util.Map offsetsForTimes(java.util.Map)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.lang.UnsupportedOperationException v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Map;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("Not implemented yet.");
throw v;
}
public synchronized java.util.Map beginningOffsets(java.util.Collection)
{
java.lang.IllegalStateException v;
java.util.Iterator v;
java.util.Collection v;
java.util.HashMap v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.common.KafkaException v, v;
java.util.Map v;
java.lang.Object v, v;
java.lang.String v;
boolean v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Collection;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.common.KafkaException offsetsException>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.common.KafkaException offsetsException>;
v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.common.KafkaException offsetsException> = null;
throw v;
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map beginningOffsets>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new java.lang.IllegalStateException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesqueesque.common.TopicPartition)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("The partition \u does not have a beginning offset.");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
return v;
}
public synchronized java.util.Map endOffsets(java.util.Collection)
{
java.lang.IllegalStateException v;
java.util.Iterator v;
java.util.Collection v;
java.util.HashMap v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.lang.Long v;
org.apache.kafkaesqueesque.common.KafkaException v, v;
java.util.Map v;
java.lang.Object v, v;
java.lang.String v;
boolean v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Collection;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.common.KafkaException offsetsException>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.common.KafkaException offsetsException>;
v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.common.KafkaException offsetsException> = null;
throw v;
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map endOffsets>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.lang.Long getEndOffset(java.util.List)>(v);
if v != null goto label;
v = new java.lang.IllegalStateException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesqueesque.common.TopicPartition)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("The partition \u does not have an end offset.");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
return v;
}
public synchronized void close()
{
java.util.concurrent.TimeUnit v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void close(long,java.util.concurrent.TimeUnit)>(30000L, v);
return;
}
public synchronized void close(long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
long v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: boolean closed> = 1;
return;
}
public synchronized boolean closed()
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
boolean v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: boolean closed>;
return v;
}
public synchronized void wakeup()
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.concurrent.atomic.AtomicBoolean v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.concurrent.atomic.AtomicBoolean wakeup>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(1);
return;
}
public synchronized void schedulePollTask(java.lang.Runnable)
{
java.lang.Throwable v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.Queue v, v;
java.lang.Runnable v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.lang.Runnable;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Queue pollTasks>;
entermonitor v;
label:
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Queue pollTasks>;
interfaceinvoke v.<java.util.Queue: boolean add(java.lang.Object)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public synchronized void scheduleNopPollTask()
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.lang.Runnable v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v = staticinvoke <org.apache.kafkaesqueesque.clients.consumer.MockConsumer$lambda_scheduleNopPollTask_5__546: java.lang.Runnable bootstrap$()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void schedulePollTask(java.lang.Runnable)>(v);
return;
}
public synchronized java.util.Set paused()
{
java.util.HashSet v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.Set v, v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v = new java.util.HashSet;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Set paused>;
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
return v;
}
private void ensureNotClosed()
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.lang.IllegalStateException v;
boolean v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: boolean closed>;
if v == 0 goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("This consumer has already been closed.");
throw v;
label:
return;
}
private void updateFetchPosition(org.apache.kafkaesqueesque.common.TopicPartition)
{
long v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.common.TopicPartition v;
java.util.Map v, v;
java.lang.Object v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v, v, v;
boolean v, v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: org.apache.kafkaesqueesque.common.TopicPartition;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: boolean isOffsetResetNeeded(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
if v == 0 goto label;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void resetOffsetPosition(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map committed>;
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: void requestOffsetReset(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void resetOffsetPosition(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map committed>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.OffsetAndMetadata: long offset()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: void seek(org.apache.kafkaesqueesque.common.TopicPartition,long)>(v, v);
label:
return;
}
private void resetOffsetPosition(org.apache.kafkaesqueesque.common.TopicPartition)
{
java.lang.IllegalStateException v, v;
org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy v, v, v;
long v;
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
org.apache.kafkaesqueesque.common.TopicPartition v;
org.apache.kafkaesqueesque.clients.consumer.NoOffsetForPartitionException v;
java.util.Map v, v;
java.lang.Object v, v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: org.apache.kafkaesqueesque.common.TopicPartition;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy resetStrategy(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
v = <org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy: org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy EARLIEST>;
if v != v goto label;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map beginningOffsets>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("MockConsumer didn\'t have beginning offset specified, but tried to seek to beginning");
throw v;
label:
v = <org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy: org.apache.kafkaesqueesque.clients.consumer.OffsetResetStrategy LATEST>;
if v != v goto label;
v = v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map endOffsets>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.lang.Long getEndOffset(java.util.List)>(v);
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("MockConsumer didn\'t have end offset specified, but tried to seek to end");
throw v;
label:
v = new org.apache.kafkaesqueesque.clients.consumer.NoOffsetForPartitionException;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.NoOffsetForPartitionException: void <init>(org.apache.kafkaesqueesque.common.TopicPartition)>(v);
throw v;
label:
v = virtualinvoke v.<java.lang.Long: long longValue()>();
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void seek(org.apache.kafkaesqueesque.common.TopicPartition,long)>(v, v);
return;
}
private java.lang.Long getEndOffset(java.util.List)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.List v;
int v;
java.lang.Object v;
boolean v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.List;
if v == null goto label;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
label:
return null;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= 1 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object remove(int)>(0);
goto label;
label:
interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
label:
return v;
}
public java.util.List partitionsFor(java.lang.String, java.time.Duration)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.util.List v;
java.time.Duration v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.lang.String;
v := @parameter: java.time.Duration;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.List partitionsFor(java.lang.String)>(v);
return v;
}
public java.util.Map listTopics(java.time.Duration)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.time.Duration v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.time.Duration;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map listTopics()>();
return v;
}
public java.util.Map offsetsForTimes(java.util.Map, java.time.Duration)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.time.Duration v;
java.util.Map v, v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Map;
v := @parameter: java.time.Duration;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map offsetsForTimes(java.util.Map)>(v);
return v;
}
public java.util.Map beginningOffsets(java.util.Collection, java.time.Duration)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.time.Duration v;
java.util.Collection v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Collection;
v := @parameter: java.time.Duration;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map beginningOffsets(java.util.Collection)>(v);
return v;
}
public java.util.Map endOffsets(java.util.Collection, java.time.Duration)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.time.Duration v;
java.util.Collection v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.util.Collection;
v := @parameter: java.time.Duration;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: java.util.Map endOffsets(java.util.Collection)>(v);
return v;
}
public org.apache.kafkaesqueesque.clients.consumer.ConsumerGroupMetadata groupMetadata()
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
return null;
}
public void close(java.time.Duration)
{
org.apache.kafkaesqueesque.clients.consumer.MockConsumer v;
java.time.Duration v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.MockConsumer;
v := @parameter: java.time.Duration;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.MockConsumer: void close()>();
return;
}
}