I've recently run into some trouble with my get() calls returning less history
entries than expected and have tracked the problem down to my history queue
sizes and the CacheQueueInterceptorPlugin.peak(int, int) method. Maybe it was
designed this way on purpose, but to me the implementation seems to have a bug:
public ArrayList peek(int numOfEntries, long numOfBytes) throws
XmlBlasterException {
synchronized(this.peekSync) {
return this.transientQueue.peek(numOfEntries, numOfBytes);
}
}
In my scenario I often only need to access the most recent message on a topic,
but occasionally need to access the full history. It makes sense to me to
configure my history queue like this:
queue/history/maxEntriesCache = 1
queue/history/maxEntries = 1000
so that I only cache what I use the most but still have a large amount of
history available when necessary. This is where the peek implementation
becomes a problem, since a get() call is forwarded to the topic's history queue
I can never get more history than the maxEntriesCache parameter. What is the
purpose of being able to store more entries persistently if I can only ever
access the number of transient entries? Shouldn't the implementation look more
like (pseudocode)
if (numEntries == -1 || numEntries > transientQueue.getMaxNumEntries()) {
return this.persistentQueue.peek(numOfEntries, numOfBytes());
} else {
return this.transientQueue.peek(numOfEntries, numOfBytes);
}
?
Thanks,
Craig McIlwee
Open Roads Consulting, Inc.
757-546-3401
http://www.openroadsconsulting.com
This e-mail communication (including any attachments) may contain confidential
and/or privileged material intended solely for the individual or entity to
which it is addressed. If you are not the intended recipient, you should
immediately stop reading this message and delete it from all computers that it
resides on. Any unauthorized reading, distribution, copying or other use of
this communication (or its attachments) is strictly prohibited. If you have
received this communication in error, please notify us immediately.
