Spec-Zone .ru спецификации, руководства, описания, API

javax.jms
Сеанс интерфейса

Все Суперинтерфейсы:

java.lang. Выполнимый

Все Известные Подынтерфейсы:

QueueSession, TopicSession, XAQueueSession, XASession, XATopicSession

public interface Session
расширяет java.lang. Выполнимый

A Session объект является однопоточным контекстом для создания и потребления сообщений. Хотя это может выделить ресурсы провайдера вне виртуальной машины Java (JVM), это считают легким объектом JMS.

Сеанс служит нескольким целям:

• Это - фабрика для своих производителей сообщения и потребителей.
• Это предоставляет оптимизированные провайдером фабрики сообщения.
• Это - фабрика для TemporaryTopics и TemporaryQueues.
• Это обеспечивает способ создать Queue или Topic объекты для тех клиентов, которые должны динамически управлять специфичными для провайдера целевыми именами.
• Это поддерживает единственную серию транзакций, которые комбинируют работу, охватывающую ее производителей и потребителей в атомарные модули.
• Это определяет последовательный порядок на сообщения, которые это использует и сообщения, которые это производит.
• Это сохраняет сообщения, которые это использует, пока они не были подтверждены.
• Это сериализирует выполнение слушателей сообщения, зарегистрированных в его потребителях сообщения.
• Это - фабрика для QueueBrowsers.

Сеанс может создать и служба многократные производители сообщения и потребители.

У одного типичного использования должен быть блок потока на синхронном MessageConsumer пока сообщение не прибывает. Поток может тогда использовать один или больше Session's MessageProducers.

Если клиентские требования иметь один поток производят сообщения, в то время как другие используют их, клиент должен использовать отдельный сеанс для его потока создания.

Как только соединение было запущено, любой сеанс с один или более зарегистрированные слушатели сообщения выделяется потоку управления, которое передает сообщения к этому. Это ошибочно для клиентского кода, чтобы использовать этот сеанс или любой из его составляющих объектов от другого потока управления. Единственное исключение к этому правилу является использованием сеанса или соединения close метод.

Для большинства клиентов должно быть легко разделить их работу естественно в сеансы. Эта модель позволяет клиентам запускаться просто и с приращением добавлять сложность обработки сообщения, поскольку их потребность в параллелизме растет.

close метод является единственным методом сеанса, который можно вызвать, в то время как некоторый другой метод сеанса выполняется в другом потоке.

Сеанс может быть определен как проведено. Каждый проведенный сеанс поддерживает единственную серию транзакций. Каждая транзакция группы, которые ряд сообщения отправляет и ряд сообщения, получает в атомарную единицу работы. В действительности транзакции организуют поток входного сигнала сеанса и поток выходного сигнала в серию атомарных модулей. Когда транзакция фиксирует, ее атомарный модуль ввода подтверждается, и ее связанная атомарная единица продукции отправляется. Если откат транзакции делается, отправленные сообщения транзакции уничтожаются, и ввод сеанса автоматически восстанавливается.

Контент модулей ввода и вывода транзакции является просто теми сообщениями, которые были произведены и использованы в пределах текущей транзакции сеанса.

Транзакция завершается, используя любой ее сеанс commit метод или его сеанс rollback метод. Завершение текущей транзакции сеанса автоматически начинает следующее. Результат состоит в том, что у проведенного сеанса всегда есть текущая транзакция, в пределах которой делается ее работа.

Служба Транзакции Java (JTS) или некоторый другой монитор транзакций могут использоваться, чтобы объединить транзакцию сеанса с транзакциями на других ресурсах (базы данных, другие сеансы JMS, и т.д.). Так как распределенными транзакциями Java управляют через API Транзакции Java (JTA), использование сеанса commit и rollback методы в этом контексте запрещаются.

API JMS не требует поддержки JTA; однако, это действительно определяет, как провайдер предоставляет эту поддержку.

Хотя для клиента JMS также возможно обработать распределенные транзакции непосредственно, маловероятно, что много клиентов JMS сделают это. Поддержка JTA в API JMS предназначается в системных поставщиках, которые будут интегрировать API JMS в их продукты сервера приложений.

См. Также:

QueueSession, TopicSession, XASession

Полевая Сводка

