public abstract class AbstractActiveMQConsumerResource extends AbstractActiveMQClientResource
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) |
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) |
after, before, createBytesMessage, createDestination, createMapMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createMessage, createObjectMessage, createStreamMessage, createTextMessage, getBrokerURL, getClientId, getDestinationName, getDestinationType, setMessageProperties, start, stop
apply
public AbstractActiveMQConsumerResource(String destinationName, ActiveMQConnectionFactory connectionFactory)
public AbstractActiveMQConsumerResource(String destinationName, URI brokerURI)
public AbstractActiveMQConsumerResource(String destinationName, EmbeddedActiveMQBroker embeddedActiveMQBroker)
public AbstractActiveMQConsumerResource(String destinationName, URI brokerURI, String userName, String password)
public long getDefaultReceiveTimout()
public void setDefaultReceiveTimout(long defaultReceiveTimout)
protected void createClient() throws javax.jms.JMSException
createClient
in class AbstractActiveMQClientResource
javax.jms.JMSException
public javax.jms.BytesMessage receiveBytesMessage() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.TextMessage receiveTextMessage() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.MapMessage receiveMapMessage() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.ObjectMessage receiveObjectMessage() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.BytesMessage receiveBytesMessage(long timeout) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.TextMessage receiveTextMessage(long timeout) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.MapMessage receiveMapMessage(long timeout) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.ObjectMessage receiveObjectMessage(long timeout) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.Message receiveMessage() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.Message receiveMessage(long timeout) throws javax.jms.JMSException
timeout
- javax.jms.JMSException
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.