DestinationBean
, NamedEntityBean
, SettableBean
, TargetableBean
UniformDistributedTopicBean
public interface TopicBean extends DestinationBean
Topics are used for asynchronous peer communications. A message delivered to a topic will be distributed to all topic consumers. Several aspects of a topics behavior can be configured with a topic bean.
Modifier and Type | Method | Description |
---|---|---|
java.lang.String |
getForwardingPolicy() |
The uniform distributed topic message Forwarding Policy specifies whether a sent message is forwarded to all members.
|
MulticastParamsBean |
getMulticast() |
Gets the multicast parameters for this destination.
|
TopicSubscriptionParamsBean |
getTopicSubscriptionParams() |
Gets the subscription parameters for this topic.
|
void |
setForwardingPolicy(java.lang.String forwardingPolicy) |
Sets the value of the Message ForwardingPolicy attribute for this topic.
|
addDestinationKey, getAttachSender, getDeliveryFailureParams, getDeliveryParamsOverrides, getDestinationKeys, getIncompleteWorkExpirationTime, getJMSCreateDestinationIdentifier, getJNDIName, getLoadBalancingPolicy, getLocalJNDIName, getMaximumMessageSize, getMessageLoggingParams, getMessagingPerformancePreference, getQuota, getSAFExportPolicy, getTemplate, getThresholds, getUnitOfOrderRouting, getUnitOfWorkHandlingPolicy, isConsumptionPausedAtStartup, isDefaultUnitOfOrder, isInsertionPausedAtStartup, isProductionPausedAtStartup, removeDestinationKey, setAttachSender, setConsumptionPausedAtStartup, setDefaultUnitOfOrder, setDestinationKeys, setIncompleteWorkExpirationTime, setInsertionPausedAtStartup, setJMSCreateDestinationIdentifier, setJNDIName, setLoadBalancingPolicy, setLocalJNDIName, setMaximumMessageSize, setMessagingPerformancePreference, setProductionPausedAtStartup, setQuota, setSAFExportPolicy, setTemplate, setUnitOfOrderRouting, setUnitOfWorkHandlingPolicy
getId, getName, getNotes, setName, setNotes
getSubDeploymentName, isDefaultTargetingEnabled, setDefaultTargetingEnabled, setSubDeploymentName
MulticastParamsBean getMulticast()
Gets the multicast parameters for this destination.
Topics with certain quality of service allowments can receive a signifigant performance boost by using multicast to receive messages rather than using a connection oriented protocol like TCP. These parameters can be configured with the bean returned.
TopicSubscriptionParamsBean getTopicSubscriptionParams()
Gets the subscription parameters for this topic.
TopicSubscriptionParamsBean
specifies topic
subscription parameters.
java.lang.String getForwardingPolicy()
The uniform distributed topic message Forwarding Policy specifies whether a sent message is forwarded to all members.
The valid values are:
A publisher that uses a logical JNDI name of a Replicated distributed topic is created on one member and every send call publishes
messages to the same member regardless the value of the Load Balancing Enabled
attribute. This is behavior is backward compatible
with previous WebLogic Server releases when using a uniform distributed topic. Under the same conditions, a Partitioned distributed topic
publishes to the same member only when the value of the Load Balancing Enabled
attribute is set to false. If the value of
the Load Balancing Enabled
attribute is to true, a publisher to a Partitioned distributed topic publishes messages that are load balanced
accross all the members of the uniform distributed topic.
Most new applications will use the new Partitioned forwarding policy in combination with a logical subscription topology on a uniform distributed
topic that consists of: (1) a same named physical subscription created directly on each physical member, (2) a Client ID Policy of Unrestricted, and
(3) a Subscription Sharing Policy of Sharable
. WL 10.3.4 Message Driven Beans (MDBs) provides a Topic Messages Distribution Mode
option to automatically setup this kind of topology.
Note: This attribute is ignored by standalone/singleton Topics, it only applies to distributed topics.
void setForwardingPolicy(java.lang.String forwardingPolicy) throws java.lang.IllegalArgumentException
Sets the value of the Message ForwardingPolicy attribute for this topic.
forwardingPolicy
- message forwarding policy for this topicjava.lang.IllegalArgumentException
getForwardingPolicy()