static int	AUTO_ACKNOWLEDGE С этим режимом подтверждения сеанс автоматически подтверждает получение клиента сообщения также, когда сеанс успешно возвратился из звонка receive или когда слушатель сообщения, которого сеанс вызвал, чтобы обработать сообщение успешно, возвращается.
static int	CLIENT_ACKNOWLEDGE С этим режимом подтверждения клиент подтверждает использованное сообщение, вызывая сообщение acknowledge метод.
static int	DUPS_OK_ACKNOWLEDGE Этот режим подтверждения дает сеансу команду лениво подтверждать поставку сообщений.
static int	SESSION_TRANSACTED Это значение возвращается из метода getAcknowledgeMode если сеанс проводится.

Сводка метода

void	close() Закрывает сеанс.
void	commit() В настоящий момент сохранены фиксации все сообщения, сделанные в этой транзакции и выпусках любые блокировки.
QueueBrowser	createBrowser(Queue queue) Создает a QueueBrowser возразите, чтобы посмотреть на сообщения на указанной очереди.
QueueBrowser	createBrowser(Queue queue, java.lang.String messageSelector) Создает a QueueBrowser возразите, чтобы посмотреть на сообщения на указанной очереди, использующей селектор сообщения.
BytesMessage	createBytesMessage() Создает a BytesMessage объект.
MessageConsumer	createConsumer(Destination destination) Создает a MessageConsumer для указанного места назначения.
MessageConsumer	createConsumer(Destination destination, java.lang.String messageSelector) Создает a MessageConsumer для указанного места назначения, используя селектор сообщения.
MessageConsumer	createConsumer(Destination destination, java.lang.String messageSelector, boolean NoLocal) Создает MessageConsumer для указанного места назначения, используя селектор сообщения.
TopicSubscriber	createDurableSubscriber(Topic topic, java.lang.String name) Создает длительного подписчика к указанной теме.
TopicSubscriber	createDurableSubscriber(Topic topic, java.lang.String name, java.lang.String messageSelector, boolean noLocal) Создает длительного подписчика к указанной теме, используя селектор сообщения и определяя, должны ли сообщения, опубликованные его собственным соединением, быть переданы к этому.
MapMessage	createMapMessage() Создает a MapMessage объект.
Сообщение	createMessage() Создает a Message объект.
ObjectMessage	createObjectMessage() Создает ObjectMessage объект.
ObjectMessage	createObjectMessage(java.io.Serializable object) Создает инициализированный ObjectMessage объект.
MessageProducer	createProducer(Destination destination) Создает a MessageProducer отправить сообщения указанному месту назначения.
Очередь	createQueue(java.lang.String queueName) Создает идентификационные данные очереди, данные a Queue имя.
StreamMessage	createStreamMessage() Создает a StreamMessage объект.
TemporaryQueue	createTemporaryQueue() Создает a TemporaryQueue объект.
TemporaryTopic	createTemporaryTopic() Создает a TemporaryTopic объект.
TextMessage	createTextMessage() Создает a TextMessage объект.
TextMessage	createTextMessage(java.lang.String text) Создает инициализированный TextMessage объект.
Тема	createTopic(java.lang.String topicName) Создает идентификационные данные темы, данные a Topic имя.
int	getAcknowledgeMode() Возвращает режим подтверждения сеанса.
MessageListener	getMessageListener() Возвращает выдающегося (дополнительного) слушателя сообщения сеанса.
boolean	getTransacted() Указывает, является ли сеанс в транзакционном режиме.
void	recover() Доставка сообщений остановок в этом сеансе, и доставка сообщений перезапусков с самым старым непризнанным сообщением.
void	rollback() Откатывает любые сообщения, сделанные в этой транзакции, и выпускает любые блокировки, в настоящий момент сохраненные.
void	run() Дополнительная работа, предназначенная, чтобы использоваться только Серверами приложений, не обычными клиентами JMS.
void	setMessageListener(MessageListener listener) Устанавливает выдающегося (дополнительного) слушателя сообщения сеанса.
void	unsubscribe(java.lang.String name) Отписывает длительную подписку, которая была создана клиентом.

Полевая Деталь

AUTO_ACKNOWLEDGE

static final int AUTO_ACKNOWLEDGE

С этим режимом подтверждения сеанс автоматически подтверждает получение клиента сообщения также, когда сеанс успешно возвратился из звонка receive или когда слушатель сообщения, которого сеанс вызвал, чтобы обработать сообщение успешно, возвращается.

