Examples of MemoryBoundedQueueManager

org.activemq.io.util.MemoryBoundedQueueManager
A factory manager for MemoryBoundedQueue and also ensures that the maximum memory used by all active MemoryBoundedQueues cewated by this instance stays within the memory usage bounds set. @version $Revision: 1.1.1.1 $
org.activemq.message.util.MemoryBoundedQueueManager
A factory manager for MemoryBoundedQueue and also ensures that the maximum memory used by all active MemoryBoundedQueues cewated by this instance stays within the memory usage bounds set. @version $Revision: 1.1.1.1 $
org.codehaus.activemq.message.util.MemoryBoundedQueueManager
A factory manager for MemoryBoundedQueue and also ensures that the maximum memory used by all active MemoryBoundedQueues cewated by this instance stays within the memory usage bounds set. @version $Revision: 1.2 $

Examples of org.activemq.io.util.MemoryBoundedQueueManager

    this.started = new SynchronizedBoolean(false);
    this.startTime = System.currentTimeMillis();
    this.prefetchPolicy = new ActiveMQPrefetchPolicy();
    this.memoryManager = new MemoryBoundedObjectManager(clientID,
        DEFAULT_CONNECTION_MEMORY_LIMIT);
    this.boundedQueueManager = new MemoryBoundedQueueManager(memoryManager);
    this.memoryManager.addCapacityEventListener(this);
    boolean transactional = this instanceof XAConnection;
    factoryStats = factory.getFactoryStats();
    factoryStats.addConnection(this);
    stats = new JMSConnectionStatsImpl(sessions, transactional);

View Full Code Here

Examples of org.activemq.io.util.MemoryBoundedQueueManager

    this.started = new SynchronizedBoolean(false);
    this.startTime = System.currentTimeMillis();
    this.prefetchPolicy = new ActiveMQPrefetchPolicy();
    this.memoryManager = new MemoryBoundedObjectManager(clientID,
        DEFAULT_CONNECTION_MEMORY_LIMIT);
    this.boundedQueueManager = new MemoryBoundedQueueManager(memoryManager);
    this.memoryManager.addCapacityEventListener(this);
    boolean transactional = this instanceof XAConnection;
    factoryStats = factory.getFactoryStats();
    factoryStats.addConnection(this);
    stats = new JMSConnectionStatsImpl(sessions, transactional);

View Full Code Here

Examples of org.activemq.io.util.MemoryBoundedQueueManager

    this.started = new SynchronizedBoolean(false);
    this.startTime = System.currentTimeMillis();
    this.prefetchPolicy = new ActiveMQPrefetchPolicy();
    this.memoryManager = new MemoryBoundedObjectManager(clientID,
        DEFAULT_CONNECTION_MEMORY_LIMIT);
    this.boundedQueueManager = new MemoryBoundedQueueManager(memoryManager);
    this.memoryManager.addCapacityEventListener(this);
    boolean transactional = this instanceof XAConnection;
    factoryStats = factory.getFactoryStats();
    factoryStats.addConnection(this);
    stats = new JMSConnectionStatsImpl(sessions, transactional);

View Full Code Here

Examples of org.activemq.io.util.MemoryBoundedQueueManager


    public DefaultBroker(String brokerName, String brokerClusterName, MemoryBoundedObjectManager memoryManager) {
        this.brokerName = brokerName;
        this.brokerClusterName = brokerClusterName;
        this.memoryManager = memoryManager;
        queueManager = new MemoryBoundedQueueManager(memoryManager);
        setDelegate(memoryManager);
        containerManagerMap = new ConcurrentHashMap();
        consumerInfoListeners = new CopyOnWriteArrayList();
        this.advisory = new AdvisorySupport(this);
    }

View Full Code Here

