org.backsource.adaptor.jms
Class JmsBase

java.lang.Object
  javax.management.NotificationBroadcasterSupport
      org.jboss.system.ServiceMBeanSupport
          org.backsource.jmx.ServiceMBeanSupport
              org.backsource.adaptor.jms.JmsBase

All Implemented Interfaces:

org.backsource.adaptor.jms.JmsBaseMBean, javax.management.MBeanRegistration, javax.management.NotificationBroadcaster, org.jboss.system.Service, org.backsource.jmx.ServiceMBean, org.jboss.system.ServiceMBean

Direct Known Subclasses:

MessageDriven, Producer

public class JmsBase

extends org.backsource.jmx.ServiceMBeanSupport

implements org.backsource.adaptor.jms.JmsBaseMBean

Base MBean for JMS MBeans.

This baseclass handles the common attributes; ands setups of connectiona dn topic. One instance of an MBean of this type, handles only one connection and one destination.

Version:

$Revision: 1.2 $

Author:

Peter Antman

Field Summary

protected int	ackMode
protected javax.jms.Connection	connection
protected boolean	connectionException
protected javax.jms.Destination	destination
protected org.backsource.adaptor.jms.JmsBase.ExceptionListenerImpl	exListener
protected boolean	failsafe
protected boolean	isTopic
protected javax.management.ObjectName	name
static javax.management.ObjectName	OBJECT_NAME
protected javax.management.MBeanServer	server
protected boolean	stopOnFail
protected boolean	transacted

Fields inherited from class org.jboss.system.ServiceMBeanSupport

log, serviceName

Fields inherited from interface org.jboss.system.ServiceMBean

CREATE_EVENT, CREATED, DESTROY_EVENT, DESTROYED, FAILED, STARTED, STARTING, states, STOPPED, STOPPING

Constructor Summary

JmsBase()

Method Summary

protected void	createService()
protected void	destroyService()
java.lang.String	getClientId()
protected javax.naming.Context	getContext()
protected javax.jms.Destination	getDestination()
java.lang.String	getDestinationFactory()
java.lang.String	getDestinationJndiName()
java.lang.String	getDestinationType()
protected javax.jms.ConnectionFactory	getFactory()
boolean	getFailsafe()
protected org.jboss.jms.jndi.JMSProviderAdapter	getJMSProviderAdapter() Return the JMSProviderAdapter that should be used.
java.lang.String	getJMSProviderAdapterJNDI()
protected javax.management.ObjectName	getObjectName(javax.management.MBeanServer server, javax.management.ObjectName name)
java.lang.String	getPassword()
long	getReconnectInterval()
boolean	getStopOnFail()
java.lang.String	getUsername()
protected void	innerCreate()
protected void	innerStop() Stop done from inside, we should not stop the exceptionListener in inner stop.
void	setClientId(java.lang.String clientId)
void	setDestinationFactory(java.lang.String destinationFactoryJNDI)
void	setDestinationJndiName(java.lang.String destinationJndiName)
void	setDestinationType(java.lang.String destinationType)
void	setFailsafe(boolean failsafe)
void	setJMSProviderAdapterJNDI(java.lang.String providerAdapterJNDI)
void	setPassword(java.lang.String passwd)
void	setReconnectInterval(long reconnectInterval)
void	setStopOnFail(boolean stopOnFail)
void	setUsername(java.lang.String user)
protected void	startQueue()
protected void	startService()
protected void	startTopic()
protected void	stopService()

Methods inherited from class org.jboss.system.ServiceMBeanSupport

create, destroy, getLog, getName, getNextNotificationSequenceNumber, getServer, getServiceName, getState, getStateString, postDeregister, postRegister, preDeregister, preRegister, start, stop

Methods inherited from class javax.management.NotificationBroadcasterSupport

addNotificationListener, getNotificationInfo, removeNotificationListener, sendNotification

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jboss.system.ServiceMBean

getName, getState, getStateString

Methods inherited from interface org.jboss.system.Service

create, destroy, start, stop

Field Detail

OBJECT_NAME

public static final javax.management.ObjectName OBJECT_NAME

name

protected javax.management.ObjectName name

server

protected javax.management.MBeanServer server

failsafe

protected boolean failsafe

stopOnFail

protected boolean stopOnFail

isTopic

protected boolean isTopic

transacted

protected boolean transacted

ackMode

protected int ackMode

connection

protected javax.jms.Connection connection

destination

protected javax.jms.Destination destination

exListener

protected org.backsource.adaptor.jms.JmsBase.ExceptionListenerImpl exListener

connectionException

protected volatile boolean connectionException

Constructor Detail

JmsBase

public JmsBase()

Method Detail

getObjectName

protected javax.management.ObjectName getObjectName(javax.management.MBeanServer server,
                                                    javax.management.ObjectName name)
                                             throws javax.management.MalformedObjectNameException

