4n  .io/moquette/broker/AbstractSessionMessageQueue()V5io/moquette/persistence/SegmentPersistentQueue$SerDes   5(Lio/moquette/persistence/SegmentPersistentQueue$1;)V  .io/moquette/persistence/SegmentPersistentQueueserdes7Lio/moquette/persistence/SegmentPersistentQueue$SerDes;  segmentedQueue'Lio/moquette/broker/unsafequeues/Queue;  checkEnqueuePreconditions(Ljava/lang/Object;)V  toBytesK(Lio/moquette/broker/SessionRegistry$EnqueuedMessage;)Ljava/nio/ByteBuffer;  ! "#%io/moquette/broker/unsafequeues/Queueenqueue(Ljava/nio/ByteBuffer;)V%.io/moquette/broker/unsafequeues/QueueException'java/lang/RuntimeException &) *(Ljava/lang/Throwable;)V , -checkDequeuePreconditions / 01dequeue()Ljava/util/Optional; 345 67java/util/Optional isPresent()Z 39 :;get()Ljava/lang/Object;=java/nio/ByteBuffer ? @A fromBytesK(Ljava/nio/ByteBuffer;)Lio/moquette/broker/SessionRegistry$EnqueuedMessage; C D7isEmpty F GHclosedZ J 0K6()Lio/moquette/broker/SessionRegistry$EnqueuedMessage;M2io/moquette/broker/SessionRegistry$EnqueuedMessage O "P7(Lio/moquette/broker/SessionRegistry$EnqueuedMessage;)V*(Lio/moquette/broker/unsafequeues/Queue;)VCodeLineNumberTableLocalVariableTablethis0Lio/moquette/persistence/SegmentPersistentQueue;e0Lio/moquette/broker/unsafequeues/QueueException;message4Lio/moquette/broker/SessionRegistry$EnqueuedMessage;payloadLjava/nio/ByteBuffer; StackMapTableLjava/util/Optional;contentLocalVariableTypeTable+Ljava/util/Optional; closeAndPurge SignaturefLio/moquette/broker/AbstractSessionMessageQueue; SourceFileSegmentPersistentQueue.java InnerClassesSerDesj0io/moquette/persistence/SegmentPersistentQueue$1l"io/moquette/broker/SessionRegistryEnqueuedMessage! QRV**Y *+SusvwTUV"PR$*+* +M*, N&Y-($S{}#T* WX$UV$YZ[\] L<$ 0KR3*+*.L M&Y,(+2+8 $S&   "*T4 0^ WX3UV0^* _\` 0a0a] O$ 3D7R2*BST UVbR4*ES T UVA0;R/*IST UVA"R3 *+LNST  UVcdefg h iLkm