Package dk.netarkivet.common.distribute
Class JMSConnectionMockupMQ.TestMessageConsumer
- java.lang.Object
-
- dk.netarkivet.common.distribute.JMSConnectionMockupMQ.TestMessageConsumer
-
- All Implemented Interfaces:
javax.jms.MessageConsumer
- Direct Known Subclasses:
JMSConnectionMockupMQ.TestQueueReceiver
- Enclosing class:
- JMSConnectionMockupMQ
protected static class JMSConnectionMockupMQ.TestMessageConsumer extends Object implements javax.jms.MessageConsumer
-
-
Field Summary
Fields Modifier and Type Field Description protected JMSConnectionMockupMQ.TestDestination
destination
-
Constructor Summary
Constructors Constructor Description TestMessageConsumer(javax.jms.Destination destination)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
javax.jms.MessageListener
getMessageListener()
String
getMessageSelector()
javax.jms.Message
receive()
javax.jms.Message
receive(long l)
javax.jms.Message
receiveNoWait()
void
setMessageListener(javax.jms.MessageListener messageListener)
-
-
-
Field Detail
-
destination
protected JMSConnectionMockupMQ.TestDestination destination
-
-
Method Detail
-
getMessageListener
public javax.jms.MessageListener getMessageListener() throws javax.jms.JMSException
- Specified by:
getMessageListener
in interfacejavax.jms.MessageConsumer
- Throws:
javax.jms.JMSException
-
setMessageListener
public void setMessageListener(javax.jms.MessageListener messageListener) throws javax.jms.JMSException
- Specified by:
setMessageListener
in interfacejavax.jms.MessageConsumer
- Throws:
javax.jms.JMSException
-
close
public void close() throws javax.jms.JMSException
- Specified by:
close
in interfacejavax.jms.MessageConsumer
- Throws:
javax.jms.JMSException
-
getMessageSelector
public String getMessageSelector() throws javax.jms.JMSException
- Specified by:
getMessageSelector
in interfacejavax.jms.MessageConsumer
- Throws:
javax.jms.JMSException
-
receive
public javax.jms.Message receive() throws javax.jms.JMSException
- Specified by:
receive
in interfacejavax.jms.MessageConsumer
- Throws:
javax.jms.JMSException
-
receive
public javax.jms.Message receive(long l) throws javax.jms.JMSException
- Specified by:
receive
in interfacejavax.jms.MessageConsumer
- Throws:
javax.jms.JMSException
-
receiveNoWait
public javax.jms.Message receiveNoWait() throws javax.jms.JMSException
- Specified by:
receiveNoWait
in interfacejavax.jms.MessageConsumer
- Throws:
javax.jms.JMSException
-
-