org.logicblaze.lingo.jms.impl
Class SingleThreadedRequestor

java.lang.Object
  org.logicblaze.lingo.jms.impl.OneWayRequestor
      org.logicblaze.lingo.jms.impl.SingleThreadedRequestor

All Implemented Interfaces:

Requestor, org.springframework.beans.factory.DisposableBean

Direct Known Subclasses:

MultiplexingRequestor

public class SingleThreadedRequestor
extends OneWayRequestor

A simple Requestor which can only be used by one thread at once and only used for one message exchange at once.

Version:

$Revision: 1.8 $

Constructor Summary

SingleThreadedRequestor(Connection connection, Session session, MessageProducer producer, Destination serverDestination, boolean ownsConnection)

SingleThreadedRequestor(Connection connection, Session session, MessageProducer producer, Destination serverDestination, Destination clientDestination, boolean ownsConnection)

SingleThreadedRequestor(JmsProducerConfig config, Destination serverDestination, Destination clientDestination)

Method Summary

void	close() Closes the Requestor and its session.
protected static TemporaryQueue	createTemporaryDestination(Session session)
Destination	getInboundDestination()
protected MessageConsumer	getReceiver()
boolean	isDeleteTemporaryDestinationsOnClose()
protected void	populateHeaders(Message message) A hook to allow custom implementations to process headers differently.
Message	receive(long timeout) Receives a message waiting for a maximum timeout if the timeout value is > 0 ir waiting forever if the timeout is < 0 or not waiting at all if the timeout is zero
Message	request(Destination destination, Message message) Sends a request and waits for a reply.
Message	request(Destination destination, Message message, long timeout) Sends a request and waits for a reply up to a maximum timeout.
void	setDeleteTemporaryDestinationsOnClose(boolean deleteTemporaryDestinationsOnClose)

Methods inherited from class org.logicblaze.lingo.jms.impl.OneWayRequestor

createCorrelationID, destroy, doSend, doSend, getConnection, getDeliveryMode, getMessageProducer, getPriority, getSession, getTimeToLive, newInstance, nextCounter, request, send, send, send, setDeliveryMode, setPriority, setTimeToLive, validateDestination

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleThreadedRequestor

public SingleThreadedRequestor(JmsProducerConfig config,
                               Destination serverDestination,
                               Destination clientDestination)
                        throws JMSException

Throws:

JMSException

SingleThreadedRequestor

public SingleThreadedRequestor(Connection connection,
                               Session session,
                               MessageProducer producer,
                               Destination serverDestination,
                               Destination clientDestination,
                               boolean ownsConnection)
                        throws JMSException

Throws:

JMSException

SingleThreadedRequestor

public SingleThreadedRequestor(Connection connection,
                               Session session,
                               MessageProducer producer,
                               Destination serverDestination,
                               boolean ownsConnection)
                        throws JMSException

Throws:

JMSException

Method Detail

request

public Message request(Destination destination,
                       Message message)
                throws JMSException

Description copied from interface: Requestor

Sends a request and waits for a reply. The temporary queue is used for the JMSReplyTo destination, and only one reply per request is expected.

Specified by:

request in interface Requestor

Overrides:

request in class OneWayRequestor

Parameters:

destination - the server side destination

message - the message to send

Returns:

the reply message

Throws:

JMSException - if the JMS provider fails to complete the request due to some internal error.

request

public Message request(Destination destination,
                       Message message,
                       long timeout)
                throws JMSException

Description copied from interface: Requestor

Sends a request and waits for a reply up to a maximum timeout. The temporary queue is used for the JMSReplyTo destination, and only one reply per request is expected.

Specified by:

request in interface Requestor

Overrides:

request in class OneWayRequestor

Parameters:

destination - the server side destination

message - the message to send

Returns:

the reply message

Throws:

JMSException - if the JMS provider fails to complete the request due to some internal error.

receive

public Message receive(long timeout)
                throws JMSException

Description copied from interface: Requestor

Receives a message waiting for a maximum timeout if the timeout value is > 0 ir waiting forever if the timeout is < 0 or not waiting at all if the timeout is zero

Specified by:

receive in interface Requestor

Overrides:

receive in class OneWayRequestor

Throws:

JMSException

close

public void close()
           throws JMSException

Description copied from interface: Requestor

Closes the Requestor and its session.

Since a provider may allocate some resources on behalf of a Requestor outside the Java virtual machine, clients should close them when they are not needed. Relying on garbage collection to eventually reclaim these resources may not be timely enough.

Note that this method closes the Session object passed to the Requestor constructor.

Specified by:

close in interface Requestor

Overrides:

close in class OneWayRequestor

Throws:

JMSException - if the JMS provider fails to close the Requestor due to some internal error.

isDeleteTemporaryDestinationsOnClose

public boolean isDeleteTemporaryDestinationsOnClose()

setDeleteTemporaryDestinationsOnClose

public void setDeleteTemporaryDestinationsOnClose(boolean deleteTemporaryDestinationsOnClose)

createTemporaryDestination

protected static TemporaryQueue createTemporaryDestination(Session session)
                                                    throws JMSException

Throws:

JMSException

populateHeaders

protected void populateHeaders(Message message)
                        throws JMSException

Description copied from class: OneWayRequestor

A hook to allow custom implementations to process headers differently.

Overrides:

populateHeaders in class OneWayRequestor

Throws:

JMSException

getReceiver

protected MessageConsumer getReceiver()
                               throws JMSException

Throws:

JMSException

getInboundDestination

public Destination getInboundDestination()
                                  throws JMSException

Throws:

JMSException