См. Также:

Постоянные Значения полей

CLIENT_ACKNOWLEDGE

static final int CLIENT_ACKNOWLEDGE

С этим режимом подтверждения клиент подтверждает использованное сообщение, вызывая сообщение acknowledge метод. Подтверждение использованного сообщения подтверждает все сообщения, что сеанс использовал.

Когда клиентский режим подтверждения используется, клиент может создать большое количество непризнанных сообщений, пытаясь обработать их. Провайдер JMS должен предоставить администраторам способ ограничить клиент, превышенный так, чтобы клиенты не управлялись к исчерпанию ресурса и следующему отказу, когда некоторый ресурс, который они используют, временно блокируется.

См. Также:

Message.acknowledge(), Постоянные Значения полей

DUPS_OK_ACKNOWLEDGE

static final int DUPS_OK_ACKNOWLEDGE

Этот режим подтверждения дает сеансу команду лениво подтверждать поставку сообщений. Это, вероятно, приведет к поставке некоторых двойных сообщений, если провайдер JMS перестанет работать, таким образом, это должно только использоваться потребителями, которые могут терпеть двойные сообщения. Использование этого режима может уменьшить издержки сеанса, минимизируя работу, которую сеанс делает, чтобы предотвратить копии.

См. Также:

Постоянные Значения полей

SESSION_TRANSACTED

static final int SESSION_TRANSACTED

Это значение возвращается из метода getAcknowledgeMode если сеанс проводится. Если a Session проводится, режим подтверждения игнорируется.

См. Также:

Постоянные Значения полей

Деталь метода

createBytesMessage

BytesMessage createBytesMessage()
                                throws JMSException

Создает a BytesMessage объект. A BytesMessage объект используется, чтобы отправить сообщение, содержащее поток неинтерпретируемых байтов.

Броски:

JMSException - если провайдер JMS не в состоянии создать это сообщение из-за некоторой внутренней ошибки.

createMapMessage

MapMessage createMapMessage()
                            throws JMSException

Создает a MapMessage объект. A MapMessage объект используется, чтобы отправить набор самоопределения пар значение-имя, где имена String объекты и значения являются примитивными значениями в языке программирования Java.

Броски:

JMSException - если провайдер JMS не в состоянии создать это сообщение из-за некоторой внутренней ошибки.

createMessage

Message createMessage()
                      throws JMSException

Создает a Message объект. Message интерфейс является корневым интерфейсом всех сообщений JMS. A Message объект содержит всю стандартную информацию о заголовке сообщения. Это может быть отправлено, когда сообщение, содержащее только информацию о заголовке, достаточно.

Броски:

JMSException - если провайдер JMS не в состоянии создать это сообщение из-за некоторой внутренней ошибки.

createObjectMessage

ObjectMessage createObjectMessage()
                                  throws JMSException

Создает ObjectMessage объект. ObjectMessage объект используется, чтобы отправить сообщение, которое содержит сериализуемый объект Java.

Броски:

JMSException - если провайдер JMS не в состоянии создать это сообщение из-за некоторой внутренней ошибки.

createObjectMessage

ObjectMessage createObjectMessage(java.io.Serializable object)
                                  throws JMSException

Создает инициализированный ObjectMessage объект. ObjectMessage объект используется, чтобы отправить сообщение, которое содержит сериализуемый объект Java.

Параметры:

object - объект использовать, чтобы инициализировать это сообщение

Броски:

JMSException - если провайдер JMS не в состоянии создать это сообщение из-за некоторой внутренней ошибки.

createStreamMessage

StreamMessage createStreamMessage()
                                  throws JMSException

Создает a StreamMessage объект. A StreamMessage объект используется, чтобы отправить поток самоопределения примитивных значений в языке программирования Java.

Броски:

JMSException - если провайдер JMS не в состоянии создать это сообщение из-за некоторой внутренней ошибки.

createTextMessage

TextMessage createTextMessage()
                              throws JMSException

Создает a TextMessage объект. A TextMessage объект используется, чтобы отправить сообщение, содержащее a String объект.

Броски:

JMSException - если провайдер JMS не в состоянии создать это сообщение из-за некоторой внутренней ошибки.

createTextMessage

