|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.logicblaze.lingo.jms.impl.OneWayRequestor
org.logicblaze.lingo.jms.impl.SingleThreadedRequestor
public class SingleThreadedRequestor
A simple Requestor
which can only be used by
one thread at once and only used for one message exchange at once.
Constructor Summary | |
---|---|
SingleThreadedRequestor(javax.jms.Connection connection,
javax.jms.Session session,
javax.jms.MessageProducer producer,
javax.jms.Destination serverDestination,
boolean ownsConnection)
|
|
SingleThreadedRequestor(javax.jms.Connection connection,
javax.jms.Session session,
javax.jms.MessageProducer producer,
javax.jms.Destination serverDestination,
javax.jms.Destination clientDestination,
boolean ownsConnection)
|
|
SingleThreadedRequestor(JmsProducerConfig config,
javax.jms.Destination serverDestination,
javax.jms.Destination clientDestination)
|
Method Summary | |
---|---|
void |
close()
Closes the Requestor and its session. |
protected static javax.jms.TemporaryQueue |
createTemporaryDestination(javax.jms.Session session)
|
javax.jms.Destination |
getInboundDestination()
|
protected javax.jms.MessageConsumer |
getReceiver()
|
boolean |
isDeleteTemporaryDestinationsOnClose()
|
protected void |
populateHeaders(javax.jms.Message message)
A hook to allow custom implementations to process headers differently. |
javax.jms.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 |
javax.jms.Message |
request(javax.jms.Destination destination,
javax.jms.Message message)
Sends a request and waits for a reply. |
javax.jms.Message |
request(javax.jms.Destination destination,
javax.jms.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 |
---|
public SingleThreadedRequestor(JmsProducerConfig config, javax.jms.Destination serverDestination, javax.jms.Destination clientDestination) throws javax.jms.JMSException
javax.jms.JMSException
public SingleThreadedRequestor(javax.jms.Connection connection, javax.jms.Session session, javax.jms.MessageProducer producer, javax.jms.Destination serverDestination, javax.jms.Destination clientDestination, boolean ownsConnection) throws javax.jms.JMSException
javax.jms.JMSException
public SingleThreadedRequestor(javax.jms.Connection connection, javax.jms.Session session, javax.jms.MessageProducer producer, javax.jms.Destination serverDestination, boolean ownsConnection) throws javax.jms.JMSException
javax.jms.JMSException
Method Detail |
---|
public javax.jms.Message request(javax.jms.Destination destination, javax.jms.Message message) throws javax.jms.JMSException
Requestor
JMSReplyTo
destination, and only one reply per request
is expected.
request
in interface Requestor
request
in class OneWayRequestor
destination
- the server side destinationmessage
- the message to send
javax.jms.JMSException
- if the JMS provider fails to complete the request due to some
internal error.public javax.jms.Message request(javax.jms.Destination destination, javax.jms.Message message, long timeout) throws javax.jms.JMSException
Requestor
JMSReplyTo
destination,
and only one reply per request is expected.
request
in interface Requestor
request
in class OneWayRequestor
destination
- the server side destinationmessage
- the message to send
javax.jms.JMSException
- if the JMS provider fails to complete the request due to some
internal error.public javax.jms.Message receive(long timeout) throws javax.jms.JMSException
Requestor
receive
in interface Requestor
receive
in class OneWayRequestor
javax.jms.JMSException
public void close() throws javax.jms.JMSException
Requestor
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.
close
in interface Requestor
close
in class OneWayRequestor
javax.jms.JMSException
- if the JMS provider fails to close the Requestor
due to some internal error.public boolean isDeleteTemporaryDestinationsOnClose()
public void setDeleteTemporaryDestinationsOnClose(boolean deleteTemporaryDestinationsOnClose)
protected static javax.jms.TemporaryQueue createTemporaryDestination(javax.jms.Session session) throws javax.jms.JMSException
javax.jms.JMSException
protected void populateHeaders(javax.jms.Message message) throws javax.jms.JMSException
OneWayRequestor
populateHeaders
in class OneWayRequestor
javax.jms.JMSException
protected javax.jms.MessageConsumer getReceiver() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.Destination getInboundDestination() throws javax.jms.JMSException
javax.jms.JMSException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |