electric.server.jms.sonicmq
Class SonicMQAdapter

java.lang.Object
  electric.server.jms.sonicmq.SonicMQAdapter

All Implemented Interfaces:

progress.message.tools.IBrokerManagerListener, IJMSAdapter

public class SonicMQAdapter

extends java.lang.Object

implements IJMSAdapter, progress.message.tools.IBrokerManagerListener

SonicMQAdapter

Author:

webMethods

Field Summary

static java.lang.String	HOST BROKER_HOST can be used as a key in Context to identify a SonicMQ broker host location.
static java.lang.String	PASSWORD BROKER_PASSWORD can be used as a key in Context to identify password used to connect to the broker
static java.lang.String	USER BROKER_USER can be used as a key in Context to identify user name used to connect to the broker

Constructor Summary

SonicMQAdapter()

Method Summary

void	brokerConnectionDropped(java.lang.String host)
void	brokerEventNotification(java.lang.String description)
void	brokerShutdown(java.lang.String host)
void	brokerUndeliveredMsgNotification(java.lang.String broker, java.lang.String messageID, java.lang.String destination, long timestamp, int reason, boolean preserved)
java.lang.String	getClassName() Returns the name of the class to be found only in the codebase of the jms provider, an implementation represents
java.lang.String	getProviderName() Return the name of the provider
javax.jms.Queue	getQueue(java.lang.String queueName, boolean create) This method is called by the JMS subsystem of GLUE to request construction and placement of a JMS Queue object in a JNDI directory The method returns the name of the queue conforming to the requirements of the provider
javax.jms.QueueConnectionFactory	getQueueConnectionFactory(java.lang.String queueConnFactoryName, boolean create) This method is called by the JMS subsystem of GLUE to request construction and placement of a JMS Queue Connection Factory object in a JNDI directory The method returns the name of the queue connection factory conforming to the requirements of the provider
Context	getStartupContext() Get the context with the properties used to initialize/customize this adapter.
boolean	isStarted() Test if the admin had been started
void	shutdown() Close any resources used by the adapter and shutdown the adapter
void	startup(Context context) Get any setting overrides from the context.

Methods inherited from class java.lang.Object

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

Field Detail

HOST

public static final java.lang.String HOST

BROKER_HOST can be used as a key in Context to identify a SonicMQ broker host location. Default host location is localhost:2506

See Also:

Constant Field Values

USER

public static final java.lang.String USER

BROKER_USER can be used as a key in Context to identify user name used to connect to the broker

See Also:

Constant Field Values

PASSWORD

public static final java.lang.String PASSWORD

BROKER_PASSWORD can be used as a key in Context to identify password used to connect to the broker

See Also:

Constant Field Values

Constructor Detail

SonicMQAdapter

public SonicMQAdapter()

Method Detail

startup

public void startup(Context context)
             throws javax.jms.JMSException

Get any setting overrides from the context. Perform initialization and start the adapter.

Specified by:

startup in interface IJMSAdapter

Parameters:

context - the context containing any custom settings for the provider

Throws:

javax.jms.JMSException

isStarted

public boolean isStarted()

Description copied from interface: IJMSAdapter

Test if the admin had been started

Specified by:

isStarted in interface IJMSAdapter

shutdown

public void shutdown()
              throws javax.jms.JMSException

Close any resources used by the adapter and shutdown the adapter

Specified by:

shutdown in interface IJMSAdapter

Throws:

javax.jms.JMSException

getStartupContext

public Context getStartupContext()

Get the context with the properties used to initialize/customize this adapter. This method is used only when Async objects are persisted. The serialization of Async object requires persisting of any state information used for the reconnection when object is deserialized.

Specified by:

getStartupContext in interface IJMSAdapter

getQueue

public javax.jms.Queue getQueue(java.lang.String queueName,
                                boolean create)
                         throws javax.jms.JMSException,
                                javax.naming.NamingException

This method is called by the JMS subsystem of GLUE to request construction and placement of a JMS Queue object in a JNDI directory The method returns the name of the queue conforming to the requirements of the provider

Specified by:

getQueue in interface IJMSAdapter

Parameters:

queueName - JNDI name of the queue

create - if true, create the queue

Throws:

javax.jms.JMSException

javax.naming.NamingException

getQueueConnectionFactory

public javax.jms.QueueConnectionFactory getQueueConnectionFactory(java.lang.String queueConnFactoryName,
                                                                  boolean create)
                                                           throws javax.jms.JMSException

This method is called by the JMS subsystem of GLUE to request construction and placement of a JMS Queue Connection Factory object in a JNDI directory The method returns the name of the queue connection factory conforming to the requirements of the provider

Specified by:

getQueueConnectionFactory in interface IJMSAdapter

Parameters:

queueConnFactoryName - JNDI name of the queue connecion factory

create - if true, create the queue

Throws:

javax.jms.JMSException

getClassName

public java.lang.String getClassName()

Returns the name of the class to be found only in the codebase of the jms provider, an implementation represents

Specified by:

getClassName in interface IJMSAdapter

getProviderName

public java.lang.String getProviderName()

Return the name of the provider

Specified by:

getProviderName in interface IJMSAdapter

brokerShutdown

public void brokerShutdown(java.lang.String host)

Specified by:

brokerShutdown in interface progress.message.tools.IBrokerManagerListener

Parameters:

host -

brokerConnectionDropped

public void brokerConnectionDropped(java.lang.String host)

Specified by:

brokerConnectionDropped in interface progress.message.tools.IBrokerManagerListener

Parameters:

host -

brokerEventNotification

public void brokerEventNotification(java.lang.String description)

Specified by:

brokerEventNotification in interface progress.message.tools.IBrokerManagerListener

Parameters:

description -

brokerUndeliveredMsgNotification

public void brokerUndeliveredMsgNotification(java.lang.String broker,
                                             java.lang.String messageID,
                                             java.lang.String destination,
                                             long timestamp,
                                             int reason,
                                             boolean preserved)

Specified by:

brokerUndeliveredMsgNotification in interface progress.message.tools.IBrokerManagerListener

Parameters:

broker -

messageID -

destination -

timestamp -

reason -

preserved -