Inheritance diagram for cern.cmw.mom.pubsub.impl.DefaultPublisherImpl:

Public Member Functions
	DefaultPublisherImpl () throws MOMException
	DefaultPublisherImpl (String username, String password, String brokerList, Boolean loadBalancing, Boolean sequential, Boolean selectorAtBroker) throws MOMException
boolean	isClosed ()
void	setExceptionListener (cern.cmw.mom.pubsub.ExceptionListener listener)
void	close ()
BytesMessage	createBytesMessage () throws JMSException
MapMessage	createMapMessage () throws JMSException
Message	createMessage () throws JMSException
ObjectMessage	createObjectMessage () throws JMSException
StreamMessage	createStreamMessage () throws JMSException
TextMessage	createTextMessage () throws JMSException
void	onException (JMSException ex)
void	open () throws MOMException
void	publish (String topic, Message message) throws JMSException, NamingException
void	publish (String topic, Message message, int deliveryMode, int priority, long timeToLive) throws JMSException, NamingException
Protected Member Functions
void	finalize () throws Throwable
Static Package Attributes
static Category	cat = Category.getInstance(DefaultPublisherImpl.class.getName())

Detailed Description

Implementation class.

Version:: 1.0 23 Jan 2001

Author:: Controls Middleware Project

See also:: Publisher

Constructor & Destructor Documentation

cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.DefaultPublisherImpl ( ) throws MOMException

Constructor DefaultPublisherImpl

Exceptions:

MOMException

References cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.open().

cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.DefaultPublisherImpl	(	String	username,
		String	password,
		String	brokerList,
		Boolean	loadBalancing,
		Boolean	sequential,
		Boolean	selectorAtBroker
	)			throws MOMException

Constructor DefaultPublisherImpl

Parameters:

	username	the user name
	password	the password
	brokerList	the coma separated broker URLs list (in the form [protocol://]hostname[:port])
	loadBalancing	if true, indicates that the client is willing to have a connect request re-directed to another broker within a cluster
	sequential	if true, the broker list will be scanned sequentially
	selectorAtBroker	if true, selectors will be evaluated on the broker side

Exceptions:

MOMException

References cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.open().

Member Function Documentation

void cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.close ( )

Method close

References cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.cat, cern.cmw.mom.pubsub.impl.JMSConnection.close(), and cern.cmw.mom.pubsub.impl.JMSConnection.stop().

Referenced by cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.finalize().

BytesMessage cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.createBytesMessage ( ) throws JMSException

Method createBytesMessage

Returns:: BytesMessage

Exceptions:

JMSException

MapMessage cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.createMapMessage ( ) throws JMSException

Method createMapMessage

Returns:: MapMessage

Exceptions:

JMSException

Message cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.createMessage ( ) throws JMSException

Method createMessage

Returns:: Message

Exceptions:

JMSException

ObjectMessage cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.createObjectMessage ( ) throws JMSException

Method createObjectMessage

Returns:: ObjectMessage

Exceptions:

JMSException

StreamMessage cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.createStreamMessage ( ) throws JMSException

Method createStreamMessage

Returns:: StreamMessage

Exceptions:

JMSException

TextMessage cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.createTextMessage ( ) throws JMSException

Method createTextMessage

Returns:: TextMessage

Exceptions:

JMSException

void cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.finalize ( ) throws Throwable [protected]

Method finalize

Exceptions:

Throwable

References cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.cat, and cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.close().

boolean cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.isClosed ( )

Method isClosed

Returns:: Topic

void cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.onException ( JMSException ex )

Method onException

Parameters:

ex

References cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.cat.

void cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.open ( ) throws MOMException

Method open

Exceptions:

MOMException

References cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.cat.

Referenced by cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.DefaultPublisherImpl().

void cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.publish	(	String	topic,
		Message	message
	)			throws JMSException, NamingException

Method publish

Parameters:

	topic
	message

Exceptions:

	JMSException
	NamingException

void cern.cmw.mom.pubsub.impl.DefaultPublisherImpl.publish	(	String	topic,
		Message	message,
		int	deliveryMode,
		int	priority,
		long	timeToLive
	)			throws JMSException, NamingException

Publish a message to the given topic.

Parameters:

	topic	The String representation of the topic
	message	The Message object to publish
	deliveryMode	The Message persistence
	priority	The Message priority
	timeToLive	The Message time to live