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

javax.jms
Интерфейс MessageConsumer

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

QueueReceiver, TopicSubscriber

public interface MessageConsumer

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

MessageConsumer родительский интерфейс для всех потребителей сообщения.

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

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

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

Для асинхронной поставки клиент может зарегистрировать a MessageListener объект с потребителем сообщения. Поскольку сообщения достигают потребителя сообщения, это поставляет им, вызывая MessageListener's onMessage метод.

Это - клиент, программирующий ошибку для a MessageListener выдавать исключение.

См. Также:

QueueReceiver, TopicSubscriber, Session

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

void	close() Закрывает потребителя сообщения.
MessageListener	getMessageListener() Получает потребителя сообщения MessageListener.
java.lang.String	getMessageSelector() Получает это потребительское выражение селектора сообщения сообщения.
Сообщение	receive() Получает следующее сообщение, произведенное для этого потребителя сообщения.
Сообщение	receive(long timeout) Получает следующее сообщение, которое прибывает в пределах указанного интервала тайм-аута.
Сообщение	receiveNoWait() Получает следующее сообщение, если Вы сразу доступны.
void	setMessageListener(MessageListener listener) Устанавливает потребителя сообщения MessageListener.

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

getMessageSelector

java.lang.String getMessageSelector()
                                    throws JMSException

Получает это потребительское выражение селектора сообщения сообщения.

Возвраты:

этот потребительский селектор сообщения сообщения, или нуль, если никакой селектор сообщения не существует для потребителя сообщения (то есть, если селектор сообщения не был установлен или был, устанавливают в NULL или пустая строка),

Броски:

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

getMessageListener

MessageListener getMessageListener()
                                   throws JMSException

Получает потребителя сообщения MessageListener.

Возвраты:

слушатель для потребителя сообщения, или нуль, если никакой слушатель не устанавливается

Броски:

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

См. Также:

setMessageListener(javax.jms.MessageListener)

setMessageListener

void setMessageListener(MessageListener listener)
                        throws JMSException

Устанавливает потребителя сообщения MessageListener.

Установка в NULL слушателя сообщения является эквивалентом сбрасывания слушателя сообщения для потребителя сообщения.

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

Параметры:

listener - слушатель, к которому должны быть переданы сообщения

Броски:

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

См. Также:

getMessageListener()

получить

Message receive()
                throws JMSException

Получает следующее сообщение, произведенное для этого потребителя сообщения.

Эти блоки вызова неопределенно до сообщения производятся или пока этот потребитель сообщения закрывается.

Если это receive делается в пределах транзакции, потребитель сохраняет сообщение до фиксаций транзакции.

Возвраты:

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

Броски:

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

получить

Message receive(long timeout)
                throws JMSException

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

Этот вызов блоки до сообщения прибывают, тайм-аут, истекает, или этот потребитель сообщения закрывается. A timeout из нуля никогда не истекает, и блоки вызова неопределенно.

Параметры:

timeout - значение тайм-аута (в миллисекундах)

Возвраты:

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

Броски:

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

receiveNoWait

Message receiveNoWait()
                      throws JMSException

Получает следующее сообщение, если Вы сразу доступны.

Возвраты:

следующее сообщение, произведенное для этого потребителя сообщения, или нуля, если Вы не доступны

Броски:

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

близко

void close()
           throws JMSException

Закрывает потребителя сообщения.

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

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

Броски:

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