public interface AQjmsTopicSubscriber extends TopicSubscriber
Modifier and Type | Method and Description |
---|---|
int |
getNavigationMode()
Get the navigation mode for receiving messages.
|
Message |
receive(long timeout, oracle.jms.AQjmsSignature signature)
Receive the next message if available within the specified timeout.
|
void |
receiveNoData()
Consume the message without returning it to the user.
|
void |
receiveNoData(long timeout)
Consume the message without returning it to the user.
|
void |
setNavigationMode(int mode)
Set the navigation mode used for receiving messagess.
|
getNoLocal, getTopic
close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener
int getNavigationMode() throws JMSException
JMSException
- if the navigation mode could not be setvoid setNavigationMode(int mode) throws JMSException
mode
- the new value of the navigation mode. See the "Oracle® Database Advanced Queuing User's Guide and Reference" for explanation of the navigation mode. The valid values of this parameter are oracle.jms.AQjmsConstants.NAVIGATION_FIRST_MESSAGE oracle.jms.AQjmsConstants.NAVIGATION_NEXT_MESSAGE oracle.jms.AQjmsConstants.NAVIGATION_NEXT_TRANSACTIONJMSException
- if there was an error in getting the navigation mode.void receiveNoData() throws JMSException
JMSException
- if the message could not be received due to an error.void receiveNoData(long timeout) throws JMSException
timeout
- the timeout value in milliseconds.JMSException
- if the message could not be received due to an error.Message receive(long timeout, oracle.jms.AQjmsSignature signature) throws JMSException
timeout
- the timeout value (in milliseconds)signature
- the signature value.null
if one is not available.JMSException
- if JMS fails to receive the next message due to some error.