com.pega.pegarules.pub.context

Interface PRDistributedTopic<E extends java.io.Serializable>

Type Parameters:

E - The type of message to be published to this topic.

Deprecated.

This class is deprecated in favor of the componentized cluster in platform/kernel/cluster. See the readme for more information. Email [email protected] with any questions

@Deprecated
public interface PRDistributedTopic<E extends java.io.Serializable>

PRDistributedTopic is the standard distributed topic interface. With this API, you can publish messages to the topic, as well as subscribe and unsubscribe listeners.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	COPYRIGHT Deprecated.
static java.lang.String	VERSION Deprecated.

Method Summary

Modifier and Type	Method and Description
java.lang.String	addMessageListener(PRMessageListener<E> aListener) Deprecated. Add a subscriber to this distributed topic.
long	getPublishOperationCount() Deprecated. Get the number of messages published to this topic.
long	getReceiveOperationCount() Deprecated. Get the number of messages received on this topic.
void	publish(E aMessage) Deprecated. Publish the specified message to all subscribers of this distributed topic.
boolean	removeMessageListener(java.lang.String aID) Deprecated. Remove the specified message listener (by ID) for this topic.

Field Detail

COPYRIGHT

static final java.lang.String COPYRIGHT

Deprecated.

See Also:

Constant Field Values

VERSION

static final java.lang.String VERSION

Deprecated.

Method Detail

publish

void publish(E aMessage)

Deprecated.

Publish the specified message to all subscribers of this distributed topic.

Parameters:

aMessage -

addMessageListener

java.lang.String addMessageListener(PRMessageListener<E> aListener)

Deprecated.

Add a subscriber to this distributed topic. Any messages published to this topic will invoke the PRMessageListener onMessage method with the PRMessage received.

Parameters:

aListener -

Returns:

a registration ID that can be used to unsubscribe from this distributed topic.

removeMessageListener

boolean removeMessageListener(java.lang.String aID)

Deprecated.

Remove the specified message listener (by ID) for this topic.

Parameters:

aID - a registration id to remove from this topic. The registration ID can be captured as the return value of the addMessageListener API.

Returns:

true if the listener was successfully removed. false otherwise.

getPublishOperationCount

long getPublishOperationCount()

Deprecated.

Get the number of messages published to this topic.

Returns:

a count of messages published.

getReceiveOperationCount

long getReceiveOperationCount()

Deprecated.

Get the number of messages received on this topic.

Returns:

the count of messages received.