Package | Description |
---|---|
org.springframework.cloud.gcp.stream.binder.pubsub |
Pub/Sub stream binder for Spring.
|
org.springframework.cloud.gcp.stream.binder.pubsub.properties |
Configuration properties of stream binder for Pub/Sub in Spring.
|
org.springframework.cloud.gcp.stream.binder.pubsub.provisioning |
Classes for provisioning and destinations of stream binder for Pub/Sub in Spring.
|
Modifier and Type | Method and Description |
---|---|
PubSubConsumerProperties |
PubSubMessageChannelBinder.getExtendedConsumerProperties(String channelName) |
Modifier and Type | Method and Description |
---|---|
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 String |
PubSubMessageChannelBinder.errorsBaseName(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
String group,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> properties) |
Modifier and Type | Method and Description |
---|---|
PubSubConsumerProperties |
PubSubBindingProperties.getConsumer() |
Modifier and Type | Method and Description |
---|---|
void |
PubSubBindingProperties.setConsumer(PubSubConsumerProperties consumer) |
Modifier and Type | Method and Description |
---|---|
org.springframework.cloud.stream.provisioning.ConsumerDestination |
PubSubChannelProvisioner.provisionConsumerDestination(String topicName,
String group,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> properties) |
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.