public interface Session
extends javax.jms.TopicSession, javax.jms.QueueSession
Modifier and Type | Field and Description |
---|---|
static int |
NO_ACKNOWLEDGE
Indicates that no client acknowledgements are required.
|
static int |
PRE_ACKNOWLEDGE
Pre acknowledge means that an ack is sent per message but sent before user code has processed
the message (i.e.
|
Modifier and Type | Method and Description |
---|---|
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination destination,
int prefetch,
boolean noLocal,
boolean exclusive,
String selector) |
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination destination,
int prefetchHigh,
int prefetchLow,
boolean noLocal,
boolean exclusive,
String selector) |
ListMessage |
createListMessage() |
javax.jms.MessageProducer |
createProducer(javax.jms.Destination destination,
boolean immediate)
Create a producer
|
javax.jms.MessageProducer |
createProducer(javax.jms.Destination destination,
boolean mandatory,
boolean immediate)
Create a producer
|
void |
deleteExchange(String exchangeName)
Deletes the exchange identified by the given name.
|
void |
deleteQueue(String queueName)
Deletes the queue identified by the given name.
|
int |
getDefaultPrefetch() |
int |
getDefaultPrefetchHigh() |
int |
getDefaultPrefetchLow() |
String |
getDefaultQueueExchangeName() |
String |
getDefaultTopicExchangeName() |
String |
getTemporaryQueueExchangeName() |
String |
getTemporaryTopicExchangeName() |
createDurableSubscriber, createDurableSubscriber, createPublisher, createSubscriber, createSubscriber, createTemporaryTopic, createTopic, unsubscribe
createBrowser, createBrowser, createQueue, createReceiver, createReceiver, createSender, createTemporaryQueue
close, commit, createBytesMessage, createConsumer, createConsumer, createConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createStreamMessage, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, getTransacted, recover, rollback, run, setMessageListener
static final int NO_ACKNOWLEDGE
static final int PRE_ACKNOWLEDGE
javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination, int prefetch, boolean noLocal, boolean exclusive, String selector) throws javax.jms.JMSException
javax.jms.JMSException
javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination, int prefetchHigh, int prefetchLow, boolean noLocal, boolean exclusive, String selector) throws javax.jms.JMSException
javax.jms.JMSException
int getDefaultPrefetch()
int getDefaultPrefetchHigh()
int getDefaultPrefetchLow()
javax.jms.MessageProducer createProducer(javax.jms.Destination destination, boolean mandatory, boolean immediate) throws javax.jms.JMSException
destination
- mandatory
- the value of the mandatory flag used by default on the producerimmediate
- the value of the immediate flag used by default on the producerjavax.jms.JMSException
javax.jms.MessageProducer createProducer(javax.jms.Destination destination, boolean immediate) throws javax.jms.JMSException
destination
- immediate
- the value of the immediate flag used by default on the producerjavax.jms.JMSException
String getTemporaryTopicExchangeName()
String getDefaultQueueExchangeName()
String getDefaultTopicExchangeName()
String getTemporaryQueueExchangeName()
ListMessage createListMessage() throws javax.jms.JMSException
javax.jms.JMSException
void deleteQueue(String queueName) throws javax.jms.JMSException
queueName
- name of the queuejavax.jms.JMSException
void deleteExchange(String exchangeName) throws javax.jms.JMSException
exchangeName
- name of the exchangejavax.jms.JMSException
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.