Package ru.bitel.bgbilling.kernel.event

Class Producer

java.lang.Object

ru.bitel.bgbilling.kernel.event.MessageAdapter

ru.bitel.bgbilling.kernel.event.Producer

All Implemented Interfaces:

javax.jms.MessageListener

public final class Producer
extends MessageAdapter
implements javax.jms.MessageListener

Отсыльщик сообщения.

Field Summary

Fields

Modifier and Type	Field	Description
protected final boolean	autoAcknowledge
protected final int	deliveryMode
protected final int	priority
protected final javax.jms.TemporaryQueue	replyQueue
protected final long	timeToLive

Fields inherited from class ru.bitel.bgbilling.kernel.event.MessageAdapter

session

Constructor Summary

Constructors

Constructor	Description
Producer(javax.jms.Session session, ConcurrentMap<String,Object> requestMap, ConcurrentMap<String,javax.jms.Message> responseMap, Class<? extends ru.bitel.bgbilling.kernel.event.common.Event> clazz, String name, boolean topic)

Method Summary

Modifier and Type	Method	Description
void	close()
void	onMessage(javax.jms.Message message)
Object	request(String correlationId, javax.jms.Message message)
Object	request(String correlationId, javax.jms.Message message, long timeout)
<Q extends ru.bitel.bgbilling.kernel.event.common.Event> Future<Q>	requestAsync(String correlationId, javax.jms.Message message, long timeout)	Выполнение запроса асинхронно. Если ответ не пришел, обязательно должен быть обязательно вызван Future.cancel(boolean)!!!
void	send(javax.jms.Message message)
void	send(javax.jms.Message message, int priority, long timeToLive)
void	send(javax.jms.Message message, long timeToLive)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

replyQueue

protected final javax.jms.TemporaryQueue replyQueue

deliveryMode

protected final int deliveryMode

priority

protected final int priority

timeToLive

protected final long timeToLive

autoAcknowledge

protected final boolean autoAcknowledge

Constructor Details

Producer

public Producer(javax.jms.Session session,
 ConcurrentMap<String,Object> requestMap,
 ConcurrentMap<String,javax.jms.Message> responseMap,
 Class<? extends ru.bitel.bgbilling.kernel.event.common.Event> clazz,
 String name,
 boolean topic)
         throws javax.jms.JMSException,
jakarta.xml.bind.JAXBException

Throws:

javax.jms.JMSException

jakarta.xml.bind.JAXBException

Method Details

onMessage

public void onMessage(javax.jms.Message message)

Specified by:

onMessage in interface javax.jms.MessageListener

close

public void close()
           throws javax.jms.JMSException

Throws:

javax.jms.JMSException

send

public void send(javax.jms.Message message)
          throws javax.jms.JMSException

Throws:

javax.jms.JMSException

send

public void send(javax.jms.Message message,
 long timeToLive)
          throws javax.jms.JMSException

Throws:

javax.jms.JMSException

send

public void send(javax.jms.Message message,
 int priority,
 long timeToLive)
          throws javax.jms.JMSException

Throws:

javax.jms.JMSException

request

public Object request(String correlationId,
 javax.jms.Message message)
               throws javax.jms.JMSException,
InterruptedException,
jakarta.xml.bind.JAXBException,
EventProcessorException

Throws:

javax.jms.JMSException

InterruptedException

jakarta.xml.bind.JAXBException

EventProcessorException

request

public Object request(String correlationId,
 javax.jms.Message message,
 long timeout)
               throws javax.jms.JMSException,
jakarta.xml.bind.JAXBException,
InterruptedException,
EventProcessorException

Throws:

javax.jms.JMSException

jakarta.xml.bind.JAXBException

InterruptedException

EventProcessorException

requestAsync

public <Q extends ru.bitel.bgbilling.kernel.event.common.Event>
Future<Q> requestAsync(String correlationId,
 javax.jms.Message message,
 long timeout)
                throws javax.jms.JMSException,
jakarta.xml.bind.JAXBException,
InterruptedException,
EventProcessorException

Выполнение запроса асинхронно.
Если ответ не пришел, обязательно должен быть обязательно вызван Future.cancel(boolean)!!!

Type Parameters:

Q -

Parameters:

correlationId -

message -

timeout -

Returns:

Throws:

javax.jms.JMSException

jakarta.xml.bind.JAXBException

InterruptedException

EventProcessorException