diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindableProxyFactory.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindableProxyFactory.java index 1573f7b75..08aec34f3 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindableProxyFactory.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindableProxyFactory.java @@ -142,7 +142,7 @@ public class BindableProxyFactory extends AbstractBindableProxyFactory @Override public synchronized Object getObject() { - if (this.proxy == null) { + if (this.proxy == null && this.type != null) { ProxyFactory factory = new ProxyFactory(this.type, this); this.proxy = factory.getProxy(); }