org.jbpm.test
Class JmsExtensions

java.lang.Object
  org.jbpm.test.JmsExtensions

public abstract class JmsExtensions
extends java.lang.Object

Author:

Tom Baeyens

Constructor Summary

JmsExtensions()

Method Summary

protected static void	bindToJndi(java.lang.String jndiName, java.lang.Object object)
static javax.jms.Message	consumeMessageFromQueue(java.lang.String connectionFactoryJndiName, java.lang.String queueJndiName, long timeout, boolean transacted, int acknowledgeMode)
static java.lang.Object	consumeMessageFromQueueXA(java.lang.String connectionFactoryJndiName, java.lang.String queueJndiName, long timeout)
static void	createQueue(java.lang.String connectionFactoryJndiName, java.lang.String queueJndiName)
static void	createTopic(java.lang.String connectionFactoryJndiName, java.lang.String topicJndiName)
static void	jmsAssertQueueEmpty(java.lang.String connectionFactoryJndiName, java.lang.String queueJndiName, long timeout, boolean transacted, int acknowledgeMode)
static void	jmsAssertQueueEmptyXA(java.lang.String connectionFactoryJndiName, java.lang.String queueJndiName, long timeout)
static void	removeQueue(java.lang.String connectionFactoryJndiName, java.lang.String queueJndiName)
static void	removeTopic(java.lang.String connectionFactoryJndiName, java.lang.String topicJndiName)
protected static void	unbindFromJndi(java.lang.String jndiName)

Methods inherited from class java.lang.Object

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

Constructor Detail

JmsExtensions

public JmsExtensions()

Method Detail

createQueue

public static void createQueue(java.lang.String connectionFactoryJndiName,
                               java.lang.String queueJndiName)

removeQueue

public static void removeQueue(java.lang.String connectionFactoryJndiName,
                               java.lang.String queueJndiName)

createTopic

public static void createTopic(java.lang.String connectionFactoryJndiName,
                               java.lang.String topicJndiName)

removeTopic

public static void removeTopic(java.lang.String connectionFactoryJndiName,
                               java.lang.String topicJndiName)

bindToJndi

protected static void bindToJndi(java.lang.String jndiName,
                                 java.lang.Object object)

unbindFromJndi

protected static void unbindFromJndi(java.lang.String jndiName)

consumeMessageFromQueueXA

public static java.lang.Object consumeMessageFromQueueXA(java.lang.String connectionFactoryJndiName,
                                                         java.lang.String queueJndiName,
                                                         long timeout)

consumeMessageFromQueue

public static javax.jms.Message consumeMessageFromQueue(java.lang.String connectionFactoryJndiName,
                                                        java.lang.String queueJndiName,
                                                        long timeout,
                                                        boolean transacted,
                                                        int acknowledgeMode)

jmsAssertQueueEmptyXA

public static void jmsAssertQueueEmptyXA(java.lang.String connectionFactoryJndiName,
                                         java.lang.String queueJndiName,
                                         long timeout)

jmsAssertQueueEmpty

public static void jmsAssertQueueEmpty(java.lang.String connectionFactoryJndiName,
                                       java.lang.String queueJndiName,
                                       long timeout,
                                       boolean transacted,
                                       int acknowledgeMode)