blob: 4f76fea8effc927594d1050e4c1ffd3b6fc52d8a (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
/*
*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*
*/
package org.apache.qpid.info.test;
import java.util.List;
import java.util.Properties;
import org.apache.qpid.info.util.HttpPoster;
import org.mortbay.jetty.testing.ServletTester;
import junit.framework.TestCase;
/*
* This test verifies that the plugin posts correctly to a webserver
* We use an embedded jetty container to mimic the webserver
*/
public class HttpPosterTest extends TestCase
{
private ServletTester tester;
private String baseURL;
private final String contextPath = "/info";
/*
* This method generates a dummy HttpPoster with a dummy body containing a
* single line. The url we are posting to can be controlled by the parameter
* url
*
* @param url
*/
private HttpPoster getHttpPoster(String url)
{
StringBuffer sb = new StringBuffer("test=TEST");
Properties props = new Properties();
props.put("http.url", url);
return new HttpPoster(props, sb);
}
/*
* (non-Javadoc)
*
* @see junit.framework.TestCase#setUp()
*/
protected void setUp() throws Exception
{
tester = new ServletTester();
tester.setContextPath("/");
tester.addServlet(InfoServlet.class, contextPath);
baseURL = tester.createSocketConnector(true);
tester.start();
}
/*
* (non-Javadoc)
*
* @see junit.framework.TestCase#tearDown()
*/
protected void tearDown() throws Exception
{
super.tearDown();
tester.stop();
}
/*
* This test is posting a string to an embedded Jetty Servlet and captures
* the response message. If the servlet receives the message ok, it will
* print Ok. A failure test is following where we post to a non-existent URL
*/
public void testHttpPoster() throws Exception
{
// Test HttpPoster posts correctly to the servlet
HttpPoster hp = getHttpPoster(baseURL + contextPath);
assertNotNull(hp);
hp.run();
List<String> response = hp.get_response();
assertTrue(response.size() > 0);
assertEquals("OK <br>", response.get(0).toString());
// Failure Test
hp = getHttpPoster("http://localhost/nonexistent");
hp.run();
response = hp.get_response();
assertTrue(response.size() == 0);
}
}
|
