org.backsource.adaptor.jms
Class MessageDriven

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

All Implemented Interfaces:

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

public class MessageDriven

extends JmsBase

implements org.backsource.adaptor.jms.MessageDrivenMBean, javax.jms.MessageListener

Version:

$Revision: 1.1.1.1 $

Author:

Peter Antman

Field Summary

Fields inherited from class org.backsource.adaptor.jms.JmsBase

ackMode, connection, connectionException, destination, exListener, failsafe, isTopic, name, OBJECT_NAME, server, stopOnFail, 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

MessageDriven()

Method Summary

protected void	destroyService()
boolean	getDurable()
java.lang.String	getMessageSelector()
boolean	getPullSubscription()
long	getPullTimeout()
java.lang.String	getSubscriptionId()
void	onMessage(javax.jms.Message message)
protected void	receive(javax.jms.MessageConsumer consumer)
void	setDurable(boolean subscriptionDurability)
void	setMessageSelector(java.lang.String messageSelector)
void	setPullSubscription(boolean pullSubscriber)
void	setPullTimeout(long pullTimeput)
void	setSubscriptionId(java.lang.String subscriptionId)
protected void	startQueue()
protected void	startTopic()

Methods inherited from class org.backsource.adaptor.jms.JmsBase

createService, getClientId, getContext, getDestination, getDestinationFactory, getDestinationJndiName, getDestinationType, getFactory, getFailsafe, getJMSProviderAdapter, getJMSProviderAdapterJNDI, getObjectName, getPassword, getReconnectInterval, getStopOnFail, getUsername, innerCreate, innerStop, setClientId, setDestinationFactory, setDestinationJndiName, setDestinationType, setFailsafe, setJMSProviderAdapterJNDI, setPassword, setReconnectInterval, setStopOnFail, setUsername, startService, 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.backsource.adaptor.jms.JmsBaseMBean

getClientId, getDestinationFactory, getDestinationJndiName, getDestinationType, getFailsafe, getJMSProviderAdapterJNDI, getPassword, getReconnectInterval, getStopOnFail, getUsername, setClientId, setDestinationFactory, setDestinationJndiName, setDestinationType, setFailsafe, setJMSProviderAdapterJNDI, setPassword, setReconnectInterval, setStopOnFail, setUsername

Methods inherited from interface org.jboss.system.ServiceMBean

getName, getState, getStateString

Methods inherited from interface org.jboss.system.Service

create, destroy, start, stop

Constructor Detail

MessageDriven

public MessageDriven()

Method Detail

getDurable

public boolean getDurable()

Specified by:

getDurable in interface org.backsource.adaptor.jms.MessageDrivenMBean

setDurable

public void setDurable(boolean subscriptionDurability)

Specified by:

setDurable in interface org.backsource.adaptor.jms.MessageDrivenMBean

getMessageSelector

public java.lang.String getMessageSelector()

Specified by:

getMessageSelector in interface org.backsource.adaptor.jms.MessageDrivenMBean

setMessageSelector

public void setMessageSelector(java.lang.String messageSelector)

Specified by:

setMessageSelector in interface org.backsource.adaptor.jms.MessageDrivenMBean

getSubscriptionId

public java.lang.String getSubscriptionId()

Specified by:

getSubscriptionId in interface org.backsource.adaptor.jms.MessageDrivenMBean

setSubscriptionId

public void setSubscriptionId(java.lang.String subscriptionId)

Specified by:

setSubscriptionId in interface org.backsource.adaptor.jms.MessageDrivenMBean

getPullSubscription

public boolean getPullSubscription()

Specified by:

getPullSubscription in interface org.backsource.adaptor.jms.MessageDrivenMBean

setPullSubscription

public void setPullSubscription(boolean pullSubscriber)

Specified by:

setPullSubscription in interface org.backsource.adaptor.jms.MessageDrivenMBean

getPullTimeout

public long getPullTimeout()

Specified by:

getPullTimeout in interface org.backsource.adaptor.jms.MessageDrivenMBean

setPullTimeout

public void setPullTimeout(long pullTimeput)

Specified by:

setPullTimeout in interface org.backsource.adaptor.jms.MessageDrivenMBean

destroyService

protected void destroyService()
                       throws java.lang.Exception

Overrides:

destroyService in class JmsBase

Throws:

java.lang.Exception

onMessage

public void onMessage(javax.jms.Message message)

Specified by:

onMessage in interface javax.jms.MessageListener

startTopic

protected void startTopic()
                   throws javax.jms.JMSException

Overrides:

startTopic in class JmsBase

Throws:

javax.jms.JMSException

startQueue

protected void startQueue()
                   throws javax.jms.JMSException

Overrides:

startQueue in class JmsBase

Throws:

javax.jms.JMSException

receive

protected void receive(javax.jms.MessageConsumer consumer)
                throws javax.jms.JMSException

Throws:

javax.jms.JMSException