protected void |
PubSubMessageChannelBinder.afterUnbindConsumer(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
String group,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> consumerProperties) |
protected org.springframework.integration.core.MessageProducer |
PubSubMessageChannelBinder.createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
String group,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> properties) |
protected org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.PolledConsumerResources |
PubSubMessageChannelBinder.createPolledConsumerResources(String name,
String group,
org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> consumerProperties) |
protected PubSubMessageSource |
PubSubMessageChannelBinder.createPubSubMessageSource(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> consumerProperties) |
protected String |
PubSubMessageChannelBinder.errorsBaseName(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
String group,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> properties) |