[jboss-user] [JBoss Messaging] - NullPersistenceManager Implementation

[vasu_suku@yahoo.com]

null-persistence-service.xml

<?xml version="1.0" encoding="UTF-8"?>
  | 
  | <!--
  |      Null persistence deployment descriptor.
  |  -->
  | 
  | <server>
  | 
  |    <mbean code="org.jboss.messaging.core.plugin.NullPersistenceManager"
  |       name="jboss.messaging:service=PersistenceManager">
  | 
  |    </mbean>
  |    
  | </server>

=============================================

NullPersistenceManager.java

/*
  |  * JBoss, Home of Professional Open Source
  |  * Copyright 2005, JBoss Inc., and individual contributors as indicated
  |  * by the @authors tag. See the copyright.txt in the distribution for a
  |  * full listing of individual contributors.
  |  *
  |  * This is free software; you can redistribute it and/or modify it
  |  * under the terms of the GNU Lesser General Public License as
  |  * published by the Free Software Foundation; either version 2.1 of
  |  * the License, or (at your option) any later version.
  |  *
  |  * This software is distributed in the hope that it will be useful,
  |  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  |  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  |  * Lesser General Public License for more details.
  |  *
  |  * You should have received a copy of the GNU Lesser General Public
  |  * License along with this software; if not, write to the Free
  |  * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
  |  * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
  |  */
  | 
  | package org.jboss.messaging.core.plugin;
  | 
  | 
  | import java.util.ArrayList;
  | import java.util.List;
  | 
  | import org.jboss.messaging.core.MessageReference;
  | import org.jboss.messaging.core.tx.Transaction;
  | import org.jboss.logging.Logger;
  | 
  | import org.jboss.messaging.core.plugin.contract.PersistenceManager;
  | 
  | 
  | 
  | import org.jboss.system.ServiceMBeanSupport;
  | 
  | 
  | 
  | 
  | 
  | public class NullPersistenceManager extends ServiceMBeanSupport implements PersistenceManager
  | {
  |    // Constants -----------------------------------------------------
  | 
  |    private static final Logger log = Logger.getLogger(NullPersistenceManager.class);
  | 
  | 
  | 
  |    // Static --------------------------------------------------------
  | 
  |    // Attributes ----------------------------------------------------
  | 
  |    private boolean trace = log.isTraceEnabled();
  | 
  | 
  | 
  |    // Constructors --------------------------------------------------
  | 
  |    public NullPersistenceManager() throws Exception
  |    {
  | 
  |    }
  | 
  | 
  | 
  |    // ServiceMBeanSupport overrides ---------------------------------
  | 
  |    protected void startService() throws Exception
  |    {
  | 
  |       log.debug(this + " started");
  |    }
  | 
  |    protected void stopService() throws Exception
  |    {
  |       log.debug(this + " stopped");
  |    }
  | 
  |    // PersistenceManager implementation -------------------------
  | 
  |    public Object getInstance()
  |    {
  |       return this;
  |    }
  | 
  | 
  |    public long reserveIDBlock(String counterName, int size) throws Exception
  |    {
  | 
  |       if (trace)
  |       {
  |          log.trace("Getting id block for counter: " + counterName + " ,size: " + size);
  |       }
  | 
  |       return 1;
  | 
  | 
  |    }
  | 
  | 
  |    public void updateReliableReferencesLoadedInRange(long channelID, long orderStart, long orderEnd) throws Exception
  |    {
  |       if (trace)
  |       {
  |          log.trace("Updating reliable references for channel " + channelID + " between " + orderStart + " and " + orderEnd);
  |       }
  | 
  | 
  |    }
  | 
  |    public int getNumberOfUnloadedReferences(long channelID) throws Exception
  |    {
  |       if (trace) { log.trace("getting number of unloaded references for channel [" + channelID + "]"); }
  | 
  | 
  |       return 0;
  | 
  |    }
  | 
  | 
  |    public List getMessages(List messageIds) throws Exception
  |    {
  |       if (trace)
  |       {
  |          log.trace("Getting batch of messages for " + messageIds);
  |       }
  | 
  | 
  |       return new ArrayList();
  | 
  | 
  |    }
  | 
  | 
  | 
  |    public void addReferences(long channelID, List references, boolean loaded) throws Exception
  |    {
  | 
  |    }
  | 
  |    public void removeReferences(long channelID, List references) throws Exception
  |    {
  |       if (trace) { log.trace(this + " Removing " + references.size() + " refs from channel " + channelID); }
  | 
  | 
  |    }
  | 
  |    public long getMinOrdering(long channelID) throws Exception
  |    {
  |       if (trace)
  |       {
  |          log.trace("Getting min ordering for channel " + channelID);
  |       }
  | 
  | 
  |       return 0;
  | 
  | 
  |    }
  | 
  | 
  | 
  |    public List getReferenceInfos(long channelID, long minOrdering, int number) throws Exception
  |    {
  |       if (trace)
  |       {
  |          log.trace("loading message reference info for channel " + channelID + " for " + number + " refs");
  |       }
  | 
  |       List refs = new ArrayList();
  | 
  |       return refs;
  | 
  | 
  |    }
  | 
  |    public void updateReferencesNotLoaded(long channelID, List references) throws Exception
  |    {
  | 
  | 
  |       if (trace)
  |       {
  |          log.trace("Updating references to not loaded for channel:" + channelID);
  |       }
  | 
  | 
  |    }
  | 
  |    public void addReference(long channelID, MessageReference ref, Transaction tx) throws Exception
  |    {
  | 
  |    }
  | 
  |    public void removeReference(long channelID, MessageReference ref, Transaction tx) throws Exception
  |    {
  | 
  |    }
  | 
  |    public void resetLoadedStatus(long channelID) throws Exception
  |    {
  |       if (trace) { log.trace("resetting all channel data for channel " + channelID); }
  | 
  | 
  |    }
  | 
  | 
  |    public List retrievePreparedTransactions() throws Exception
  |    {
  | 
  | 
  |       List transactions = new ArrayList();
  | 
  |       return transactions;
  | 
  | 
  |    }
  | 
  | 
  | 
  |    public String toString()
  |    {
  |       return "NullPersistenceManager[]";
  |    }
  | 
  |    public String getName()
  |    {
  |         return toString();
  |    }
  | 
  | 
  | 
  | }


=============================================
Error during deployment

006-10-17 22:21:29,578 ERROR [org.jboss.deployment.MainDeployer] could not create deployment: file:/C:/work/head/jboss-4.0.2/server/messaging/deploy/jboss-messaging.sar/null-persistence-service.xml
org.jboss.deployment.DeploymentException: Class does not expose a management interface: java.lang.Object; - nested throwable: (javax.management.NotCompliantMBeanException: Class does not expose a management interface: java.lang.Object)
	at org.jboss.system.ServiceConfigurator.install(ServiceConfigurator.java:143)





View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=3978971#3978971

Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=3978971