TextMessage createTextMessage(java.lang.String text)
                              throws JMSException

Создает инициализированный TextMessage объект. A TextMessage объект используется, чтобы отправить сообщение, содержащее a String.

Параметры:

text - строка, используемая, чтобы инициализировать это сообщение

Броски:

JMSException - если провайдер JMS не в состоянии создать это сообщение из-за некоторой внутренней ошибки.

getTransacted

boolean getTransacted()
                      throws JMSException

Указывает, является ли сеанс в транзакционном режиме.

Возвраты:

истина, если сеанс находится в транзакционном режиме

Броски:

JMSException - если провайдер JMS не в состоянии возвратить режим транзакции из-за некоторой внутренней ошибки.

getAcknowledgeMode

int getAcknowledgeMode()
                       throws JMSException

Возвращает режим подтверждения сеанса. Режим подтверждения устанавливается в то время, когда сеанс создается. Если сеанс проводится, режим подтверждения игнорируется.

Возвраты:

Если сеанс не проводится, возвращает текущий режим подтверждения для сеанса. Если сеанс проводится, SESSION_TRANSACTED возвратов.

Броски:

JMSException - если провайдер JMS не в состоянии возвратить режим подтверждения из-за некоторой внутренней ошибки.

С тех пор:

1.1

См. Также:

Connection#createSession

фиксация

void commit()
            throws JMSException

В настоящий момент сохранены фиксации все сообщения, сделанные в этой транзакции и выпусках любые блокировки.

Броски:

JMSException - если провайдер JMS не в состоянии фиксировать транзакцию из-за некоторой внутренней ошибки.

TransactionRolledBackException - если транзакция откатывается из-за некоторой внутренней ошибки во время фиксации.

IllegalStateException - если метод не вызывает проведенный сеанс.

откат

void rollback()
              throws JMSException

Откатывает любые сообщения, сделанные в этой транзакции, и выпускает любые блокировки, в настоящий момент сохраненные.

Броски:

JMSException - если провайдер JMS не в состоянии откатывать транзакцию из-за некоторой внутренней ошибки.

IllegalStateException - если метод не вызывает проведенный сеанс.

близко

void close()
           throws JMSException

Закрывает сеанс.

Так как провайдер может выделить некоторые ресурсы от имени сеанса вне JVM, клиенты должны закрыть ресурсы, когда они не необходимы. Доверие сборке "мусора", чтобы в конечном счете исправить эти ресурсы, возможно, не достаточно своевременно.

Нет никакой потребности закрыть производителей и потребителей закрытого сеанса.

Этот вызов блокирует до a receive вызовите или обменивайтесь сообщениями, происходящий слушатель завершился. Блокированный потребитель сообщения receive вызовите возвраты null когда этот сеанс закрывается.

Закрытие проведенного сеанса должно откатывать происходящую транзакцию.

Этот метод является единственным Session метод, который можно вызвать одновременно.

Вызов любого другого Session метод на закрытом сеансе должен бросить a JMSException.IllegalStateException. Закрытие закрытого сеанса не должно выдать исключение.

Броски:

JMSException - если провайдер JMS не в состоянии закрыть сеанс из-за некоторой внутренней ошибки.

восстановиться

void recover()
             throws JMSException

Доставка сообщений остановок в этом сеансе, и доставка сообщений перезапусков с самым старым непризнанным сообщением.

Все потребители передают сообщения в последовательном порядке. Подтверждение полученного сообщения автоматически подтверждает все сообщения, которые были переданы клиенту.

Перезапуск сеанса заставляет это предпринимать следующие меры:

• Остановите доставку сообщений
• Отметьте все сообщения, которые, возможно, были переданы, но не подтверждены как "повторно поставлено"
• Перезапустите последовательность поставки включая все непризнанные сообщения, которые были ранее переданы. Повторно поставленные сообщения не должны быть переданы в точно их исходном заказе на поставку.

Броски:

JMSException - если провайдер JMS не в состоянии остановить и перезапустить доставку сообщений из-за некоторой внутренней ошибки.

IllegalStateException - если метод вызывает проведенный сеанс.

getMessageListener

MessageListener getMessageListener()
                                   throws JMSException

Возвращает выдающегося (дополнительного) слушателя сообщения сеанса.

Возвраты:

слушатель сообщения связался с этим сеансом

Броски:

