Statistics
| Branch: | Revision:

root / extensions / httpnio / src / main / java / org / jclouds / http / httpnio / pool / NioHttpCommandConnectionHandle.java @ 35e7942d

History | View | Annotate | Download (1.7 kB)

1
/**
2
 *
3
 * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.com>
4
 *
5
 * ====================================================================
6
 * Licensed under the Apache License, Version 2.0 (the "License");
7
 * you may not use this file except in compliance with the License.
8
 * You may obtain a copy of the License at
9
 *
10
 * http://www.apache.org/licenses/LICENSE-2.0
11
 *
12
 * Unless required by applicable law or agreed to in writing, software
13
 * distributed under the License is distributed on an "AS IS" BASIS,
14
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15
 * See the License for the specific language governing permissions and
16
 * limitations under the License.
17
 * ====================================================================
18
 */
19
package org.jclouds.http.httpnio.pool;
20

    
21
import java.io.IOException;
22
import java.net.URI;
23
import java.util.concurrent.BlockingQueue;
24
import java.util.concurrent.Semaphore;
25

    
26
import org.apache.http.nio.NHttpConnection;
27
import org.jclouds.http.HttpCommandRendezvous;
28
import org.jclouds.http.pool.HttpCommandConnectionHandle;
29

    
30
/**
31
 * // TODO: Adrian: Document this!
32
 * 
33
 * @author Adrian Cole
34
 */
35
public class NioHttpCommandConnectionHandle extends HttpCommandConnectionHandle<NHttpConnection> {
36

    
37
   public NioHttpCommandConnectionHandle(Semaphore maxConnections,
38
            BlockingQueue<NHttpConnection> available, URI endPoint,
39
            HttpCommandRendezvous<?> command, NHttpConnection conn) throws InterruptedException {
40
      super(maxConnections, available, endPoint, command, conn);
41
   }
42

    
43
   public void startConnection() {
44
      conn.getContext().setAttribute("command", command);
45
      conn.requestOutput();
46
   }
47

    
48
   public void shutdownConnection() throws IOException {
49
      conn.shutdown();
50
   }
51

    
52
}