You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@jackrabbit.apache.org by mr...@apache.org on 2007/02/13 10:27:52 UTC

svn commit: r506926 - /jackrabbit/trunk/contrib/spi/spi2dav/src/main/java/org/apache/jackrabbit/spi2dav/RepositoryServiceImpl.java

Author: mreutegg
Date: Tue Feb 13 01:27:51 2007
New Revision: 506926

URL: http://svn.apache.org/viewvc?view=rev&rev=506926
Log:
Use PollTimeout in RepositoryServiceImpl.

Modified:
    jackrabbit/trunk/contrib/spi/spi2dav/src/main/java/org/apache/jackrabbit/spi2dav/RepositoryServiceImpl.java

Modified: jackrabbit/trunk/contrib/spi/spi2dav/src/main/java/org/apache/jackrabbit/spi2dav/RepositoryServiceImpl.java
URL: http://svn.apache.org/viewvc/jackrabbit/trunk/contrib/spi/spi2dav/src/main/java/org/apache/jackrabbit/spi2dav/RepositoryServiceImpl.java?view=diff&rev=506926&r1=506925&r2=506926
==============================================================================
--- jackrabbit/trunk/contrib/spi/spi2dav/src/main/java/org/apache/jackrabbit/spi2dav/RepositoryServiceImpl.java (original)
+++ jackrabbit/trunk/contrib/spi/spi2dav/src/main/java/org/apache/jackrabbit/spi2dav/RepositoryServiceImpl.java Tue Feb 13 01:27:51 2007
@@ -1330,8 +1330,7 @@
         SessionInfoImpl sessionInfoImpl = (SessionInfoImpl)sessionInfo;
         String rootUri = uriResolver.getRootItemUri(sessionInfo.getWorkspaceName());
 
-        return poll(rootUri, sessionInfoImpl.getSubscriptionId(), sessionInfoImpl);
-        // todo timeout is not respected
+        return poll(rootUri, sessionInfoImpl.getSubscriptionId(), timeout, sessionInfoImpl);
     }
 
     private String subscribe(String uri, SubscriptionInfo subscriptionInfo,
@@ -1395,10 +1394,10 @@
         }
     }
 
-    private EventBundle[] poll(String uri, String subscriptionId,  SessionInfoImpl sessionInfo) throws RepositoryException {
+    private EventBundle[] poll(String uri, String subscriptionId, long timeout, SessionInfoImpl sessionInfo) throws RepositoryException {
         PollMethod method = null;
         try {
-            method = new PollMethod(uri, subscriptionId);
+            method = new PollMethod(uri, subscriptionId, timeout);
             getClient(sessionInfo).executeMethod(method);
             method.checkSuccess();