SpringCloud/spring-cloud-consul
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix cast issue when sending an event.

Browse Source 
Fixes gh-458
Fixes gh-641
This commit is contained in:
plmaheu
2020-05-28 12:47:53 -04:00
committed by spencergibb
parent 4c4c897486
commit e5e1280c49
2 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-cloud-consul-binder/src/main/java/org/springframework/cloud/consul/binder/ConsulSendingHandler.java
View File

@@ -16,6 +16,8 @@
package org.springframework.cloud.consul.binder;
import java.util.Arrays;
import com.ecwid.consul.v1.ConsulClient;
import com.ecwid.consul.v1.QueryParams;
import com.ecwid.consul.v1.Response;
@@ -48,12 +50,16 @@ public class ConsulSendingHandler extends AbstractMessageHandler {
}
Object payload = message.getPayload();
if (payload instanceof byte[])
{
payload = Arrays.toString((byte[])payload);
}
// TODO: support headers
// TODO: support consul event filters: NodeFilter, ServiceFilter, TagFilter
Response<Event> event = this.consul.eventFire(this.eventName, (String) payload,
new EventParams(), QueryParams.DEFAULT);
// TODO: return event?
// return null;
}
}

3
spring-cloud-consul-binder/src/test/java/org/springframework/cloud/consul/binder/ConsulBinderApplicationTests.java
View File

@@ -21,7 +21,6 @@ import java.util.concurrent.TimeUnit;
import com.ecwid.consul.v1.ConsulClient;
import com.github.tomakehurst.wiremock.junit.WireMockRule;
import org.junit.Before;
import org.junit.Ignore;
import org.junit.Rule;
import org.junit.Test;
import org.junit.runner.RunWith;
@@ -78,14 +77,12 @@ public class ConsulBinderApplicationTests {
}
@Test
@Ignore // FIXME: 2.0.0 need stream fix
public void shouldInitializeConsulSource() {
assertThat(this.events).isNotNull();
}
@Test
@Ignore // FIXME: 2.0.0 need stream fix
public void shouldPublishTextConsulMessage() {
// given