Examples of org.activemq.io.util.MemoryBoundedQueueManager

    this.started = new SynchronizedBoolean(false);
    this.startTime = System.currentTimeMillis();
    this.prefetchPolicy = new ActiveMQPrefetchPolicy();
    this.memoryManager = new MemoryBoundedObjectManager(clientID,
        DEFAULT_CONNECTION_MEMORY_LIMIT);
    this.boundedQueueManager = new MemoryBoundedQueueManager(memoryManager);
    this.memoryManager.addCapacityEventListener(this);
    boolean transactional = this instanceof XAConnection;
    factoryStats = factory.getFactoryStats();
    factoryStats.addConnection(this);
    stats = new JMSConnectionStatsImpl(sessions, transactional);

View Full Code Here

Examples of org.activemq.io.util.MemoryBoundedQueueManager

    
    public void setUp() throws Exception {
      // setup memory space for just 1 message
      this.memoryManager = new MemoryBoundedObjectManager("testmanager", MESSAGE_SIZE);
      assertEquals("Total memory used must be zero", 0, this.memoryManager.getTotalMemoryUsedSize());
      this.queueManager = new MemoryBoundedQueueManager(this.memoryManager);
      //this.queue = this.queueManager.getMemoryBoundedQueue(QUEUE_NAME);
      this.transientQueueMCM = new TransientQueueBoundedMessageManager(this.queueManager,null,null);
      this.transientQueueMCM.start();
      this.client = new BrokerClientStub();
    }

View Full Code Here

Examples of org.activemq.io.util.MemoryBoundedQueueManager


    public DefaultBroker(String brokerName, String brokerClusterName, MemoryBoundedObjectManager memoryManager) {
        this.brokerName = brokerName;
        this.brokerClusterName = brokerClusterName;
        this.memoryManager = memoryManager;
        queueManager = new MemoryBoundedQueueManager(memoryManager);
        setDelegate(memoryManager);
        containerManagerMap = new ConcurrentHashMap();
        consumerInfoListeners = new CopyOnWriteArrayList();
        this.advisory = new AdvisorySupport(this);
    }

View Full Code Here

Examples of org.activemq.message.util.MemoryBoundedQueueManager

        this.connectionMetaData = new ActiveMQConnectionMetaData();
        this.started = new SynchronizedBoolean(false);
        this.startTime = System.currentTimeMillis();
        this.prefetchPolicy = new ActiveMQPrefetchPolicy();
        this.memoryManager = new MemoryBoundedObjectManager(clientID, DEFAULT_CONNECTION_MEMORY_LIMIT);
        this.boundedQueueManager = new MemoryBoundedQueueManager(memoryManager);
        this.memoryManager.addCapacityEventListener(this);
        boolean transactional = this instanceof XAConnection;
        factoryStats = factory.getFactoryStats();
        factoryStats.addConnection(this);
        stats = new JMSConnectionStatsImpl(sessions, transactional);

View Full Code Here

Examples of org.activemq.message.util.MemoryBoundedQueueManager


    public DefaultBroker(String brokerName, String brokerClusterName, MemoryBoundedObjectManager memoryManager) {
        this.brokerName = brokerName;
        this.brokerClusterName = brokerClusterName;
        this.memoryManager = memoryManager;
        queueManager = new MemoryBoundedQueueManager(memoryManager);
        setDelegate(memoryManager);
        containerManagerMap = new ConcurrentHashMap();
        consumerInfoListeners = new CopyOnWriteArrayList();
        this.advisory = new AdvisorySupport(this);
    }

View Full Code Here

Examples of org.codehaus.activemq.message.util.MemoryBoundedQueueManager

        this.connectionMetaData = new ActiveMQConnectionMetaData();
        this.closed = new SynchronizedBoolean(false);
        this.started = new SynchronizedBoolean(false);
        this.startTime = System.currentTimeMillis();
        this.prefetchPolicy = new ActiveMQPrefetchPolicy();
        this.boundedQueueManager = new MemoryBoundedQueueManager(clientID, DEFAULT_CONNECTION_MEMORY_LIMIT);
        this.boundedQueueManager.addCapacityEventListener(this);
        boolean transactional = this instanceof XAConnection;
        factoryStats = factory.getFactoryStats();
        factoryStats.addConnection(this);
        stats = new JMSConnectionStatsImpl(sessions, transactional);

View Full Code Here

0 1 2

TOP

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.