weblogic.wsee.reliability2.sequence

Class SourceSequenceManager

java.lang.Object

weblogic.wsee.reliability2.sequence.SequenceManager<SourceSequence,DestinationSequence>

weblogic.wsee.reliability2.sequence.SourceSequenceManager

public class SourceSequenceManager
extends SequenceManager<SourceSequence,DestinationSequence>

Manages access to SourceSequence instances used for sending sequence messages

Excluded in public API Reference.

Field Summary

Fields

Modifier and Type	Field and Description
private static java.lang.String	DESTINATION_ID

Fields inherited from class weblogic.wsee.reliability2.sequence.SequenceManager

_ioMgr, _peer, _store

Constructor Summary

Constructors

Constructor and Description
SourceSequenceManager(com.oracle.state.persistence.Store<SourceSequence> store)

Method Summary

Modifier and Type	Method and Description
protected void	addAlternateKeySpecsToList(java.util.List<com.oracle.state.ext.query.AlternateKeySpec> specs)
DestinationSequenceManager	getPeer()
SourceSequence	getSequence(WsrmConstants.RMVersion rmVersion, java.lang.String id, boolean allowNonExistent) Allows retrieval of a DestinationSequence via its source CreateSequence message ID or destination side sequence ID.
protected SourceSequence	getSequenceUsingAlternateKeys(WsrmConstants.RMVersion rmVersion, java.lang.String id)
boolean	updateSequence(SourceSequence oldSeq, SourceSequence seq) Update the given sequence, and store it back to persistent store as needed.

Methods inherited from class weblogic.wsee.reliability2.sequence.SequenceManager

addSequence, close, getIoMgr, getSequence, getStore, getUnknownSequenceLogMessage, internalUnsetStoreListener, listenToStore, listSequences, open, removeSequence, setIoMgr, setPeer, setStoreListener

Methods inherited from class java.lang.Object

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

Field Detail

DESTINATION_ID

private static final java.lang.String DESTINATION_ID

See Also:

Constant Field Values

Constructor Detail

SourceSequenceManager

public SourceSequenceManager(com.oracle.state.persistence.Store<SourceSequence> store)

Method Detail

addAlternateKeySpecsToList

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

Overrides:

addAlternateKeySpecsToList in class SequenceManager<SourceSequence,DestinationSequence>

getSequenceUsingAlternateKeys

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

Overrides:

getSequenceUsingAlternateKeys in class SequenceManager<SourceSequence,DestinationSequence>

getPeer

public DestinationSequenceManager getPeer()

Overrides:

getPeer in class SequenceManager<SourceSequence,DestinationSequence>

updateSequence

public boolean updateSequence(SourceSequence oldSeq,
                              SourceSequence seq)
                       throws UnknownSourceSequenceException,
                              weblogic.wsee.reliability2.io.StaleSequenceException

Update the given sequence, and store it back to persistent store as needed.

Overrides:

updateSequence in class SequenceManager<SourceSequence,DestinationSequence>

Throws:

UnknownSourceSequenceException

weblogic.wsee.reliability2.io.StaleSequenceException

getSequence

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

Allows retrieval of a DestinationSequence via its source CreateSequence message ID or destination side sequence ID. We allow lookup via source CreateSequence message ID to help us detect duplicate CreateSequence messages (say the network or client resends a message we already got)

Overrides:

getSequence in class SequenceManager<SourceSequence,DestinationSequence>

Parameters:

id - The source CreateSequence message ID or destination side sequence ID of the sequence to get

allowNonExistent - If false, and the requested sequence cannot be found, treating the given id as either a CreateSequence message ID or destination side sequence ID, then UnknownDestinationSequenceException is thrown.

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.

Returns:

The SourceSequence corresponding to the given ID

Throws:

UnknownDestinationSequenceException - If the given sequence cannot be found and allowNonExistent = false.

UnknownSourceSequenceException