cern.cmw.mom.pubsub

Class PubSubFactory

java.lang.Object

cern.cmw.mom.pubsub.PubSubFactory

public final class PubSubFactory
extends java.lang.Object

Public class. Factory class for creating Publisher or Subscriber instances.

Author:

Controls Middleware Project

See Also:

Subscriber, Publisher

Constructor Summary

Constructors

Constructor and Description
PubSubFactory()

Method Summary

Modifier and Type	Method and Description
static Publisher	publisher() Create a new Publisher instance.
static Publisher	publisher(java.lang.String username, java.lang.String password, java.lang.String brokerList, java.lang.Boolean loadBalancing, java.lang.Boolean sequential, java.lang.Boolean selectorAtBroker) Create a new Publisher instance using default properties.
static Subscriber	subscriber() Create a new Subscriber instance using default properties.
static Subscriber	subscriber(java.lang.String username, java.lang.String password, java.lang.String brokerList, java.lang.Boolean loadBalancing, java.lang.Boolean sequential, java.lang.Boolean selectorAtBroker) Create a new Subscriber instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

PubSubFactory

public PubSubFactory()

Method Detail

publisher

public static Publisher publisher()
                           throws MOMException

Create a new Publisher instance.

Returns:

the Publisher instance.

Throws:

MOMException - if the system fails to instantiate the Publisher due to some internal error.

publisher

public static Publisher publisher(java.lang.String username,
                                  java.lang.String password,
                                  java.lang.String brokerList,
                                  java.lang.Boolean loadBalancing,
                                  java.lang.Boolean sequential,
                                  java.lang.Boolean selectorAtBroker)
                           throws MOMException

Create a new Publisher instance using default properties.

Parameters:

username - the user name. This may be null.

password - the password. This may be null.

brokerList - the coma separated broker URLs list (in the form [protocol://]hostname[:port]). This may be null.

loadBalancing - if true, indicates that the client is willing to have a connect request re-directed to another broker within the broker list. This may be null.

sequential - if true, the broker list will be scanned sequentially. This may be null.

selectorAtBroker - if true, selectors will be evaluated on the broker side. This may be null.

Returns:

the Publisher instance.

Throws:

MOMException - if the system fails to instantiate the Publisher due to some internal error.

subscriber

public static Subscriber subscriber()
                             throws MOMException

Create a new Subscriber instance using default properties.

Returns:

the Subscriber instance.

Throws:

MOMException - if the system fails to instantiate a Subscriber due to some internal error.

subscriber

public static Subscriber subscriber(java.lang.String username,
                                    java.lang.String password,
                                    java.lang.String brokerList,
                                    java.lang.Boolean loadBalancing,
                                    java.lang.Boolean sequential,
                                    java.lang.Boolean selectorAtBroker)
                             throws MOMException

Create a new Subscriber instance.

Parameters:

username - the user name. This may be null.

password - the password. This may be null.

brokerList - the coma separated broker URLs list (in the form [protocol://]hostname[:port]). This may be null.

loadBalancing - if true, indicates that the client is willing to have a connect request re-directed to another broker within a cluster. This may be null.

sequential - if true, the broker list will be scanned sequentially. This may be null.

selectorAtBroker - if true, selectors will be evaluated on the broker side. This may be null.

Returns:

the Subscriber instance.

Throws:

MOMException - if the system fails to instantiate a Subscriber due to some internal error.