weblogic.jms.common

Class DistributedDestinationImpl

java.lang.Object

weblogic.jms.common.Destination

weblogic.jms.common.DestinationImpl

weblogic.jms.common.DistributedDestinationImpl

All Implemented Interfaces:

java.io.Externalizable, java.io.Serializable, java.lang.Cloneable, javax.jms.Destination, javax.jms.Queue, javax.jms.TemporaryQueue, javax.jms.TemporaryTopic, javax.jms.Topic, weblogic.common.internal.InteropWriteReplaceable, weblogic.deployment.jms.ForeignJMSServerAware, WLDestination

public final class DistributedDestinationImpl
extends DestinationImpl
implements weblogic.common.internal.InteropWriteReplaceable, java.io.Externalizable

DistributedDestinationImpl is the class for JMS Distributed destinations (topics and queues stored in JNDI) and is used by frontend for High Availability of a Destination)

See Also:

Serialized Form

Excluded in public API Reference.

Field Summary

Fields

Modifier and Type	Field and Description
private static int	_DDVERSIONMASK
private static int	_DDVERSIONSHIFT
private static int	_DONOTUSE_RESERVED static private final int _RESERVED = (int)1 << 12; 13th bit should not be used.
private static int	_HASDDJNDINAME
private static int	_HASNONSYSSUBCNT
private static int	_HASSTORE
private static int	_ISBOUNDBYINTERNALNAME
private static int	_ISDURABLE
private static int	_ISFORWARDING_POLICY_PARTITIONED For now we have only two policy choices FORWARDING_POLICY_PARTITIONED and FORWARDING_POLICY_REPLICATED.
private static int	_ISQUEUEFORWARD
private static int	_ISSERVERAFFINITY
private static int	BE_DESTINATION_NOT_TEMPORARY
private boolean	clusterTargeted
private java.lang.String	ddJNDIName
private static int	DDVERSION1
private java.lang.String	distributedConfigMbeanName
private int	distributionPolicy
private boolean	hasStore
private boolean	isConsumptionPaused
private boolean	isInsertionPaused
private boolean	isLocal
private boolean	isProductionPaused
private boolean	isQueueForward
private int	loadBalancePolicy
private int	messageForwardingPolicy
private int	nonSystemSubscriberConsumers
private boolean	onDynamicNonUPS
private int	order
(package private) static long	serialVersionUID
private boolean	serverAffinityEnabled
private boolean	stale
private int	weight
private java.lang.String	wlsServerName

Fields inherited from class weblogic.jms.common.DestinationImpl

_HASIDS, backEndId, destinationId, dispatcherId, type, TYPE_ANONYMOUS, TYPE_QUEUE, TYPE_TEMP_QUEUE, TYPE_TEMP_TOPIC, TYPE_TOPIC

Fields inherited from class weblogic.jms.common.Destination

_IFDESTCANNOTBENULL, _IFMUSTBEQUEUE, _IFMUSTBETOPIC, DESTINATIONIMPL, DISTRIBUTEDDESTINATIONIMPL, FUTUREDESTINATIONIMPL1, FUTUREDESTINATIONIMPL2, FUTUREDESTINATIONIMPL3, FUTUREDESTINATIONIMPL4, FUTUREDESTINATIONIMPL5, NULLDESTINATIONIMPL

Constructor Summary

Constructors

Constructor and Description
DistributedDestinationImpl()
DistributedDestinationImpl(int ddType, java.lang.String ddJMSServerInstanceName, java.lang.String ddJMSServerConfigName, java.lang.String ddName, java.lang.String applicationName, java.lang.String moduleName, int lbPolicy, int forwardingPolicy, java.lang.String ddInstanceName, java.lang.String vdName, JMSServerId beId, JMSID destId, weblogic.messaging.dispatcher.DispatcherId dispId, boolean dHasStore, java.lang.String persistentStoreName, java.lang.String safExportPolicy, boolean isLocal)
DistributedDestinationImpl(int ddType, java.lang.String ddJMSServerInstanceName, java.lang.String ddJMSServerConfigName, java.lang.String ddName, java.lang.String applicationName, java.lang.String moduleName, int lbPolicy, int forwardingPolicy, java.lang.String ddInstanceName, java.lang.String vdName, JMSServerId beId, JMSID destId, weblogic.messaging.dispatcher.DispatcherId dispId, boolean dHasStore, java.lang.String persistentStoreName, java.lang.String safExportPolicy, boolean isLocal, java.lang.String partitionName)