Throws:

javax.management.MalformedObjectNameException

getJMSProviderAdapterJNDI

public java.lang.String getJMSProviderAdapterJNDI()

Specified by:

getJMSProviderAdapterJNDI in interface org.backsource.adaptor.jms.JmsBaseMBean

setJMSProviderAdapterJNDI

public void setJMSProviderAdapterJNDI(java.lang.String providerAdapterJNDI)

Specified by:

setJMSProviderAdapterJNDI in interface org.backsource.adaptor.jms.JmsBaseMBean

getDestinationFactory

public java.lang.String getDestinationFactory()

Specified by:

getDestinationFactory in interface org.backsource.adaptor.jms.JmsBaseMBean

setDestinationFactory

public void setDestinationFactory(java.lang.String destinationFactoryJNDI)

Specified by:

setDestinationFactory in interface org.backsource.adaptor.jms.JmsBaseMBean

getDestinationType

public java.lang.String getDestinationType()

Specified by:

getDestinationType in interface org.backsource.adaptor.jms.JmsBaseMBean

setDestinationType

public void setDestinationType(java.lang.String destinationType)

Specified by:

setDestinationType in interface org.backsource.adaptor.jms.JmsBaseMBean

getDestinationJndiName

public java.lang.String getDestinationJndiName()

Specified by:

getDestinationJndiName in interface org.backsource.adaptor.jms.JmsBaseMBean

setDestinationJndiName

public void setDestinationJndiName(java.lang.String destinationJndiName)

Specified by:

setDestinationJndiName in interface org.backsource.adaptor.jms.JmsBaseMBean

getUsername

public java.lang.String getUsername()

Specified by:

getUsername in interface org.backsource.adaptor.jms.JmsBaseMBean

setUsername

public void setUsername(java.lang.String user)

Specified by:

setUsername in interface org.backsource.adaptor.jms.JmsBaseMBean

getPassword

public java.lang.String getPassword()

Specified by:

getPassword in interface org.backsource.adaptor.jms.JmsBaseMBean

setPassword

public void setPassword(java.lang.String passwd)

Specified by:

setPassword in interface org.backsource.adaptor.jms.JmsBaseMBean

getClientId

public java.lang.String getClientId()

Specified by:

getClientId in interface org.backsource.adaptor.jms.JmsBaseMBean

setClientId

public void setClientId(java.lang.String clientId)

Specified by:

setClientId in interface org.backsource.adaptor.jms.JmsBaseMBean

getFailsafe

public boolean getFailsafe()

Specified by:

getFailsafe in interface org.backsource.adaptor.jms.JmsBaseMBean

setFailsafe

public void setFailsafe(boolean failsafe)

Specified by:

setFailsafe in interface org.backsource.adaptor.jms.JmsBaseMBean

getStopOnFail

public boolean getStopOnFail()

Specified by:

getStopOnFail in interface org.backsource.adaptor.jms.JmsBaseMBean

setStopOnFail

public void setStopOnFail(boolean stopOnFail)

Specified by:

setStopOnFail in interface org.backsource.adaptor.jms.JmsBaseMBean

getReconnectInterval

public long getReconnectInterval()

Specified by:

getReconnectInterval in interface org.backsource.adaptor.jms.JmsBaseMBean

setReconnectInterval

public void setReconnectInterval(long reconnectInterval)

Specified by:

setReconnectInterval in interface org.backsource.adaptor.jms.JmsBaseMBean

createService

protected void createService()
                      throws java.lang.Exception

Throws:

java.lang.Exception

startService

protected void startService()
                     throws java.lang.Exception

Throws:

java.lang.Exception

stopService

protected void stopService()
                    throws java.lang.Exception

Throws:

java.lang.Exception

destroyService

protected void destroyService()
                       throws java.lang.Exception

Throws:

java.lang.Exception

innerCreate

protected void innerCreate()
                    throws javax.jms.JMSException

Throws:

javax.jms.JMSException

innerStop

protected void innerStop()
                  throws javax.jms.JMSException

Stop done from inside, we should not stop the exceptionListener in inner stop.

Throws:

javax.jms.JMSException

startTopic

protected void startTopic()
                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

startQueue

protected void startQueue()
                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getFactory

protected javax.jms.ConnectionFactory getFactory()
                                          throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getDestination

protected javax.jms.Destination getDestination()
                                        throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getContext

protected javax.naming.Context getContext()
                                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getJMSProviderAdapter

protected org.jboss.jms.jndi.JMSProviderAdapter getJMSProviderAdapter()
                                                               throws javax.jms.JMSException

Return the JMSProviderAdapter that should be used.

Returns:

The JMSProviderAdapter to use.

Throws:

javax.jms.JMSException