weblogic.wsee.reliability2.sequence

Class SequenceManager<S extends Sequence,P extends Sequence>

java.lang.Object

weblogic.wsee.reliability2.sequence.SequenceManager<S,P>

Direct Known Subclasses:

DestinationSequenceManager, SourceSequenceManager

public abstract class SequenceManager<S extends Sequence,P extends Sequence>
extends java.lang.Object

Abstract base class that manages access to Sequence instances used for sending/receiving sequence messages

Excluded in public API Reference.

Field Summary

Fields

Modifier and Type	Field and Description
protected weblogic.wsee.reliability2.io.SequenceIOManager	_ioMgr
private com.oracle.state.persistence.Listener<S>	_listener
protected SequenceManager<P,S>	_peer
protected com.oracle.state.persistence.Store<S>	_store The map of record for sequences.
private java.lang.String	_type
private static java.lang.String	CREATE_SEQUENCE_MSG_ID
private static java.util.logging.Logger	LOGGER

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SequenceManager(com.oracle.state.persistence.Store<S> map) Construct the base sequence manager.

Method Summary

Modifier and Type	Method and Description
protected void	addAlternateKeySpecsToList(java.util.List<com.oracle.state.ext.query.AlternateKeySpec> specs)
boolean	addSequence(S seq) Add the given sequence to the set of sequences being managed.
void	close()
private com.oracle.state.ext.query.AlternateKeySpec[]	collectAlternateKeySpecs()
weblogic.wsee.reliability2.io.SequenceIOManager	getIoMgr()
SequenceManager<P,S>	getPeer()
S	getSequence(WsrmConstants.RMVersion rmVersion, java.lang.String id) Obtain a reference to the sequence with the given ID.
S	getSequence(WsrmConstants.RMVersion rmVersion, java.lang.String id, boolean allowNonExistent) Get a sequence by it's ID, optionally throwing an exception if it cannot be found.
protected S	getSequenceUsingAlternateKeys(WsrmConstants.RMVersion rmVersion, java.lang.String id)
com.oracle.state.persistence.Store<S>	getStore()
static java.lang.String	getUnknownSequenceLogMessage(boolean sourceSide, java.lang.String seqId)
void	internalUnsetStoreListener() Internal use only!
protected void	listenToStore()
java.util.Iterator<S>	listSequences()
void	open()
private void	parseType()
void	removeSequence(S seq)
void	setIoMgr(weblogic.wsee.reliability2.io.SequenceIOManager ioMgr)
void	setPeer(SequenceManager<P,S> peer)
void	setStoreListener(com.oracle.state.persistence.Listener<S> listener)
boolean	updateSequence(S oldSeq, S seq)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final java.util.logging.Logger LOGGER

CREATE_SEQUENCE_MSG_ID

private static final java.lang.String CREATE_SEQUENCE_MSG_ID

See Also:

Constant Field Values

_peer

protected SequenceManager<P extends Sequence,S extends Sequence> _peer

_ioMgr

protected weblogic.wsee.reliability2.io.SequenceIOManager _ioMgr

_store

protected com.oracle.state.persistence.Store<S extends Sequence> _store

The map of record for sequences. This map is generally a 'composite' map that allows us to use multiple stores all from one map interface. This 'composite' map is thread-safe, and doesn't require any additional locks.

_type

private java.lang.String _type

_listener

private com.oracle.state.persistence.Listener<S extends Sequence> _listener

Constructor Detail

SequenceManager

protected SequenceManager(com.oracle.state.persistence.Store<S> map)

Construct the base sequence manager. You must call setMap directly after this. The map parameter is the basic storage facility for sequences. This class will only use the following methods of Map

• containsKey
• values
• size
• get
• put
• remove

Method Detail

open

public void open()

collectAlternateKeySpecs

private com.oracle.state.ext.query.AlternateKeySpec[] collectAlternateKeySpecs()

addAlternateKeySpecsToList

protected void addAlternateKeySpecsToList(java.util.List<com.oracle.state.ext.query.AlternateKeySpec> specs)

getSequenceUsingAlternateKeys

protected S getSequenceUsingAlternateKeys(WsrmConstants.RMVersion rmVersion,
                                          java.lang.String id)

close

public void close()

getStore

public com.oracle.state.persistence.Store<S> getStore()

setPeer

public void setPeer(SequenceManager<P,S> peer)

getPeer

public SequenceManager<P,S> getPeer()

getIoMgr

public weblogic.wsee.reliability2.io.SequenceIOManager getIoMgr()

setIoMgr

public void setIoMgr(weblogic.wsee.reliability2.io.SequenceIOManager ioMgr)

setStoreListener

public void setStoreListener(com.oracle.state.persistence.Listener<S> listener)

internalUnsetStoreListener

public void internalUnsetStoreListener()

Internal use only!

listenToStore

protected void listenToStore()

parseType

private void parseType()

addSequence

public boolean addSequence(S seq)
                    throws WsrmException

Add the given sequence to the set of sequences being managed.

Parameters:

seq - The new sequence

Throws:

DuplicateSequenceException - If a sequence with the given ID already exists.

WsrmException - If any other error occurs adding the sequence.

updateSequence

public boolean updateSequence(S oldSeq,
                              S seq)
                       throws UnknownSequenceException,
                              weblogic.wsee.reliability2.io.StaleSequenceException

Throws:

UnknownSequenceException

weblogic.wsee.reliability2.io.StaleSequenceException

getSequence

public S getSequence(WsrmConstants.RMVersion rmVersion,
                     java.lang.String id)

Obtain a reference to the sequence with the given ID. Note, any changes made to this sequence should be considered 'pending' until a call to updateSequence is made.

Parameters:

rmVersion - Version used if an error must be thrown. Ok to just pass RMVersion.latest() if you don't know the actual version.

id - The sequence ID of the sequence you want to get.

Returns:

The sequence object (or null if it wasn't found)

getSequence

public S getSequence(WsrmConstants.RMVersion rmVersion,
                     java.lang.String id,
                     boolean allowNonExistent)
              throws UnknownSequenceException

Get a sequence by it's ID, optionally throwing an exception if it cannot be found.

Parameters:

rmVersion - Expected RM version, does not affect the lookup, but is propagated in any UnknownSequenceException that may be thrown. Ok to pass RMVersion.latest() if you don't know the version.

id - The ID of the sequence to retrieve.

allowNonExistent - If true, null can be returned if the sequence is not found, otherwise UnknownSequenceFault is thrown.

Returns:

The sequence with the given ID, or null if not found and allowNonExistent is true.

Throws:

UnknownSequenceException - If lookup fails and allowNonExistent is false.

listSequences

public java.util.Iterator<S> listSequences()

removeSequence

public void removeSequence(S seq)

getUnknownSequenceLogMessage

public static java.lang.String getUnknownSequenceLogMessage(boolean sourceSide,
                                                            java.lang.String seqId)