org.apache.activemq.junit

Class AbstractActiveMQConsumerResource

java.lang.Object

org.junit.rules.ExternalResource

org.apache.activemq.junit.AbstractActiveMQClientResource

org.apache.activemq.junit.AbstractActiveMQConsumerResource

All Implemented Interfaces:

org.junit.rules.TestRule

Direct Known Subclasses:

ActiveMQQueueReceiverResource, ActiveMQTopicDurableSubscriberResource, ActiveMQTopicSubscriberResource

public abstract class AbstractActiveMQConsumerResource
extends AbstractActiveMQClientResource

Constructor Summary

Constructors

Constructor and Description
AbstractActiveMQConsumerResource(String destinationName, ActiveMQConnectionFactory connectionFactory)
AbstractActiveMQConsumerResource(String destinationName, EmbeddedActiveMQBroker embeddedActiveMQBroker)
AbstractActiveMQConsumerResource(String destinationName, URI brokerURI)
AbstractActiveMQConsumerResource(String destinationName, URI brokerURI, String userName, String password)

Method Summary

Modifier and Type	Method and Description
protected void	createClient()
long	getDefaultReceiveTimout()
javax.jms.BytesMessage	receiveBytesMessage()
javax.jms.BytesMessage	receiveBytesMessage(long timeout)
javax.jms.MapMessage	receiveMapMessage()
javax.jms.MapMessage	receiveMapMessage(long timeout)
javax.jms.Message	receiveMessage()
javax.jms.Message	receiveMessage(long timeout) Receive a message with the given timeout
javax.jms.ObjectMessage	receiveObjectMessage()
javax.jms.ObjectMessage	receiveObjectMessage(long timeout)
javax.jms.TextMessage	receiveTextMessage()
javax.jms.TextMessage	receiveTextMessage(long timeout)
void	setDefaultReceiveTimout(long defaultReceiveTimout)

Methods inherited from class org.apache.activemq.junit.AbstractActiveMQClientResource

after, before, createBytesMessage, createDestination, createMapMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createObjectMessage, createStreamMessage, createTextMessage, getBrokerURL, getClientId, getDestinationName, getDestinationType, setMessageProperties, start, stop

Methods inherited from class org.junit.rules.ExternalResource

apply

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractActiveMQConsumerResource

public AbstractActiveMQConsumerResource(String destinationName,
                                        ActiveMQConnectionFactory connectionFactory)

AbstractActiveMQConsumerResource

public AbstractActiveMQConsumerResource(String destinationName,
                                        URI brokerURI)

AbstractActiveMQConsumerResource

public AbstractActiveMQConsumerResource(String destinationName,
                                        EmbeddedActiveMQBroker embeddedActiveMQBroker)

AbstractActiveMQConsumerResource

public AbstractActiveMQConsumerResource(String destinationName,
                                        URI brokerURI,
                                        String userName,
                                        String password)

Method Detail

getDefaultReceiveTimout

public long getDefaultReceiveTimout()

setDefaultReceiveTimout

public void setDefaultReceiveTimout(long defaultReceiveTimout)

createClient

protected void createClient()
                     throws javax.jms.JMSException

Specified by:

createClient in class AbstractActiveMQClientResource

Throws:

javax.jms.JMSException

receiveBytesMessage

public javax.jms.BytesMessage receiveBytesMessage()
                                           throws javax.jms.JMSException

Throws:

javax.jms.JMSException

receiveTextMessage

public javax.jms.TextMessage receiveTextMessage()
                                         throws javax.jms.JMSException

Throws:

javax.jms.JMSException

receiveMapMessage

public javax.jms.MapMessage receiveMapMessage()
                                       throws javax.jms.JMSException

Throws:

javax.jms.JMSException

receiveObjectMessage

public javax.jms.ObjectMessage receiveObjectMessage()
                                             throws javax.jms.JMSException

Throws:

javax.jms.JMSException

receiveBytesMessage

public javax.jms.BytesMessage receiveBytesMessage(long timeout)
                                           throws javax.jms.JMSException

Throws:

javax.jms.JMSException

receiveTextMessage

public javax.jms.TextMessage receiveTextMessage(long timeout)
                                         throws javax.jms.JMSException

Throws:

javax.jms.JMSException

receiveMapMessage

public javax.jms.MapMessage receiveMapMessage(long timeout)
                                       throws javax.jms.JMSException

Throws:

javax.jms.JMSException

receiveObjectMessage

public javax.jms.ObjectMessage receiveObjectMessage(long timeout)
                                             throws javax.jms.JMSException

Throws:

javax.jms.JMSException

receiveMessage

public javax.jms.Message receiveMessage()
                                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

receiveMessage

public javax.jms.Message receiveMessage(long timeout)
                                 throws javax.jms.JMSException

Receive a message with the given timeout

Parameters:

timeout -

Returns:

Throws:

javax.jms.JMSException