MemoryMessageQueue

Overview

Package

Class

Use

Deprecated

Index

Home >> All >> com >> presumo >> jms >> plugin >> [ implementation overview ]

PREV CLASS NEXT CLASS

SUMMARY:

JAVADOC |

Sourc code of com.presumo.jms.plugin.implementation.MemoryMessageQueue

SOURCE |

Download com.presumo.jms.plugin.implementation.MemoryMessageQueue

DOWNLOAD | NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

com.presumo.jms.plugin.implementation
Class MemoryMessageQueue

java.lang.Object
  com.presumo.jms.plugin.implementation.MemoryMessageQueue

All Implemented Interfaces:: com.presumo.jms.plugin.MessageQueue

public class MemoryMessageQueue
extends java.lang.Object
implements com.presumo.jms.plugin.MessageQueue

Implementation of the MessageQueue interface in which all messages reside in memory. Used by RemoteSession and JmsSession due to some nasty design shortcuts. Currently also used by Router, but that will eventually be replaced by an implementation that transactionally writes persistent messages to disk and leaves non-persistent messages in memory.

Field Summary

private java.util.LinkedList list


Constructor Summary

MemoryMessageQueue()


Method Summary

void close()


void delete(java.lang.String key)


void delete(java.lang.String[] keys)


com.presumo.jms.message.JmsMessage getNext()


com.presumo.jms.message.JmsMessage[] getNext(int batchsize)


boolean isPersistent()
          Implementations must implement this method in order to indicate if the given message queue stores persistent message in non-volatile storage.

void push(com.presumo.jms.message.JmsMessage msg)


void push(com.presumo.jms.message.JmsMessage[] msgs)


int size()


Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

list

private final java.util.LinkedList list

Constructor Detail