final class org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator extends java.lang.Object implements java.util.Iterator
{
private final org.apache.activemq.store.PList$PListIterator iterator;
final org.apache.activemq.broker.region.cursors.FilePendingMessageCursor this$0;
void <init>(org.apache.activemq.broker.region.cursors.FilePendingMessageCursor)
{
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor v;
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator v;
org.apache.activemq.store.PList$PListIterator v;
java.lang.RuntimeException v;
org.apache.activemq.store.PList v;
java.lang.Exception v;
v := @this: org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator;
v := @parameter: org.apache.activemq.broker.region.cursors.FilePendingMessageCursor;
v.<org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator: org.apache.activemq.broker.region.cursors.FilePendingMessageCursor this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
label:
v = virtualinvoke v.<org.apache.activemq.broker.region.cursors.FilePendingMessageCursor: org.apache.activemq.store.PList getDiskList()>();
v = interfaceinvoke v.<org.apache.activemq.store.PList: org.apache.activemq.store.PList$PListIterator iterator()>();
v.<org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator: org.apache.activemq.store.PList$PListIterator iterator> = v;
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
public boolean hasNext()
{
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator v;
boolean v;
org.apache.activemq.store.PList$PListIterator v;
v := @this: org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator;
v = v.<org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator: org.apache.activemq.store.PList$PListIterator iterator>;
v = interfaceinvoke v.<org.apache.activemq.store.PList$PListIterator: boolean hasNext()>();
return v;
}
public org.apache.activemq.broker.region.MessageReference next()
{
org.slf4j.Logger v;
org.apache.activemq.command.MessageId v;
java.io.IOException v;
java.lang.RuntimeException v;
org.apache.activemq.command.Message v;
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor v;
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator v;
org.apache.activemq.store.PList$PListIterator v;
java.lang.Object v, v;
org.apache.activemq.util.ByteSequence v;
v := @this: org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator;
label:
v = v.<org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator: org.apache.activemq.store.PList$PListIterator iterator>;
v = interfaceinvoke v.<org.apache.activemq.store.PList$PListIterator: java.lang.Object next()>();
v = v.<org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator: org.apache.activemq.broker.region.cursors.FilePendingMessageCursor this$0>;
v = virtualinvoke v.<org.apache.activemq.store.PListEntry: org.apache.activemq.util.ByteSequence getByteSequence()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.cursors.FilePendingMessageCursor: org.apache.activemq.command.Message getMessage(org.apache.activemq.util.ByteSequence)>(v);
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.command.MessageId getMessageId()>();
v = virtualinvoke v.<org.apache.activemq.store.PListEntry: java.lang.Object getLocator()>();
virtualinvoke v.<org.apache.activemq.command.MessageId: void setPlistLocator(java.lang.Object)>(v);
label:
return v;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.region.cursors.FilePendingMessageCursor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("I/O error", v);
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
catch java.io.IOException from label to label with label;
}
public void remove()
{
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator v;
org.apache.activemq.store.PList$PListIterator v;
v := @this: org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator;
v = v.<org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator: org.apache.activemq.store.PList$PListIterator iterator>;
interfaceinvoke v.<org.apache.activemq.store.PList$PListIterator: void remove()>();
return;
}
public void release()
{
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator v;
org.apache.activemq.store.PList$PListIterator v;
v := @this: org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator;
v = v.<org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator: org.apache.activemq.store.PList$PListIterator iterator>;
interfaceinvoke v.<org.apache.activemq.store.PList$PListIterator: void release()>();
return;
}
}