Examples of com.sun.appserv.ha.spi.BackingStore

com.sun.appserv.ha.spi.BackingStore
An object that stores a given Metadata against an id. This class defines the set of operations that a container could perform on a store.

An instance of BackingStore is created by calling BackingStoreFactory.createSimpleStore() method.

The BackingStore instance is created and used for storing data that belongs to a single application or container.

The store implementation must be thread safe.

@author Mahesh.Kannan@Sun.Com @author bhavanishankar@dev.java.net @author Larry.White@Sun.Com

     * @exception IOException
     */
    public void doSave(HAServletTimer haTimer) throws IOException {
        haTimer.setInternalLastAccessedTime(System.currentTimeMillis());
        byte[] timerState = ReplicationUtil.getByteArray(haTimer, isReplicationCompressionEnabled());
        BackingStore replicator = this.getBackingStore();
        SimpleMetadata simpleMetadata =
            SimpleMetadataFactory.createSimpleMetadata(
                haTimer.getVersion(),
                haTimer.getInternalLastAccessedTime(), //lastAccessedTime
                0L, //maxinactiveinterval
                timerState,
                haTimer.getExtraParameters() //containerExtraParam
            );
        if(haTimer.getParentSASId() != null) {
            String beKey = SipApplicationSessionUtil.getSipApplicationKey(haTimer.getParentSASId());
            simpleMetadata.setBeKey(beKey);
            simpleMetadata.setOwningInstanceName(ReplicationUtil.getInstanceName());
        }


        try {
            replicator.save(haTimer.getId(), //id
                    simpleMetadata, haTimer.isReplicated());
        } catch (BackingStoreException ex) {
            IOException ex1 =
                (IOException) new IOException("Error during save: " + ex.getMessage()).initCause(ex);
            throw ex1;

View Full Code Here

    }


    public ReplicationState getTransmitState(HAServletTimer haTimer) throws IOException {
        SipTransactionPersistentManager mgr
            = (SipTransactionPersistentManager)this.getSipSessionManager();
        BackingStore replicator = mgr.getServletTimerBackingStore();
        if(!(replicator instanceof JxtaBackingStoreImpl)) {
            return null;
        }
        JxtaBackingStoreImpl jxtaReplicator = (JxtaBackingStoreImpl)replicator;
        ReplicationState transmitState = null;

View Full Code Here

     */
    public void remove(String id) throws IOException {
        if(_logger.isLoggable(Level.FINE)) {
            _logger.fine("ServletTimerStoreImpl>>remove" + " id: " + id);
        }
        BackingStore replicator = this.getBackingStore();
        if(_logger.isLoggable(Level.FINE)) {
            _logger.fine("ServletTimerStoreImpl>>remove: replicator: " + replicator);
        }
        try {
            replicator.remove(id);
        } catch (BackingStoreException ex) {
            IOException ex1 =
                (IOException) new IOException("Error during remove: " + ex.getMessage()).initCause(ex);
            throw ex1;
        }

View Full Code Here

     */
    public void remove(String id, String originatingInstanceName, int count) throws IOException {
        if(_logger.isLoggable(Level.FINE)) {
            _logger.fine("ServletTimerStoreImpl>>remove" + " id: " + id + " originatingInstanceName: " + originatingInstanceName);
        }
        BackingStore replicator = this.getBackingStore();
        if(!(replicator instanceof JxtaBackingStoreImpl)) {
            return;
        }
        JxtaBackingStoreImpl jxtaReplicator
            = (JxtaBackingStoreImpl)replicator;

View Full Code Here

     * @param timer ServletTimerImpl to be saved
     *
     * @exception IOException if an input/output error occurs
     */
    public void updateContainerExtraParam(HAServletTimer timer) throws IOException {
        BackingStore replicator = this.getBackingStore();
        JxtaBackingStoreImpl jxtaReplicator = null;
        if(replicator instanceof JxtaBackingStoreImpl) {
            jxtaReplicator = (JxtaBackingStoreImpl)replicator;
        }
        if(_logger.isLoggable(Level.FINE)) {
            _logger.fine("ServletTimerStoreImpl>>updateContainerExtraParam: replicator: " + replicator);
        }
        try {
            SimpleMetadata smd = SimpleMetadataFactory.createSimpleMetadata(0L, //lastaccesstime not used for ServletTimer
                    timer.getVersion(), //version
                    timer.getExtraParameters());
            replicator.save(timer.getId(), smd, timer.isReplicated()); //containerExtraParams
        } catch (BackingStoreException ex) {
            IOException ex1 =
                (IOException) new IOException("Error during updateContainerExtraParam: " + ex.getMessage()).initCause(ex);
            throw ex1;
        }

View Full Code Here

    private ReplicationState findSessionViaBroadcast(String id, String version)
        throws BackingStoreException {
        if(_logger.isLoggable(Level.FINE)) {
            _logger.fine("SipSessionStoreImpl>>findSessionViaBroadcast");                       
        }        
        BackingStore replicator = this.getBackingStore();
        JxtaBackingStoreImpl jxtaReplicator = null;
        if(replicator instanceof JxtaBackingStoreImpl) {
            jxtaReplicator = (JxtaBackingStoreImpl)replicator;
        }
        if(_logger.isLoggable(Level.FINE)) {

View Full Code Here

     *
     * @exception IOException
     */
    public void doSave(HASipSession haSession) throws IOException {
        byte[] sessionState = ReplicationUtil.getByteArray(haSession, isReplicationCompressionEnabled());
        BackingStore replicator = this.getBackingStore();
        SimpleMetadata simpleMetadata =        
            SimpleMetadataFactory.createSimpleMetadata(
                haSession.getVersion(),
                haSession.getInternalLastAccessedTime(),
                0L, //maxinactiveinterval
                sessionState,
                haSession.getExtraParameters() //containerExtraParam
            );       
        if(haSession.getParentSASId() != null) {
            String beKey = SipApplicationSessionUtil.getSipApplicationKey(haSession.getParentSASId());
            simpleMetadata.setBeKey(beKey);
            simpleMetadata.setOwningInstanceName(ReplicationUtil.getInstanceName());
        }
                
        try {        
            replicator.save(haSession.getId(), //id
                    simpleMetadata, haSession.isReplicated());
        } catch (BackingStoreException ex) {
            IOException ex1 = 
                (IOException) new IOException("Error during save: " + ex.getMessage()).initCause(ex);
            throw ex1;

View Full Code Here

    }


    public ReplicationState getTransmitState(HASipSession haSession) throws IOException {
        SipTransactionPersistentManager mgr
            = (SipTransactionPersistentManager)this.getSipSessionManager();
        BackingStore replicator = mgr.getSipSessionBackingStore();
        if(!(replicator instanceof JxtaBackingStoreImpl)) {
            return null;
        }
        JxtaBackingStoreImpl jxtaReplicator = (JxtaBackingStoreImpl)replicator;
        ReplicationState transmitState = null;

View Full Code Here

     */
    public void remove(String id) throws IOException {
        if(_logger.isLoggable(Level.FINE)) {
            _logger.fine("SipSessionStoreImpl>>remove" + " id: " + id);                       
        } 
        BackingStore replicator = this.getBackingStore();
        if(_logger.isLoggable(Level.FINE)) {
            _logger.fine("SipSessionStoreImpl>>remove: replicator: " + replicator);                       
        }        
        try {
            replicator.remove(id);
        } catch (BackingStoreException ex) {
            IOException ex1 = 
                (IOException) new IOException("Error during remove: " + ex.getMessage()).initCause(ex);
            throw ex1;       
        }

View Full Code Here

     *
     * @exception IOException if an input/output error occurs
     */    
    public void updateContainerExtraParam(HASipSession sipSession)
            throws IOException {
        BackingStore replicator = this.getBackingStore();
        JxtaBackingStoreImpl jxtaReplicator = null;
        if(replicator instanceof JxtaBackingStoreImpl) {
            jxtaReplicator = (JxtaBackingStoreImpl)replicator;
        }
        if(_logger.isLoggable(Level.FINE)) {
            _logger.fine("SipSessionStoreImpl>>updateContainerExtraParam: replicator: " + replicator);                       
        }         
        try {
            SimpleMetadata smd = SimpleMetadataFactory.createSimpleMetadata(
                    sipSession.getInternalLastAccessedTime(), //internallastaccesstime
                    sipSession.getVersion(), //version
                    sipSession.getExtraParameters());
            replicator.save(sipSession.getId(), smd, sipSession.isReplicated()); //containerExtraParams
        } catch (BackingStoreException ex) {
            IOException ex1 = 
                (IOException) new IOException("Error during updateContainerExtraParam: " + ex.getMessage()).initCause(ex);
            throw ex1;
        }

View Full Code Here

0 1 2 3 4 5 6 7

TOP

Related Classes of com.sun.appserv.ha.spi.BackingStore

com.sun.ejb.ee.sfsb.store.ReplicatedEjbStore

com.sun.ejb.ee.sfsb.store.ReplicatedSFSBStoreManager

com.sun.enterprise.ee.web.authenticator.ReplicationSingleSignOn

com.sun.enterprise.ee.web.authenticator.ReplicationSSOStore

com.sun.enterprise.ee.web.sessmgmt.ReplicationAttributeStore

com.sun.enterprise.ee.web.sessmgmt.ReplicationManagerBase

com.sun.enterprise.ee.web.sessmgmt.ReplicationStore

org.jvnet.glassfish.comms.replication.dialogmgmt.DialogFragmentStoreImpl

org.jvnet.glassfish.comms.replication.dialogmgmt.ReplicationDialogFragmentManager

org.jvnet.glassfish.comms.replication.sessmgmt.ServletTimerStoreImpl

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.