Method Summary

Modifier and Type	Method and Description
java.lang.Object	clone()
java.lang.String	debugString() Called to remove an element from this aggregate.
boolean	equals(java.lang.Object o)
java.lang.String	getCreateDestinationArgument() createDestination string does not begin with "serverName/" or the "./", it is just the distributed destination name
java.lang.String	getDDJNDIName()
byte	getDestinationInstanceType()
(package private) java.lang.String	getDestinationName() Returns the name of the destination.
java.lang.String	getGlobalJNDIName()
java.lang.String	getInstanceName()
int	getLoadBalancingPolicy()
int	getMessageForwardingPolicy()
java.lang.String	getName() Returns the name of the destination.
int	getNonSystemSubscriberConsumers()
int	getOrder()
int	getWeight()
boolean	hasConsumer()
java.lang.Object	interopWriteReplace(weblogic.common.internal.PeerInfo peerInfo)
boolean	isClusterTargeted()
boolean	isConsumptionPaused()
boolean	isInsertionPaused()
boolean	isLocal()
boolean	isOnDynamicNonUPS()
boolean	isPersistent()
boolean	isProductionPaused()
boolean	isQueueForward()
boolean	isStale()
void	readExternal(java.io.ObjectInput in)
boolean	same(java.lang.String name)
void	setClusterTargeted(boolean b)
void	setDistributionPolicy(int p)
void	setIsConsumptionPaused(boolean isConsumptionPaused)
void	setIsInsertionPaused(boolean isInsertionPaused)
void	setIsProductionPaused(boolean isProductionPaused)
void	setName(java.lang.String mBeanName)
void	setNonSystemSubscriberConsumers(int nonSystemSubscriberConsumers)
void	setOnDynamicNonUPS(boolean b)
void	setOrder(int order)
void	setQueueForward(boolean isQueueForward)
void	setStale(boolean stale)
void	setWeight(int weight)
void	setWLSServerName(java.lang.String wlssName)
java.lang.String	toString()
private void	writeDistributedDestinationImpl(java.io.ObjectOutput out, weblogic.common.internal.PeerInfo peerInfo)
void	writeExternal(java.io.ObjectOutput out)

Methods inherited from class weblogic.jms.common.DestinationImpl

delete, destinationImplInternal, getApplicationName, getBackEndId, getClone, getConnection, getDestinationId, getDestinationNameInternal, getDispatcherId, getGeneration, getId, getJMSServerConfigName, getMemberName, getModuleName, getMulticastAddress, getPartitionName, getPersistentStoreName, getPort, getQueueName, getReferenceName, getSafAllowedArray, getServerName, getTopicName, getType, getVersion, hashCode, isAnonymous, isOneCopyPerServer, isPre10_3_4, isPre90, isQueue, isReferencedByFS, isReplicated, isTopic, markStale, readDestinationImpl, setApplicationName, setBackEndID, setConnection, setDestinationId, setDispatcherId, setJMSServerConfigName, setModuleName, setMulticastAddress, setOneCopyPerServer, setPort, setReferencedByFS, setReferenceName, setReplicated, setSafExportAllowedArray, setServerName, writeDestinationImpl, writeDestinationImpl

Methods inherited from class weblogic.jms.common.Destination

checkDestinationType, createDestination, equalsForDS, getDestinationType

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

DDVERSION1

private static final int DDVERSION1

See Also:

Constant Field Values

serialVersionUID

static final long serialVersionUID

See Also:

Constant Field Values

BE_DESTINATION_NOT_TEMPORARY

private static final int BE_DESTINATION_NOT_TEMPORARY

See Also:

Constant Field Values

weight

private int weight

loadBalancePolicy

private int loadBalancePolicy

messageForwardingPolicy

private int messageForwardingPolicy

ddJNDIName

private java.lang.String ddJNDIName

distributedConfigMbeanName

private java.lang.String distributedConfigMbeanName

hasStore

private boolean hasStore

stale

private boolean stale

serverAffinityEnabled

private boolean serverAffinityEnabled

isQueueForward

private boolean isQueueForward

isLocal

private boolean isLocal

isConsumptionPaused

private boolean isConsumptionPaused

