User: norbert
Date: 00/05/19 12:28:51
Modified: src/java/org/spyderMQ/distributed/server
DistributedJMSServerRMI.java
DistributedJMSServerRMIImpl.java
Log:
Here we are... There's a parser for selctors.
Revision Changes Path
1.12 +2 -1
spyderMQ/src/java/org/spyderMQ/distributed/server/DistributedJMSServerRMI.java
Index: DistributedJMSServerRMI.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spyderMQ/distributed/server/DistributedJMSServerRMI.java,v
retrieving revision 1.11
retrieving revision 1.12
diff -u -r1.11 -r1.12
--- DistributedJMSServerRMI.java 2000/05/16 03:31:02 1.11
+++ DistributedJMSServerRMI.java 2000/05/19 19:28:51 1.12
@@ -24,7 +24,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.11 $
+ * @version $Revision: 1.12 $
*/
public interface DistributedJMSServerRMI extends DistributedJMSServer, Remote
{
@@ -41,4 +41,5 @@
public void connectionClosing(SpyDistributedConnection dc) throws
JMSException, RemoteException;
public void deleteTemporaryDestination(SpyDestination dest) throws
JMSException, RemoteException;
public void checkID(String ID) throws JMSException, RemoteException;
+ public SpyMessage queueReceiveNoWait(Queue queue) throws Exception,
RemoteException;
}
1.14 +6 -1
spyderMQ/src/java/org/spyderMQ/distributed/server/DistributedJMSServerRMIImpl.java
Index: DistributedJMSServerRMIImpl.java
===================================================================
RCS file:
/products/cvs/ejboss/spyderMQ/src/java/org/spyderMQ/distributed/server/DistributedJMSServerRMIImpl.java,v
retrieving revision 1.13
retrieving revision 1.14
diff -u -r1.13 -r1.14
--- DistributedJMSServerRMIImpl.java 2000/05/18 00:16:12 1.13
+++ DistributedJMSServerRMIImpl.java 2000/05/19 19:28:51 1.14
@@ -24,7 +24,7 @@
*
* @author Norbert Lataille ([EMAIL PROTECTED])
*
- * @version $Revision: 1.13 $
+ * @version $Revision: 1.14 $
*/
public class DistributedJMSServerRMIImpl extends UnicastRemoteObject implements
DistributedJMSServerRMI
{
@@ -100,6 +100,11 @@
public void checkID(String ID) throws JMSException
{
server.checkID(ID);
+ }
+
+ public SpyMessage queueReceiveNoWait(Queue queue) throws JMSException
+ {
+ return server.queueReceiveNoWait(queue);
}
}