JMSException - если провайдер JMS не в состоянии получить слушателя сообщения из-за внутренней ошибки.

См. Также:

setMessageListener(javax.jms.MessageListener), ServerSessionPool, ServerSession

setMessageListener

void setMessageListener(MessageListener listener)
                        throws JMSException

Устанавливает выдающегося (дополнительного) слушателя сообщения сеанса.

Когда выдающийся слушатель сообщения устанавливается, никакая другая форма получения сообщения в сеансе не может использоваться; однако, все формы отправки сообщений все еще поддерживаются.

Это - опытное средство, не используемое регулярными клиентами JMS.

Параметры:

listener - слушатель сообщения, чтобы связаться с этим сеансом

Броски:

JMSException - если провайдер JMS не в состоянии установить слушателя сообщения из-за внутренней ошибки.

См. Также:

getMessageListener(), ServerSessionPool, ServerSession

выполненный

void run()

Дополнительная работа, предназначенная, чтобы использоваться только Серверами приложений, не обычными клиентами JMS.

Определенный:

run в интерфейсе java.lang.Runnable

См. Также:

ServerSession

createProducer

MessageProducer createProducer(Destination destination)
                               throws JMSException

Создает a MessageProducer отправить сообщения указанному месту назначения.

Клиент использует a MessageProducer объект отправить сообщения месту назначения. С тех пор Queue и Topic оба наследовались от Destination, они могут использоваться в целевом параметре, чтобы создать a MessageProducer объект.

Параметры:

destination - Destination передаться к, или нуль, если это - производитель, у которого нет указанного места назначения.

Броски:

JMSException - если сеанс не в состоянии создать MessageProducer из-за некоторой внутренней ошибки.

InvalidDestinationException - если недопустимое место назначения определяется.

С тех пор:

1.1

createConsumer

MessageConsumer createConsumer(Destination destination)
                               throws JMSException

Создает a MessageConsumer для указанного места назначения. С тех пор Queue и Topic оба наследовались от Destination, они могут использоваться в целевом параметре, чтобы создать a MessageConsumer.

Параметры:

destination - Destination к доступу.

Броски:

JMSException - если сеанс не в состоянии создать потребителя из-за некоторой внутренней ошибки.

InvalidDestinationException - если недопустимое место назначения определяется.

С тех пор:

1.1

createConsumer

MessageConsumer createConsumer(Destination destination,
                               java.lang.String messageSelector)
                               throws JMSException

Создает a MessageConsumer для указанного места назначения, используя селектор сообщения. С тех пор Queue и Topic оба наследовались от Destination, они могут использоваться в целевом параметре, чтобы создать a MessageConsumer.

Клиент использует a MessageConsumer объект получить сообщения, которые были отправлены месту назначения.

Параметры:

destination - Destination к доступу

messageSelector - только сообщения со свойствами, соответствующими выражение селектора сообщения, передаются. Значение нуля или пустой строки указывает, что нет никакого селектора сообщения для потребителя сообщения.

Броски:

JMSException - если сеанс не в состоянии создать MessageConsumer из-за некоторой внутренней ошибки.

InvalidDestinationException - если недопустимое место назначения определяется.

InvalidSelectorException - если селектор сообщения недопустим.

С тех пор:

1.1

createConsumer

MessageConsumer createConsumer(Destination destination,
                               java.lang.String messageSelector,
                               boolean NoLocal)
                               throws JMSException

Создает MessageConsumer для указанного места назначения, используя селектор сообщения. Этот метод может определить, должны ли сообщения, опубликованные его собственным соединением, быть переданы к этому, если место назначения является темой.

С тех пор Queue и Topic оба наследовались от Destination, они могут использоваться в целевом параметре, чтобы создать a MessageConsumer.

Клиент использует a MessageConsumer объект получить сообщения, которые были опубликованы месту назначения.

В некоторых случаях соединение может и опубликовать и подписаться на тему. Потребитель NoLocal атрибут позволяет потребителю подавлять поставку сообщений, опубликованных ее собственным соединением. Значение по умолчанию для этого атрибута является Ложью. noLocal значение должно поддерживаться местами назначения, которые являются темами.

Параметры:

destination - Destination к доступу

messageSelector - только сообщения со свойствами, соответствующими выражение селектора сообщения, передаются. Значение нуля или пустой строки указывает, что нет никакого селектора сообщения для потребителя сообщения.

