org.apache.http.client.methods.HttpPost#getConfig()源码实例Demo

下面列出了org.apache.http.client.methods.HttpPost#getConfig() 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。

@Test
public void localSettingsOverrideClientDefaultSettings() throws Exception {
	RequestConfig defaultConfig = RequestConfig.custom()
			.setConnectTimeout(1234).setConnectionRequestTimeout(6789).build();
	CloseableHttpClient client = mock(CloseableHttpClient.class,
			withSettings().extraInterfaces(Configurable.class));
	Configurable configurable = (Configurable) client;
	given(configurable.getConfig()).willReturn(defaultConfig);

	HttpComponentsHttpInvokerRequestExecutor executor =
			new HttpComponentsHttpInvokerRequestExecutor(client);
	executor.setConnectTimeout(5000);

	HttpInvokerClientConfiguration config = mockHttpInvokerClientConfiguration("https://fake-service");
	HttpPost httpPost = executor.createHttpPost(config);
	RequestConfig requestConfig = httpPost.getConfig();
	assertEquals(5000, requestConfig.getConnectTimeout());
	assertEquals(6789, requestConfig.getConnectionRequestTimeout());
	assertEquals(-1, requestConfig.getSocketTimeout());
}
 
@Test
public void localSettingsOverrideClientDefaultSettings() throws Exception {
	RequestConfig defaultConfig = RequestConfig.custom()
			.setConnectTimeout(1234).setConnectionRequestTimeout(6789).build();
	CloseableHttpClient client = mock(CloseableHttpClient.class,
			withSettings().extraInterfaces(Configurable.class));
	Configurable configurable = (Configurable) client;
	when(configurable.getConfig()).thenReturn(defaultConfig);

	HttpComponentsHttpInvokerRequestExecutor executor =
			new HttpComponentsHttpInvokerRequestExecutor(client);
	executor.setConnectTimeout(5000);

	HttpInvokerClientConfiguration config = mockHttpInvokerClientConfiguration("http://fake-service");
	HttpPost httpPost = executor.createHttpPost(config);
	RequestConfig requestConfig = httpPost.getConfig();
	assertEquals(5000, requestConfig.getConnectTimeout());
	assertEquals(6789, requestConfig.getConnectionRequestTimeout());
	assertEquals(-1, requestConfig.getSocketTimeout());
}
 
@Test
public void localSettingsOverrideClientDefaultSettings() throws Exception {
	RequestConfig defaultConfig = RequestConfig.custom()
			.setConnectTimeout(1234).setConnectionRequestTimeout(6789).build();
	CloseableHttpClient client = mock(CloseableHttpClient.class,
			withSettings().extraInterfaces(Configurable.class));
	Configurable configurable = (Configurable) client;
	when(configurable.getConfig()).thenReturn(defaultConfig);

	HttpComponentsHttpInvokerRequestExecutor executor =
			new HttpComponentsHttpInvokerRequestExecutor(client);
	executor.setConnectTimeout(5000);

	HttpInvokerClientConfiguration config = mockHttpInvokerClientConfiguration("http://fake-service");
	HttpPost httpPost = executor.createHttpPost(config);
	RequestConfig requestConfig = httpPost.getConfig();
	assertEquals(5000, requestConfig.getConnectTimeout());
	assertEquals(6789, requestConfig.getConnectionRequestTimeout());
	assertEquals(-1, requestConfig.getSocketTimeout());
}
 
@Test
public void mergeBasedOnCurrentHttpClient() throws Exception {
	RequestConfig defaultConfig = RequestConfig.custom()
			.setSocketTimeout(1234).build();
	final CloseableHttpClient client = mock(CloseableHttpClient.class,
			withSettings().extraInterfaces(Configurable.class));
	Configurable configurable = (Configurable) client;
	given(configurable.getConfig()).willReturn(defaultConfig);

	HttpComponentsHttpInvokerRequestExecutor executor =
			new HttpComponentsHttpInvokerRequestExecutor() {
				@Override
				public HttpClient getHttpClient() {
					return client;
				}
			};
	executor.setReadTimeout(5000);
	HttpInvokerClientConfiguration config = mockHttpInvokerClientConfiguration("https://fake-service");
	HttpPost httpPost = executor.createHttpPost(config);
	RequestConfig requestConfig = httpPost.getConfig();
	assertEquals(-1, requestConfig.getConnectTimeout());
	assertEquals(-1, requestConfig.getConnectionRequestTimeout());
	assertEquals(5000, requestConfig.getSocketTimeout());

	// Update the Http client so that it returns an updated  config
	RequestConfig updatedDefaultConfig = RequestConfig.custom()
			.setConnectTimeout(1234).build();
	given(configurable.getConfig()).willReturn(updatedDefaultConfig);
	executor.setReadTimeout(7000);
	HttpPost httpPost2 = executor.createHttpPost(config);
	RequestConfig requestConfig2 = httpPost2.getConfig();
	assertEquals(1234, requestConfig2.getConnectTimeout());
	assertEquals(-1, requestConfig2.getConnectionRequestTimeout());
	assertEquals(7000, requestConfig2.getSocketTimeout());
}
 
