weblogic.jms.common

Class SingularAggregatableManager

java.lang.Object

weblogic.jms.common.SingularAggregatableManager

public final class SingularAggregatableManager
extends java.lang.Object

Excluded in public API Reference.

SingularAggregatableManager is singleton for managing SingularResources

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	SingularAggregatableManager.SingularUnbindOnConflictThread

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Hashtable	boundAggregatables
private JMSService	jmsService
private static weblogic.security.acl.internal.AuthenticatedSubject	kernelId
private java.util.Hashtable	pendingRequests
private java.lang.String	serverName

Constructor Summary

Constructors

Constructor and Description
SingularAggregatableManager(JMSService jmsService)

Method Summary

Modifier and Type	Method and Description
void	aggregatableDidBind(java.lang.String jndiName, SingularAggregatable sAg)
private weblogic.jms.dispatcher.JMSDispatcher	findLeader()
static SingularAggregatableManager	findThrowsJMSException()
private static void	sendFailedToBind(SingularAggregatable sAg, LeaderBindResponse lbr)
java.lang.String	singularBind(java.lang.String jndiName, SingularAggregatable sAg)
java.lang.String	singularBindFinish(SingularAggregatable sAg, weblogic.jms.dispatcher.Request parentRequest)
void	singularBindStart(java.lang.String jndiName, SingularAggregatable sAg, weblogic.jms.dispatcher.Request parentRequest)
void	singularUnbind(java.lang.String jndiName)

Methods inherited from class java.lang.Object

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

Field Detail

kernelId

private static final weblogic.security.acl.internal.AuthenticatedSubject kernelId

pendingRequests

private final java.util.Hashtable pendingRequests

boundAggregatables

private final java.util.Hashtable boundAggregatables

serverName

private final java.lang.String serverName

jmsService

private final JMSService jmsService

Constructor Detail

SingularAggregatableManager

public SingularAggregatableManager(JMSService jmsService)

Method Detail

findThrowsJMSException

public static SingularAggregatableManager findThrowsJMSException()
                                                          throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Excluded in public API Reference.

This function retrieves a singular aggregatable manager which is a singleton object in the JVM managing singular aggregatables. Care should be taken because this can be called from finalize, and hence this method should be recursive safe.

findLeader

private weblogic.jms.dispatcher.JMSDispatcher findLeader()
                                                  throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Excluded in public API Reference.

Uses the lexical ordering of servers currently in the cluster in order to determine the leader. Returns the dispatcher for that leader.

singularBindStart

public void singularBindStart(java.lang.String jndiName,
                              SingularAggregatable sAg,
                              weblogic.jms.dispatcher.Request parentRequest)
                       throws javax.jms.JMSException

Parameters:

jndiName - The JNDI name that should be used when binding this object. This first portion of this name must match the getJNDIPrefix method from sAg.

sAg - The singular object to be bound into JNDI

parentRequest - The parent request asking for this bind operation This is the request which will obtain a client request and which will be resumed when the reply from this child has completed. Note that the state of this request will NOT have been changed due to the fact that states are not available at this level in the object heirarchy. If parentRequest is null then this is for a blocking request using the dispatcher of the leader

Throws:

JMSException - if there was some problem other than not being allowed to bind the name into JNDI. A further explanation will be in the JMSException

javax.jms.JMSException

Excluded in public API Reference.

Will bind this aggregatable into JNDI if there is a good possibility that no-one else in the cluster has this fellow bound already. Will begin the work of binding by asking the leader whether or not this object can be bound.

sendFailedToBind

private static void sendFailedToBind(SingularAggregatable sAg,
                                     LeaderBindResponse lbr)

Parameters:

sAg - The aggregatable we failed to bind. Must have its JNDI name set

lbr - The response we failed to complete properly

Excluded in public API Reference.

This sends the failed to bind response to the leader if for some strange reason we fail to bind this fellow into JNDI for any reason

singularBindFinish

public java.lang.String singularBindFinish(SingularAggregatable sAg,
                                           weblogic.jms.dispatcher.Request parentRequest)
                                    throws javax.jms.JMSException

Parameters:

sAg - The SingularAggregatable to bind

parentRequest - the parent request where the result should come from

Returns:

null on success, or the reason for failure

Throws:

JMSException - if there was an error binding into JNDI

javax.jms.JMSException

Excluded in public API Reference.

This method finishes the bind request, returning the results of the bind request. Note that this function will block if the response has not come back yet for this request

singularBind

public java.lang.String singularBind(java.lang.String jndiName,
                                     SingularAggregatable sAg)
                              throws javax.jms.JMSException

Parameters:

jndiName - The JNDI name that should be used when binding this object. This first portion of this name must match the getJNDIPrefix method from sAg.

sAg - The singular object to be bound into JNDI

Returns:

null on success, or the reason for failure

Throws:

JMSException - if there was an error binding into JNDI

javax.jms.JMSException

Excluded in public API Reference.

This is a bind of a singular aggregatable call that blocks and does its work synchronously

singularUnbind

public void singularUnbind(java.lang.String jndiName)
                    throws javax.jms.JMSException

Parameters:

jndiName - The name to unbind

Throws:

JMSException - if there was some problem unbinding something

javax.jms.JMSException

Excluded in public API Reference.

This method should be used whenever an unbind request for an Aggregatable is made

aggregatableDidBind

public void aggregatableDidBind(java.lang.String jndiName,
                                SingularAggregatable sAg)

Parameters:

jndiName - The name under which this SingularAggregatable was bound

sAg - The SingularAggregatable which has been bound

Excluded in public API Reference.

This function should be called whenever a SingularAggregatable is bound so that we can clean up any dirty little secrets. Notice that it is here that the possibility of a conflict will arise, and where the conflict callback of the SingularAggregatable may be called