Package jdbm.helper

Examples of jdbm.helper.Tuple

141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
    }

    public synchronized void start() throws JMSException {
        try {
            // lets iterate through all IDs from the
            Tuple tuple = new Tuple();
            Long lastSequenceNumber = null;
            TupleBrowser iter = getOrderedIndex().browse();
            while (iter.getNext(tuple)) {
                lastSequenceNumber = (Long) tuple.getKey();
            }
            if (lastSequenceNumber != null) {
                this.lastSequenceNumber = lastSequenceNumber.longValue();
                if (log.isDebugEnabled()) {
                    log.debug("Last sequence number is: " + lastSequenceNumber + " for: " + this);
View Full Code Here
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
     * @return
     */
    protected Object findSequenceNumber(String messageID) throws IOException, AlreadyClosedException {
        log.warn("Having to table scan to find the sequence number for messageID: " + messageID);

        Tuple tuple = new Tuple();
        TupleBrowser iter = getOrderedIndex().browse();
        while (iter.getNext(tuple)) {
            Object value = tuple.getValue();
            if (messageID.equals(value)) {
                return tuple.getKey();
            }
        }
        return null;
    }
View Full Code Here
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
        return null;
    }

    public void removeAllMessages() throws JMSException {
        try {
            Tuple tuple = new Tuple();
            TupleBrowser iter = getOrderedIndex().browse();
            while (iter.getNext(tuple)) {               
                Object sequenceID = tuple.getKey();
                MessageIdentity messageIdentity = null;
                if (sequenceID != null) {
                    String messageID = (String) tuple.getValue();
                    if (messageID != null) {
                        getMessageTable().remove(messageID);
                    }
                    getOrderedIndex().remove(sequenceID);
                }
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
            Object lastAckedSequenceNumber = lastAcked.getSequenceNumber();

            // lets iterate through all IDs from the

            //Tuple tuple = new Tuple();
            Tuple tuple = getOrderedIndex().findGreaterOrEqual(lastAckedSequenceNumber);

            TupleBrowser iter = getOrderedIndex().browse();
            while (iter.getNext(tuple)) {
                Long sequenceNumber = (Long) tuple.getKey();
                if (sequenceNumber.compareTo(lastAckedSequenceNumber) > 0) {
                    ActiveMQMessage message = null;

                    // TODO we could probably tune this some more since we have tuple.getValue() already
                    message = getMessageBySequenceNumber(sequenceNumber);
View Full Code Here
39
40
41
42
43
44
45
46
47
48
49
50
51
        table.insert(new Long(124), "BAR", true);
        table.insert(new Long(125), "XYZ", true);
        table.insert(new Long(126), "ABC", true);
        table.insert(new Long(127), "DEF", true);

        Tuple tuple = new Tuple();
        TupleBrowser iter = table.browse();
        while (iter.getNext(tuple)) {
            Object key = tuple.getKey();
            System.out.println("Key " + key);
        }
        manager.stop();
    }
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
            Object lastAckedSequenceNumber = lastAcked.getSequenceNumber();

            // lets iterate through all IDs from the

            //Tuple tuple = new Tuple();
            Tuple tuple = getOrderedIndex().findGreaterOrEqual(lastAckedSequenceNumber);

            TupleBrowser iter = getOrderedIndex().browse();
            while (iter.getNext(tuple)) {
                Long sequenceNumber = (Long) tuple.getKey();
                if (sequenceNumber.compareTo(lastAckedSequenceNumber) > 0) {
                    ActiveMQMessage message = null;

                    // TODO we could probably tune this some more since we have tuple.getValue() already
                    message = getMessageBySequenceNumber(sequenceNumber);
View Full Code Here
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
        }
    }

    public synchronized void recover(QueueMessageContainer container) throws JMSException {
        try {
            Tuple tuple = new Tuple();
            TupleBrowser iter = getOrderedIndex().browse();
            while (iter.getNext(tuple)) {
                Long key = (Long) tuple.getKey();
                MessageIdentity messageIdentity = null;
                if (key != null) {
                    String messageID = (String) tuple.getValue();
                    if (messageID != null) {
                        messageIdentity = new MessageIdentity(messageID, key);
                    }
                }
                if (messageIdentity != null) {
View Full Code Here
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
    }

    public synchronized void start() throws JMSException {
        try {
            // lets iterate through all IDs from the
            Tuple tuple = new Tuple();
            Long lastSequenceNumber = null;
            TupleBrowser iter = getOrderedIndex().browse();
            while (iter.getNext(tuple)) {
                lastSequenceNumber = (Long) tuple.getKey();
            }
            if (lastSequenceNumber != null) {
                this.lastSequenceNumber = lastSequenceNumber.longValue();
                if (log.isDebugEnabled()) {
                    log.debug("Last sequence number is: " + lastSequenceNumber + " for: " + this);
View Full Code Here
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
     * @return
     */
    protected Object findSequenceNumber(String messageID) throws IOException, AlreadyClosedException {
        log.warn("Having to table scan to find the sequence number for messageID: " + messageID);

        Tuple tuple = new Tuple();
        TupleBrowser iter = getOrderedIndex().browse();
        while (iter.getNext(tuple)) {
            Object value = tuple.getValue();
            if (messageID.equals(value)) {
                return tuple.getKey();
            }
        }
        return null;
    }
View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
57
58
59
    }

    public ActiveMQXid[] getXids() throws XAException {
        try {
            List list = new ArrayList();
            Tuple tuple = new Tuple();
            TupleBrowser iter = database.browse();
            while (iter.getNext(tuple)) {
                list.add(tuple.getKey());
            }
            ActiveMQXid[] answer = new ActiveMQXid[list.size()];
            list.toArray(answer);
            return answer;
        }
View Full Code Here
TOP

Related Classes of jdbm.helper.Tuple

  • FamousPeople
  • jdbm.btree.BTree
  • jdbm.btree.TestBPage
  • jdbm.btree.TestBTree
  • org.activemq.store.jdbm.JdbmMessageStore
  • org.activemq.store.jdbm.JdbmTopicMessageStore
  • org.activemq.store.jdbm.OrderTest
  • org.apache.directory.server.core.partition.impl.btree.jdbm.JdbmBrowserBugTest
  • org.apache.directory.server.core.partition.impl.btree.jdbm.KeyBTreeCursorTest
  • org.apache.directory.server.core.partition.impl.btree.jdbm.KeyCursorTest
    • 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.