Skip to content

Commit e508b2f

Browse files
committed
PulsarBinderIntegrationTests config upddate
Signed-off-by: Soby Chacko <soby.chacko@broadcom.com>
1 parent 1631fa1 commit e508b2f

1 file changed

Lines changed: 8 additions & 0 deletions

File tree

binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/test/java/org/springframework/cloud/stream/binder/pulsar/PulsarBinderIntegrationTests.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -59,6 +59,7 @@
5959
import org.springframework.pulsar.core.PulsarConsumerFactory;
6060
import org.springframework.pulsar.core.PulsarProducerFactory;
6161
import org.springframework.pulsar.core.SchemaResolver.SchemaResolverCustomizer;
62+
import org.springframework.pulsar.support.header.JsonPulsarHeaderMapper;
6263
import org.springframework.pulsar.support.header.PulsarHeaderMapper;
6364
import org.springframework.pulsar.support.header.ToStringPulsarHeaderMapper;
6465

@@ -520,6 +521,13 @@ static class CustomComplexHeadersConfig {
520521

521522
private int msgCount = 0;
522523

524+
@Bean
525+
public PulsarHeaderMapper pulsarHeaderMapper() {
526+
return JsonPulsarHeaderMapper.builder()
527+
.trustedPackages("org.springframework.cloud.stream.binder.pulsar")
528+
.build();
529+
}
530+
523531
@Bean
524532
public Supplier<Message<String>> springMessageSupplier() {
525533
return () -> {

0 commit comments

Comments
 (0)