isInsertionPaused

private boolean isInsertionPaused

isProductionPaused

private boolean isProductionPaused

nonSystemSubscriberConsumers

private int nonSystemSubscriberConsumers

order

private int order

wlsServerName

private transient java.lang.String wlsServerName

clusterTargeted

private transient boolean clusterTargeted

distributionPolicy

private transient int distributionPolicy

onDynamicNonUPS

private transient boolean onDynamicNonUPS

_DDVERSIONMASK

private static final int _DDVERSIONMASK

See Also:

Constant Field Values

_DDVERSIONSHIFT

private static final int _DDVERSIONSHIFT

See Also:

Constant Field Values

_ISFORWARDING_POLICY_PARTITIONED

private static final int _ISFORWARDING_POLICY_PARTITIONED

For now we have only two policy choices FORWARDING_POLICY_PARTITIONED and FORWARDING_POLICY_REPLICATED. In future we envision third policy FORWARDING_POLICY_CONDITIONAL or something in that case we would need to introduce new flag to pass condition string. Alternate would be to pass policy as int instead but for now it is efficient this way.

See Also:

Constant Field Values

_HASDDJNDINAME

private static final int _HASDDJNDINAME

See Also:

Constant Field Values

_HASSTORE

private static final int _HASSTORE

See Also:

Constant Field Values

_HASNONSYSSUBCNT

private static final int _HASNONSYSSUBCNT

See Also:

Constant Field Values

_ISDURABLE

private static final int _ISDURABLE

See Also:

Constant Field Values

_ISBOUNDBYINTERNALNAME

private static final int _ISBOUNDBYINTERNALNAME

See Also:

Constant Field Values

_ISQUEUEFORWARD

private static final int _ISQUEUEFORWARD

See Also:

Constant Field Values

_ISSERVERAFFINITY

private static final int _ISSERVERAFFINITY

See Also:

Constant Field Values

_DONOTUSE_RESERVED

private static final int _DONOTUSE_RESERVED

