java.lang.Object
org.activemq.spring.ConsumerBean
org.activemq.spring.SpringConsumer
- All Implemented Interfaces:
- javax.jms.MessageListener, org.activemq.service.Service
- public class SpringConsumer
- extends ConsumerBean
- implements org.activemq.service.Service, javax.jms.MessageListener
- Version:
- $Revision$
| Fields inherited from class org.activemq.spring.ConsumerBean |
|
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
log
private static final org.apache.commons.logging.Log log
template
private org.springframework.jms.core.JmsTemplate template
myId
private java.lang.String myId
destination
private javax.jms.Destination destination
connection
private javax.jms.Connection connection
session
private javax.jms.Session session
consumer
private javax.jms.MessageConsumer consumer
SpringConsumer
public SpringConsumer()
start
public void start()
throws javax.jms.JMSException
- Description copied from interface:
org.activemq.service.Service
- Called to start the service
- Specified by:
start in interface org.activemq.service.Service
stop
public void stop()
throws javax.jms.JMSException
- Description copied from interface:
org.activemq.service.Service
- Called to shutdown the service
- Specified by:
stop in interface org.activemq.service.Service
onMessage
public void onMessage(javax.jms.Message message)
- Specified by:
onMessage in interface javax.jms.MessageListener- Overrides:
onMessage in class ConsumerBean
getDestination
public javax.jms.Destination getDestination()
setDestination
public void setDestination(javax.jms.Destination destination)
getMyId
public java.lang.String getMyId()
setMyId
public void setMyId(java.lang.String myId)
getTemplate
public org.springframework.jms.core.JmsTemplate getTemplate()
setTemplate
public void setTemplate(org.springframework.jms.core.JmsTemplate template)