NoLocal - если это правда, и место назначения тема, запрещает поставку сообщений, опубликованных ее собственным соединением. Поведение для NoLocal не определяется, если место назначения является очередью.

Броски:

JMSException - если сеанс не в состоянии создать MessageConsumer из-за некоторой внутренней ошибки.

InvalidDestinationException - если недопустимое место назначения определяется.

InvalidSelectorException - если селектор сообщения недопустим.

С тех пор:

1.1

createQueue

Queue createQueue(java.lang.String queueName)
                  throws JMSException

Создает идентификационные данные очереди, данные a Queue имя.

Это средство предоставляется для редких случаев, где клиенты должны динамически управлять идентификационными данными очереди. Это позволяет создание идентификационных данных очереди со специфичным для провайдера именем. Клиенты, которые зависят от этой возможности, не переносимы.

Отметьте, что этот метод не для того, чтобы создать физическую очередь. Физическое создание очередей является задачей администрирования и не должно инициироваться API JMS. Одно исключение является созданием временных очередей, которое выполняется с createTemporaryQueue метод.

Параметры:

queueName - имя этого Queue

Возвраты:

a Queue с именем

Броски:

JMSException - если сеанс не в состоянии создать очередь из-за некоторой внутренней ошибки.

С тех пор:

1.1

createTopic

Topic createTopic(java.lang.String topicName)
                  throws JMSException

Создает идентификационные данные темы, данные a Topic имя.

Это средство предоставляется для редких случаев, где клиенты должны динамически управлять идентификационными данными темы. Это позволяет создание идентификационных данных темы со специфичным для провайдера именем. Клиенты, которые зависят от этой возможности, не переносимы.

Отметьте, что этот метод не для того, чтобы создать физическую тему. Физическое создание тем является задачей администрирования и не должно инициироваться API JMS. Одно исключение является созданием временных тем, которое выполняется с createTemporaryTopic метод.

Параметры:

topicName - имя этого Topic

Возвраты:

a Topic с именем

Броски:

JMSException - если сеанс не в состоянии создать тему из-за некоторой внутренней ошибки.

С тех пор:

1.1

createDurableSubscriber

TopicSubscriber createDurableSubscriber(Topic topic,
                                        java.lang.String name)
                                        throws JMSException

Создает длительного подписчика к указанной теме.

Если клиент должен получить все сообщения, опубликованные на теме, включая тех опубликованных, в то время как подписчик неактивен, она использует длительное TopicSubscriber. Провайдер JMS сохраняет запись этой длительной подписки и обеспечивает, чтобы все сообщения от издателей темы были сохранены, пока они не подтверждаются этим длительным подписчиком, или они истекли.

Сеансы с длительными подписчиками должны всегда обеспечивать тот же самый клиентский идентификатор. Кроме того, каждый клиент должен определить имя, которое однозначно определяет (в пределах клиентского идентификатора) каждую длительную подписку, которую он создает. Только у одного сеанса за один раз может быть a TopicSubscriber для определенной длительной подписки.

Клиент может изменить существующую длительную подписку, создавая длительное TopicSubscriber с тем же самым именем и новой темой и/или селектором сообщения. Изменение длительного подписчика эквивалентно отмене подписки (удаления) старого и создания нового.

В некоторых случаях соединение может и опубликовать и подписаться на тему. Подписчик NoLocal атрибут позволяет подписчику подавлять поставку сообщений, опубликованных ее собственным соединением. Значение по умолчанию для этого атрибута является ложью.

Параметры:

topic - невременное Topic подписываться на

name - имя, используемое, чтобы идентифицировать эту подписку

Броски:

JMSException - если сеанс не в состоянии создать подписчика из-за некоторой внутренней ошибки.

InvalidDestinationException - если недопустимая тема определяется.

С тех пор:

1.1

createDurableSubscriber

TopicSubscriber createDurableSubscriber(Topic topic,
                                        java.lang.String name,
                                        java.lang.String messageSelector,
                                        boolean noLocal)
                                        throws JMSException

Создает длительного подписчика к указанной теме, используя селектор сообщения и определяя, должны ли сообщения, опубликованные его собственным соединением, быть переданы к этому.

