org.jbpm.msg.jms
Class JmsMessageService

java.lang.Object
  org.jbpm.msg.jms.JmsMessageService

All Implemented Interfaces:

Serializable, org.jbpm.msg.MessageService, org.jbpm.svc.Service

Direct Known Subclasses:

JmsMessageServiceImpl

public class JmsMessageService
extends Object
implements org.jbpm.msg.MessageService

See Also:

Serialized Form

Constructor Summary

JmsMessageService(javax.jms.Connection connection, javax.jms.Destination destination, boolean commitEnabled)
Deprecated. use JmsMessageService(JmsMessageServiceFactory) instead

JmsMessageService(JmsMessageServiceFactory serviceFactory)

Method Summary

void	close()
protected javax.jms.MessageProducer	getMessageProducer()
javax.jms.Session	getSession()
protected void	modifyMessage(javax.jms.Message message, org.jbpm.job.Job job) Hook to modify the message, e.g.
void	send(org.jbpm.job.Job job)

Methods inherited from class java.lang.Object

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

Constructor Detail

JmsMessageService

public JmsMessageService(javax.jms.Connection connection,
                         javax.jms.Destination destination,
                         boolean commitEnabled)
                  throws javax.jms.JMSException

Deprecated. use JmsMessageService(JmsMessageServiceFactory) instead

Throws:

javax.jms.JMSException

JmsMessageService

public JmsMessageService(JmsMessageServiceFactory serviceFactory)
                  throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Method Detail

send

public void send(org.jbpm.job.Job job)

Specified by:

send in interface org.jbpm.msg.MessageService

modifyMessage

protected void modifyMessage(javax.jms.Message message,
                             org.jbpm.job.Job job)
                      throws javax.jms.JMSException

Hook to modify the message, e.g. adding extra properties to the header required by the own application. One possible use case is to rescue the actor id over the "JMS" intermezzo of asynchronous continuations.

Throws:

javax.jms.JMSException

close

public void close()

Specified by:

close in interface org.jbpm.msg.MessageService

Specified by:

close in interface org.jbpm.svc.Service

getSession

public javax.jms.Session getSession()

getMessageProducer

protected javax.jms.MessageProducer getMessageProducer()
                                                throws javax.jms.JMSException

Throws:

javax.jms.JMSException