@Test
public void mergeBasedOnCurrentHttpClient() throws Exception {
	RequestConfig defaultConfig = RequestConfig.custom()
			.setSocketTimeout(1234).build();
	final CloseableHttpClient client = mock(CloseableHttpClient.class,
			withSettings().extraInterfaces(Configurable.class));
	Configurable configurable = (Configurable) client;
	when(configurable.getConfig()).thenReturn(defaultConfig);

	HttpComponentsHttpInvokerRequestExecutor executor =
			new HttpComponentsHttpInvokerRequestExecutor() {
				@Override
				public HttpClient getHttpClient() {
					return client;
				}
			};
	executor.setReadTimeout(5000);
	HttpInvokerClientConfiguration config = mockHttpInvokerClientConfiguration("http://fake-service");
	HttpPost httpPost = executor.createHttpPost(config);
	RequestConfig requestConfig = httpPost.getConfig();
	assertEquals(-1, requestConfig.getConnectTimeout());
	assertEquals(-1, requestConfig.getConnectionRequestTimeout());
	assertEquals(5000, requestConfig.getSocketTimeout());

	// Update the Http client so that it returns an updated  config
	RequestConfig updatedDefaultConfig = RequestConfig.custom()
			.setConnectTimeout(1234).build();
	when(configurable.getConfig()).thenReturn(updatedDefaultConfig);
	executor.setReadTimeout(7000);
	HttpPost httpPost2 = executor.createHttpPost(config);
	RequestConfig requestConfig2 = httpPost2.getConfig();
	assertEquals(1234, requestConfig2.getConnectTimeout());
	assertEquals(-1, requestConfig2.getConnectionRequestTimeout());
	assertEquals(7000, requestConfig2.getSocketTimeout());
}
 
@Test
public void mergeBasedOnCurrentHttpClient() throws Exception {
	RequestConfig defaultConfig = RequestConfig.custom()
			.setSocketTimeout(1234).build();
	final CloseableHttpClient client = mock(CloseableHttpClient.class,
			withSettings().extraInterfaces(Configurable.class));
	Configurable configurable = (Configurable) client;
	when(configurable.getConfig()).thenReturn(defaultConfig);

	HttpComponentsHttpInvokerRequestExecutor executor =
			new HttpComponentsHttpInvokerRequestExecutor() {
				@Override
				public HttpClient getHttpClient() {
					return client;
				}
			};
	executor.setReadTimeout(5000);
	HttpInvokerClientConfiguration config = mockHttpInvokerClientConfiguration("http://fake-service");
	HttpPost httpPost = executor.createHttpPost(config);
	RequestConfig requestConfig = httpPost.getConfig();
	assertEquals(-1, requestConfig.getConnectTimeout());
	assertEquals(-1, requestConfig.getConnectionRequestTimeout());
	assertEquals(5000, requestConfig.getSocketTimeout());

	// Update the Http client so that it returns an updated  config
	RequestConfig updatedDefaultConfig = RequestConfig.custom()
			.setConnectTimeout(1234).build();
	when(configurable.getConfig()).thenReturn(updatedDefaultConfig);
	executor.setReadTimeout(7000);
	HttpPost httpPost2 = executor.createHttpPost(config);
	RequestConfig requestConfig2 = httpPost2.getConfig();
	assertEquals(1234, requestConfig2.getConnectTimeout());
	assertEquals(-1, requestConfig2.getConnectionRequestTimeout());
	assertEquals(7000, requestConfig2.getSocketTimeout());
}