Package org.apache.activemq.kaha

Examples of org.apache.activemq.kaha.StoreEntry

88
89
90
91
92
93
94
95
96
97
98
    /**
     * @param key
     * @return the entry
     */
    public StoreEntry get(Object key) {
        StoreEntry result = map.get(key);
        if (result != null) {
            try {
                result = indexManager.refreshIndex((IndexItem)result);
            } catch (IOException e) {
                LOG.error("Failed to refresh entry", e);
View Full Code Here
95
96
97
98
99
100
101
102
103
     */
    public synchronized Object removeLast() {
        if (size == 0) {
            return null;
        }
        StoreEntry result = last;
        remove(last);
        return result;
    }
View Full Code Here
301
302
303
304
305
306
307
308
309
310
311
    }
    return result;
  }

    public synchronized StoreEntry getEntry(StoreEntry current) {
        StoreEntry result = null;
        if (current != null && current.getOffset() >= 0) {
            try {
                result = indexManager.getIndex(current.getOffset());
            } catch (IOException e) {
                throw new RuntimeException("Failed to index", e);
View Full Code Here
322
323
324
325
326
327
328
329
330
331
332
     * Update the indexes of a StoreEntry
     *
     * @param current
     */
    public synchronized StoreEntry refreshEntry(StoreEntry current) {
        StoreEntry result = null;
        if (current != null && current.getOffset() >= 0) {
            try {
                result = indexManager.refreshIndex((IndexItem)current);
            } catch (IOException e) {
                throw new RuntimeException("Failed to index", e);
View Full Code Here
63
64
65
66
67
68
69
70
71
72
73
    public int nextIndex() {
        int result = -1;
        if (nextItem != null) {
            synchronized (container) {
                nextItem = (IndexItem)list.refreshEntry(nextItem);
                StoreEntry next = list.getNextEntry(nextItem);
                if (next != null) {
                    result = container.getInternalList().indexOf(next);
                }
            }
        }
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
    public int previousIndex() {
        int result = -1;
        if (nextItem != null) {
            synchronized (container) {
                nextItem = (IndexItem)list.refreshEntry(nextItem);
                StoreEntry prev = list.getPrevEntry(nextItem);
                if (prev != null) {
                    result = container.getInternalList().indexOf(prev);
                }
            }
        }
View Full Code Here
636
637
638
639
640
641
642
643
     *
     * @param object
     * @return the entry in the Store
     */
    public synchronized StoreEntry placeLast(Object object) {
        StoreEntry item = internalAddLast(object);
        return item;
    }
View Full Code Here
648
649
650
651
652
653
654
655
     *
     * @param object
     * @return the location in the Store
     */
    public synchronized StoreEntry placeFirst(Object object) {
        StoreEntry item = internalAddFirst(object);
        return item;
    }
View Full Code Here
674
675
676
677
678
679
680
681
     * @param entry
     * @return the Object at that entry
     */
    public synchronized Object get(final StoreEntry entry) {
        load();
        StoreEntry entryToUse = refresh(entry);
        return getValue(entryToUse);
    }
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
    public void recoverNextMessages(int maxReturned, MessageRecoveryListener listener)
        throws Exception {
        lock.lock();
        try {
            StoreEntry entry = batchEntry;
            if (entry == null) {
                entry = messageContainer.getFirst();
            } else {
                entry = messageContainer.refresh(entry);
                if (entry != null) {
View Full Code Here
TOP

Related Classes of org.apache.activemq.kaha.StoreEntry

  • org.apache.activemq.kaha.impl.container.ContainerListIterator
  • org.apache.activemq.kaha.impl.container.ListContainerImpl
  • org.apache.activemq.kaha.impl.container.MapContainerImpl
  • org.apache.activemq.kaha.impl.index.DiskIndexLinkedList
  • org.apache.activemq.kaha.impl.index.hash.HashIndex
  • org.apache.activemq.kaha.impl.index.IndexBenchmark$Consumer
  • org.apache.activemq.kaha.impl.index.VMIndex
  • org.apache.activemq.kaha.impl.index.VMIndexLinkedList
  • org.apache.activemq.kaha.impl.IndexRootContainer
  • org.apache.activemq.store.kahadaptor.KahaMessageStore
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.