Если клиент должен получить все сообщения, опубликованные на теме, включая тех опубликованных, в то время как подписчик неактивен, она использует длительное TopicSubscriber. Провайдер JMS сохраняет запись этой длительной подписки и обеспечивает, чтобы все сообщения от издателей темы были сохранены, пока они не подтверждаются этим длительным подписчиком, или они истекли.

Сеансы с длительными подписчиками должны всегда обеспечивать тот же самый клиентский идентификатор. Кроме того, каждый клиент должен определить имя, которое однозначно определяет (в пределах клиентского идентификатора) каждую длительную подписку, которую он создает. Только у одного сеанса за один раз может быть a TopicSubscriber для определенной длительной подписки. Неактивный длительный подписчик является тем, который существует, но в настоящий момент не связывал потребителя сообщения с этим.

Клиент может изменить существующую длительную подписку, создавая длительное TopicSubscriber с тем же самым именем и новой темой и/или селектором сообщения. Изменение длительного подписчика эквивалентно отмене подписки (удаления) старого и создания нового.

Параметры:

topic - невременное Topic подписываться на

name - имя, используемое, чтобы идентифицировать эту подписку

messageSelector - только сообщения со свойствами, соответствующими выражение селектора сообщения, передаются. Значение нуля или пустой строки указывает, что нет никакого селектора сообщения для потребителя сообщения.

noLocal - если установлено, запрещает поставку сообщений, опубликованных ее собственным соединением

Броски:

JMSException - если сеанс не в состоянии создать подписчика из-за некоторой внутренней ошибки.

InvalidDestinationException - если недопустимая тема определяется.

InvalidSelectorException - если селектор сообщения недопустим.

С тех пор:

1.1

createBrowser

QueueBrowser createBrowser(Queue queue)
                           throws JMSException

Создает a QueueBrowser возразите, чтобы посмотреть на сообщения на указанной очереди.

Параметры:

queue - queue к доступу

Броски:

JMSException - если сеанс не в состоянии создать браузер из-за некоторой внутренней ошибки.

InvalidDestinationException - если недопустимое место назначения определяется

С тех пор:

1.1

createBrowser

QueueBrowser createBrowser(Queue queue,
                           java.lang.String messageSelector)
                           throws JMSException

Создает a QueueBrowser возразите, чтобы посмотреть на сообщения на указанной очереди, использующей селектор сообщения.

Параметры:

queue - queue к доступу

messageSelector - только сообщения со свойствами, соответствующими выражение селектора сообщения, передаются. Значение нуля или пустой строки указывает, что нет никакого селектора сообщения для потребителя сообщения.

Броски:

JMSException - если сеанс не в состоянии создать браузер из-за некоторой внутренней ошибки.

InvalidDestinationException - если недопустимое место назначения определяется

InvalidSelectorException - если селектор сообщения недопустим.

С тех пор:

1.1

createTemporaryQueue

TemporaryQueue createTemporaryQueue()
                                    throws JMSException

Создает a TemporaryQueue объект. Его время жизни будет временем жизни Connection если это не удаляется ранее.

Возвраты:

временные идентификационные данные очереди

Броски:

JMSException - если сеанс не в состоянии создать временную очередь из-за некоторой внутренней ошибки.

С тех пор:

1.1

createTemporaryTopic

TemporaryTopic createTemporaryTopic()
                                    throws JMSException

Создает a TemporaryTopic объект. Его время жизни будет временем жизни Connection если это не удаляется ранее.

Возвраты:

временные идентификационные данные темы

Броски:

JMSException - если сеанс не в состоянии создать временную тему из-за некоторой внутренней ошибки.

С тех пор:

1.1

отписаться

void unsubscribe(java.lang.String name)
                 throws JMSException

Отписывает длительную подписку, которая была создана клиентом.

Этот метод удаляет состояние, сохраняемое от имени подписчика его провайдером.

Это ошибочно для клиента, чтобы удалить длительную подписку, в то время как есть активное MessageConsumer или TopicSubscriber для подписки, или в то время как использованное сообщение является частью транзакции на ожидании или не было подтверждено в сеансе.

Параметры:

name - имя, используемое, чтобы идентифицировать эту подписку

Броски:

JMSException - если сеанс не в состоянии отписаться к длительной подписке из-за некоторой внутренней ошибки.

InvalidDestinationException - если недопустимое имя подписки определяется.

С тех пор:

1.1