honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

testSendMessage: log message request/response on failures 

Original commit: elastic/x-pack-elasticsearch@591284dced
This commit is contained in:
Boaz Leskes 2017-03-20 18:06:41 +01:00
parent 025461c3c8
commit e3d244164c
1 changed files with 17 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
plugin/src/test/java/org/elasticsearch/xpack/watcher/test/integration/SlackServiceTests.java
View File

@ -7,6 +7,8 @@ package org.elasticsearch.xpack.watcher.test.integration;
import org.elasticsearch.action.search.SearchResponse; import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.common.settings.Settings; import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentFactory;
import org.elasticsearch.test.junit.annotations.Network; import org.elasticsearch.test.junit.annotations.Network;
import org.elasticsearch.xpack.notification.slack.SentMessages; import org.elasticsearch.xpack.notification.slack.SentMessages;
import org.elasticsearch.xpack.notification.slack.SlackAccount; import org.elasticsearch.xpack.notification.slack.SlackAccount;
@ -19,6 +21,7 @@ import org.elasticsearch.xpack.watcher.test.AbstractWatcherIntegrationTestCase;
import org.elasticsearch.xpack.watcher.transport.actions.put.PutWatchResponse; import org.elasticsearch.xpack.watcher.transport.actions.put.PutWatchResponse;
import org.joda.time.DateTime; import org.joda.time.DateTime;
import static org.elasticsearch.common.xcontent.ToXContent.EMPTY_PARAMS;
import static org.elasticsearch.index.query.QueryBuilders.boolQuery; import static org.elasticsearch.index.query.QueryBuilders.boolQuery;
import static org.elasticsearch.index.query.QueryBuilders.termQuery; import static org.elasticsearch.index.query.QueryBuilders.termQuery;
import static org.elasticsearch.search.builder.SearchSourceBuilder.searchSource; import static org.elasticsearch.search.builder.SearchSourceBuilder.searchSource;
@ -69,10 +72,20 @@ public class SlackServiceTests extends AbstractWatcherIntegrationTestCase {
SentMessages messages = account.send(message, null); SentMessages messages = account.send(message, null);
assertThat(messages.count(), is(2)); assertThat(messages.count(), is(2));
for (SentMessages.SentMessage sentMessage : messages) { for (SentMessages.SentMessage sentMessage : messages) {
assertThat(sentMessage.successful(), is(true)); try {
assertThat(sentMessage.getRequest(), notNullValue()); assertThat(sentMessage.successful(), is(true));
assertThat(sentMessage.getResponse(), notNullValue()); assertThat(sentMessage.getRequest(), notNullValue());
assertThat(sentMessage.getResponse().status(), lessThan(300)); assertThat(sentMessage.getResponse(), notNullValue());
assertThat(sentMessage.getResponse().status(), lessThan(300));
} catch (AssertionError e) {
XContentBuilder builder = XContentFactory.jsonBuilder();
builder.prettyPrint();
sentMessage.toXContent(builder, EMPTY_PARAMS);
final String messageDescription = builder.string();
logger.warn("failed to send message. full message description: \n"
+ messageDescription, e);
throw e;
}
} }
} }