cern.cmw.mom.pubsub.impl

Class DefaultPublisherImpl

java.lang.Object

cern.cmw.mom.pubsub.impl.DefaultPublisherImpl

All Implemented Interfaces:

Publisher

public class DefaultPublisherImpl
extends java.lang.Object
implements Publisher

Implementation class.

Author:

Controls Middleware Project

See Also:

Publisher

Constructor Summary

Constructors

Constructor and Description
DefaultPublisherImpl() Constructor DefaultPublisherImpl
DefaultPublisherImpl(java.lang.String username, java.lang.String password, java.lang.String brokerList, java.lang.Boolean loadBalancing, java.lang.Boolean sequential, java.lang.Boolean selectorAtBroker) Constructor DefaultPublisherImpl

Method Summary

Modifier and Type	Method and Description
void	close() Method close
BytesMessage	createBytesMessage() Method createBytesMessage
MapMessage	createMapMessage() Method createMapMessage
Message	createMessage() Method createMessage
ObjectMessage	createObjectMessage() Method createObjectMessage
StreamMessage	createStreamMessage() Method createStreamMessage
TextMessage	createTextMessage() Method createTextMessage
protected void	finalize() Method finalize
boolean	isClosed() Method isClosed
void	onException(JMSException ex) Method onException
void	open() Method open
void	publish(java.lang.String topic, Message message) Method publish
void	publish(java.lang.String topic, Message message, int deliveryMode, int priority, long timeToLive) Publish a message to the given topic.
void	setExceptionListener(ExceptionListener listener) Method setExceptionListener

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultPublisherImpl

public DefaultPublisherImpl()
                     throws MOMException

Constructor DefaultPublisherImpl

Throws:

MOMException

DefaultPublisherImpl

public DefaultPublisherImpl(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

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

Throws:

MOMException

Method Detail

isClosed

public boolean isClosed()

Method isClosed

Returns:

Topic

setExceptionListener

public void setExceptionListener(ExceptionListener listener)

Method setExceptionListener

Specified by:

setExceptionListener in interface Publisher

Parameters:

listener -

close

public void close()

Method close

Specified by:

close in interface Publisher

createBytesMessage

public BytesMessage createBytesMessage()
                                throws JMSException

Method createBytesMessage

Specified by:

createBytesMessage in interface Publisher

Returns:

BytesMessage

Throws:

JMSException

createMapMessage

public MapMessage createMapMessage()
                            throws JMSException

Method createMapMessage

Specified by:

createMapMessage in interface Publisher

Returns:

MapMessage

Throws:

JMSException

createMessage

public Message createMessage()
                      throws JMSException

Method createMessage

Specified by:

createMessage in interface Publisher

Returns:

Message

Throws:

JMSException

createObjectMessage

public ObjectMessage createObjectMessage()
                                  throws JMSException

Method createObjectMessage

Specified by:

createObjectMessage in interface Publisher

Returns:

ObjectMessage

Throws:

JMSException

createStreamMessage

public StreamMessage createStreamMessage()
                                  throws JMSException

Method createStreamMessage

Specified by:

createStreamMessage in interface Publisher

Returns:

StreamMessage

Throws:

JMSException

createTextMessage

public TextMessage createTextMessage()
                              throws JMSException

Method createTextMessage

Specified by:

createTextMessage in interface Publisher

Returns:

TextMessage

Throws:

JMSException

onException

public void onException(JMSException ex)

Method onException

Parameters:

ex -

open

public void open()
          throws MOMException

Method open

Throws:

MOMException

publish

public void publish(java.lang.String topic,
                    Message message)
             throws JMSException,
                    javax.naming.NamingException

Method publish

Specified by:

publish in interface Publisher

Parameters:

topic -

message -

Throws:

JMSException

javax.naming.NamingException

publish

public void publish(java.lang.String topic,
                    Message message,
                    int deliveryMode,
                    int priority,
                    long timeToLive)
             throws JMSException,
                    javax.naming.NamingException

Publish a message to the given topic.

Specified by:

publish in interface Publisher

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

Throws:

JMSException - if JMS fails to publish the message due to some internal JMS error.

javax.naming.NamingException - if there is a violation in the namespace policy.

finalize

protected void finalize()
                 throws java.lang.Throwable

Method finalize

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable