Examples of org.apache.activemq.memory.list.SimpleMessageList

org.apache.activemq.memory.list.SimpleMessageList
A simple fixed size {@link MessageList} where there is a single, fixed sizelist that all messages are added to for simplicity. Though this will lead to possibly slow recovery times as many more messages than is necessary will have to be iterated through for each subscription. @version $Revision: 1.1 $

    // Implementation methods


    // -------------------------------------------------------------------------
    protected MessageList createMessageList() {
        if (useSharedBuffer) {
            return new SimpleMessageList(maximumSize);
        } else {
            return new DestinationBasedMessageList(maximumSize);
        }
    }

View Full Code Here

    // Implementation methods
    
    // -------------------------------------------------------------------------
    protected MessageList createMessageList() {
        if (useSharedBuffer) {
            return new SimpleMessageList(maximumSize);
        }
        else {
            return new DestinationBasedMessageList(maximumSize);
        }
    }

View Full Code Here

    // Implementation methods


    // -------------------------------------------------------------------------
    protected MessageList createMessageList() {
        if (useSharedBuffer) {
            return new SimpleMessageList(maximumSize);
        } else {
            return new DestinationBasedMessageList(maximumSize);
        }
    }

View Full Code Here

    // Implementation methods


    // -------------------------------------------------------------------------
    protected MessageList createMessageList() {
        if (useSharedBuffer) {
            return new SimpleMessageList(maximumSize);
        } else {
            return new DestinationBasedMessageList(maximumSize);
        }
    }

View Full Code Here

    // Implementation methods


    // -------------------------------------------------------------------------
    protected MessageList createMessageList() {
        if (useSharedBuffer) {
            return new SimpleMessageList(maximumSize);
        } else {
            return new DestinationBasedMessageList(maximumSize);
        }
    }

View Full Code Here

TOP

Related Classes of org.apache.activemq.memory.list.SimpleMessageList

org.apache.activemq.broker.region.MessageReference

org.apache.activemq.broker.region.policy.FixedSizedSubscriptionRecoveryPolicy

org.apache.activemq.command.Message

org.apache.activemq.filter.DestinationFilter

java.util.List

java.util.ArrayList

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.