static private final int _RESERVED = (int)1 << 12; 13th bit should not be used. This matches with DestinationImpl._HASIDS of DestinationImpl. This is used to identify a store stream. (as we do not write the flags of DistributedDestinationImpl to the store

See Also:

Constant Field Values

Constructor Detail

DistributedDestinationImpl

public DistributedDestinationImpl()

DistributedDestinationImpl

public DistributedDestinationImpl(int ddType,
                                  java.lang.String ddJMSServerInstanceName,
                                  java.lang.String ddJMSServerConfigName,
                                  java.lang.String ddName,
                                  java.lang.String applicationName,
                                  java.lang.String moduleName,
                                  int lbPolicy,
                                  int forwardingPolicy,
                                  java.lang.String ddInstanceName,
                                  java.lang.String vdName,
                                  JMSServerId beId,
                                  JMSID destId,
                                  weblogic.messaging.dispatcher.DispatcherId dispId,
                                  boolean dHasStore,
                                  java.lang.String persistentStoreName,
                                  java.lang.String safExportPolicy,
                                  boolean isLocal)

DistributedDestinationImpl

public DistributedDestinationImpl(int ddType,
                                  java.lang.String ddJMSServerInstanceName,
                                  java.lang.String ddJMSServerConfigName,
                                  java.lang.String ddName,
                                  java.lang.String applicationName,
                                  java.lang.String moduleName,
                                  int lbPolicy,
                                  int forwardingPolicy,
                                  java.lang.String ddInstanceName,
                                  java.lang.String vdName,
                                  JMSServerId beId,
                                  JMSID destId,
                                  weblogic.messaging.dispatcher.DispatcherId dispId,
                                  boolean dHasStore,
                                  java.lang.String persistentStoreName,
                                  java.lang.String safExportPolicy,
                                  boolean isLocal,
                                  java.lang.String partitionName)

Method Detail

clone

public java.lang.Object clone()
                       throws java.lang.CloneNotSupportedException

Overrides:

clone in class DestinationImpl

Throws:

java.lang.CloneNotSupportedException

toString

public java.lang.String toString()

Specified by:

toString in interface javax.jms.Queue

Specified by:

toString in interface javax.jms.Topic

Overrides:

toString in class DestinationImpl

getLoadBalancingPolicy

public int getLoadBalancingPolicy()

getMessageForwardingPolicy

public int getMessageForwardingPolicy()

getWeight

public int getWeight()

setWeight

public void setWeight(int weight)

getOrder

public int getOrder()

setOrder

public void setOrder(int order)

isPersistent

public boolean isPersistent()

getDestinationInstanceType

public byte getDestinationInstanceType()

Overrides:

getDestinationInstanceType in class DestinationImpl

isLocal

public boolean isLocal()

setStale

public void setStale(boolean stale)

isStale

public boolean isStale()

Overrides:

isStale in class DestinationImpl

setQueueForward

public void setQueueForward(boolean isQueueForward)

isQueueForward

public boolean isQueueForward()

setNonSystemSubscriberConsumers

public void setNonSystemSubscriberConsumers(int nonSystemSubscriberConsumers)

getNonSystemSubscriberConsumers

public int getNonSystemSubscriberConsumers()

hasConsumer

public boolean hasConsumer()

getInstanceName

public java.lang.String getInstanceName()

getCreateDestinationArgument

public java.lang.String getCreateDestinationArgument()

createDestination string does not begin with "serverName/" or the "./", it is just the distributed destination name

Specified by:

getCreateDestinationArgument in interface WLDestination

Overrides:

getCreateDestinationArgument in class DestinationImpl

See Also:

Session, DestinationBean.getJMSCreateDestinationIdentifier()

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class DestinationImpl

same

public boolean same(java.lang.String name)

getDDJNDIName

public java.lang.String getDDJNDIName()

getGlobalJNDIName

public java.lang.String getGlobalJNDIName()

getName

public java.lang.String getName()

Returns the name of the destination. This will be the name of the distributed destination, if the destination is a member of a distributed destination.

Overrides:

getName in class DestinationImpl

setName

public void setName(java.lang.String mBeanName)

Overrides:

setName in class DestinationImpl

getDestinationName

java.lang.String getDestinationName()

Description copied from class: DestinationImpl

Returns the name of the destination. If the instance is an object of the subclass DistributedDestinationImpl, this method will be overritten by its getDestinationName() method, which unfortunately does " return distributedConfigMbeanName ". We keep it "as is" for the backwards compatibility reason.

Overrides:

getDestinationName in class DestinationImpl

isConsumptionPaused

public boolean isConsumptionPaused()

setIsConsumptionPaused

public void setIsConsumptionPaused(boolean isConsumptionPaused)

isInsertionPaused

public boolean isInsertionPaused()

setIsInsertionPaused

public void setIsInsertionPaused(boolean isInsertionPaused)

isProductionPaused

public boolean isProductionPaused()

setIsProductionPaused

public void setIsProductionPaused(boolean isProductionPaused)

setWLSServerName

public void setWLSServerName(java.lang.String wlssName)

setClusterTargeted

public void setClusterTargeted(boolean b)

isClusterTargeted

public boolean isClusterTargeted()

setDistributionPolicy

public void setDistributionPolicy(int p)

setOnDynamicNonUPS

public void setOnDynamicNonUPS(boolean b)

isOnDynamicNonUPS

public boolean isOnDynamicNonUPS()

debugString

public java.lang.String debugString()

Called to remove an element from this aggregate. If 'other' is non-null, and there exists an element e such that (e.HostID).equals('other'), should be removed. If there 'other' is not found in the list, this method would return silently (to ensure idempotence). If no elements are left in the aggregate after this call, true should be returned to indicate that the aggregate is empty and should be unbound.

interopWriteReplace

public java.lang.Object interopWriteReplace(weblogic.common.internal.PeerInfo peerInfo)
                                     throws java.io.IOException

Specified by:

interopWriteReplace in interface weblogic.common.internal.InteropWriteReplaceable

Throws:

java.io.IOException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Specified by:

writeExternal in interface java.io.Externalizable

Overrides:

writeExternal in class DestinationImpl

Throws:

java.io.IOException

writeDistributedDestinationImpl

private void writeDistributedDestinationImpl(java.io.ObjectOutput out,
                                             weblogic.common.internal.PeerInfo peerInfo)
                                      throws java.io.IOException

Throws:

java.io.IOException

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException,
                         java.lang.ClassNotFoundException

Specified by:

readExternal in interface java.io.Externalizable

Overrides:

readExternal in class DestinationImpl

Throws:

java.io.IOException

java.lang.ClassNotFoundException