User: kimptoc
Date: 01/04/01 13:40:01
Modified: src/main/javax/jms QueueRequestor.java
Log:
sorted out queuerequestor too now
Revision Changes Path
1.2 +14 -4 jboss-j2ee/src/main/javax/jms/QueueRequestor.java
Index: QueueRequestor.java
===================================================================
RCS file: /cvsroot/jboss/jboss-j2ee/src/main/javax/jms/QueueRequestor.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- QueueRequestor.java 2001/04/01 19:34:02 1.1
+++ QueueRequestor.java 2001/04/01 20:40:01 1.2
@@ -10,7 +10,7 @@
/**
*
* @author Chris Kimpton ([EMAIL PROTECTED])
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
**/
public class QueueRequestor
{
@@ -21,24 +21,34 @@
{
_queueSession = session;
_queue = queue;
+
+ _requestSender = _queueSession.createSender(_queue);
+ _replyQueue = _queueSession.createTemporaryQueue();
+ _replyReceiver = _queueSession.createReceiver(_replyQueue);
}
// PUBLIC METHODS ------------------------------------------
public Message request(Message message) throws JMSException
{
- // FIXME
- return null;
+ message.setJMSReplyTo(_replyQueue);
+ message.setJMSDeliveryMode(DeliveryMode.NON_PERSISTENT);
+ _requestSender.send(message);
+ return _replyReceiver.receive();
}
public void close() throws JMSException
{
- // FIXME
+ _requestSender.close();
+ _replyReceiver.close();
}
// INSTANCE VARIABLES ----------------------------------------
private QueueSession _queueSession = null;
private Queue _queue = null;
+ private QueueSender _requestSender = null;
+ private QueueReceiver _replyReceiver = null;
+ private TemporaryQueue _replyQueue = null;
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
