honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-06 21:18:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

increased logging

Browse Source 
Original commit: elastic/x-pack-elasticsearch@704c8d6132
This commit is contained in:
Martijn van Groningen 2015-04-24 23:07:38 +02:00
parent b0a16e36fd
commit 4530232060
2 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/main/java/org/elasticsearch/watcher/support/http/HttpClient.java
View File

@ -93,6 +93,7 @@ public class HttpClient extends AbstractComponent {
} }
} }
if (request.auth() != null) { if (request.auth() != null) {
logger.debug("applying auth headers");
request.auth().update(urlConnection); request.auth().update(urlConnection);
} }
urlConnection.setUseCaches(false); urlConnection.setUseCaches(false);

4
src/test/java/org/elasticsearch/watcher/test/integration/HttpInputIntegrationTest.java
View File

@ -11,6 +11,7 @@ import org.elasticsearch.common.settings.ImmutableSettings;
import org.elasticsearch.common.settings.Settings; import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.XContentBuilder; import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.node.internal.InternalNode; import org.elasticsearch.node.internal.InternalNode;
import org.elasticsearch.test.junit.annotations.TestLogging;
import org.elasticsearch.watcher.client.WatcherClient; import org.elasticsearch.watcher.client.WatcherClient;
import org.elasticsearch.watcher.history.HistoryStore; import org.elasticsearch.watcher.history.HistoryStore;
import org.elasticsearch.watcher.support.http.HttpRequestTemplate; import org.elasticsearch.watcher.support.http.HttpRequestTemplate;
@ -48,6 +49,7 @@ public class HttpInputIntegrationTest extends AbstractWatcherIntegrationTests {
} }
@Test @Test
@TestLogging("watcher.support.http:TRACE")
public void testHttpInput() throws Exception { public void testHttpInput() throws Exception {
createIndex("index"); createIndex("index");
client().prepareIndex("index", "type", "id").setSource("{}").setRefresh(true).get(); client().prepareIndex("index", "type", "id").setSource("{}").setRefresh(true).get();
@ -72,6 +74,7 @@ public class HttpInputIntegrationTest extends AbstractWatcherIntegrationTests {
} }
@Test @Test
@TestLogging("watcher.support.http:TRACE")
public void testHttpInput_clusterStats() throws Exception { public void testHttpInput_clusterStats() throws Exception {
InetSocketAddress address = internalTestCluster().httpAddresses()[0]; InetSocketAddress address = internalTestCluster().httpAddresses()[0];
watcherClient().preparePutWatch("_name") watcherClient().preparePutWatch("_name")
@ -92,6 +95,7 @@ public class HttpInputIntegrationTest extends AbstractWatcherIntegrationTests {
} }
@Test @Test
@TestLogging("watcher.support.http:TRACE")
public void testInputFiltering() throws Exception { public void testInputFiltering() throws Exception {
WatcherClient watcherClient = watcherClient(); WatcherClient watcherClient = watcherClient();
createIndex("idx"); createIndex("idx");