A C D E F G H I L M N P R S T V W
All Classes All Packages
All Classes All Packages
All Classes All Packages
A
- ACK - com.adaptris.google.cloud.pubsub.ReplyProvider.AckReply
- AdminClientProvider - Class in com.adaptris.google.cloud.pubsub.adminclient
- AdminClientProvider() - Constructor for class com.adaptris.google.cloud.pubsub.adminclient.AdminClientProvider
- apply(Subscriber.Builder) - Method in class com.adaptris.google.cloud.pubsub.flowcontrol.CustomFlowControlProvider
- apply(Subscriber.Builder) - Method in class com.adaptris.google.cloud.pubsub.flowcontrol.DefaultFlowControlProvider
- apply(Subscriber.Builder) - Method in class com.adaptris.google.cloud.pubsub.flowcontrol.FlowControlProvider
C
- ChannelProvider - Class in com.adaptris.google.cloud.pubsub.channel
- ChannelProvider() - Constructor for class com.adaptris.google.cloud.pubsub.channel.ChannelProvider
- close() - Method in class com.adaptris.google.cloud.pubsub.adminclient.SubscriptionAdminClientProvider
- close() - Method in class com.adaptris.google.cloud.pubsub.adminclient.TopicAdminClientProvider
- close() - Method in class com.adaptris.google.cloud.pubsub.channel.ChannelProvider
- close() - Method in class com.adaptris.google.cloud.pubsub.credentials.CredentialsProvider
- close() - Method in class com.adaptris.google.cloud.pubsub.credentials.FixedCredentialsProvider
- close() - Method in class com.adaptris.google.cloud.pubsub.flowcontrol.FlowControlProvider
- close() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubConnectionErrorHandler
- close() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubProducer
- close() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubPullConsumer
- closeService() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubTransformService
- com.adaptris.google.cloud.pubsub - package com.adaptris.google.cloud.pubsub
- com.adaptris.google.cloud.pubsub.adminclient - package com.adaptris.google.cloud.pubsub.adminclient
- com.adaptris.google.cloud.pubsub.channel - package com.adaptris.google.cloud.pubsub.channel
- com.adaptris.google.cloud.pubsub.credentials - package com.adaptris.google.cloud.pubsub.credentials
- com.adaptris.google.cloud.pubsub.flowcontrol - package com.adaptris.google.cloud.pubsub.flowcontrol
- ConfiguredReplyProvider - Class in com.adaptris.google.cloud.pubsub
- ConfiguredReplyProvider() - Constructor for class com.adaptris.google.cloud.pubsub.ConfiguredReplyProvider
- ConfiguredReplyProvider(ReplyProvider.AckReply) - Constructor for class com.adaptris.google.cloud.pubsub.ConfiguredReplyProvider
- ConsumeConfig - Class in com.adaptris.google.cloud.pubsub
- ConsumeConfig() - Constructor for class com.adaptris.google.cloud.pubsub.ConsumeConfig
- createSubscriber(ProjectSubscriptionName, MessageReceiver) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubConnection
- createSubscription(ConsumeConfig) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubConnection
- CredentialsProvider - Class in com.adaptris.google.cloud.pubsub.credentials
- CredentialsProvider() - Constructor for class com.adaptris.google.cloud.pubsub.credentials.CredentialsProvider
- CustomChannelProvider - Class in com.adaptris.google.cloud.pubsub.channel
- CustomChannelProvider() - Constructor for class com.adaptris.google.cloud.pubsub.channel.CustomChannelProvider
- CustomChannelProvider(String) - Constructor for class com.adaptris.google.cloud.pubsub.channel.CustomChannelProvider
- CustomChannelProvider(String, Boolean) - Constructor for class com.adaptris.google.cloud.pubsub.channel.CustomChannelProvider
- CustomFlowControlProvider - Class in com.adaptris.google.cloud.pubsub.flowcontrol
- CustomFlowControlProvider() - Constructor for class com.adaptris.google.cloud.pubsub.flowcontrol.CustomFlowControlProvider
D
- DEFAULT_MAX_ENTRIES - Static variable in class com.adaptris.google.cloud.pubsub.PublisherMap
- DefaultChannelProvider - Class in com.adaptris.google.cloud.pubsub.channel
- DefaultChannelProvider() - Constructor for class com.adaptris.google.cloud.pubsub.channel.DefaultChannelProvider
- DefaultFlowControlProvider - Class in com.adaptris.google.cloud.pubsub.flowcontrol
- DefaultFlowControlProvider() - Constructor for class com.adaptris.google.cloud.pubsub.flowcontrol.DefaultFlowControlProvider
- DefaultGoogleCloudPubSubTransformationDriver - Class in com.adaptris.google.cloud.pubsub
- DefaultGoogleCloudPubSubTransformationDriver() - Constructor for class com.adaptris.google.cloud.pubsub.DefaultGoogleCloudPubSubTransformationDriver
- deleteSubscription(ConsumeConfig) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubConnection
- doProduce(AdaptrisMessage, String) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubProducer
- doProduce(AdaptrisMessage, String) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubResponseProducer
- doService(AdaptrisMessage) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubTransformService
E
- endpoint(AdaptrisMessage) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubProducer
- endpoint(AdaptrisMessage) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubResponseProducer
- execute(AckReplyConsumer) - Method in enum com.adaptris.google.cloud.pubsub.ReplyProvider.AckReply
F
- FixedCredentialsProvider - Class in com.adaptris.google.cloud.pubsub.credentials
- FixedCredentialsProvider() - Constructor for class com.adaptris.google.cloud.pubsub.credentials.FixedCredentialsProvider
- FixedCredentialsProvider(Credentials) - Constructor for class com.adaptris.google.cloud.pubsub.credentials.FixedCredentialsProvider
- FlowControlProvider - Class in com.adaptris.google.cloud.pubsub.flowcontrol
- FlowControlProvider() - Constructor for class com.adaptris.google.cloud.pubsub.flowcontrol.FlowControlProvider
G
- getAckDeadline() - Method in class com.adaptris.google.cloud.pubsub.ConsumeConfig
- getAckDeadlineSeconds() - Method in class com.adaptris.google.cloud.pubsub.ConsumeConfig
- getAckReply(AdaptrisMessage) - Method in class com.adaptris.google.cloud.pubsub.ConfiguredReplyProvider
- getAckReply(AdaptrisMessage) - Method in class com.adaptris.google.cloud.pubsub.MetadataReplyProvider
- getAckReply(AdaptrisMessage) - Method in interface com.adaptris.google.cloud.pubsub.ReplyProvider
- getAddress() - Method in class com.adaptris.google.cloud.pubsub.channel.CustomChannelProvider
- getAutoAcknowledge() - Method in class com.adaptris.google.cloud.pubsub.ConsumeConfig
- getChannelProvider() - Method in class com.adaptris.google.cloud.pubsub.adminclient.AdminClientProvider
- getChannelProvider() - Method in class com.adaptris.google.cloud.pubsub.channel.ChannelProvider
- getCreateSubscription() - Method in class com.adaptris.google.cloud.pubsub.ConsumeConfig
- getCreateTopic() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubProducer
- getCredentials() - Method in class com.adaptris.google.cloud.pubsub.credentials.FixedCredentialsProvider
- getCredentialsProvider() - Method in class com.adaptris.google.cloud.pubsub.adminclient.AdminClientProvider
- getCredentialsProvider() - Method in class com.adaptris.google.cloud.pubsub.credentials.CredentialsProvider
- getDefaultReply() - Method in class com.adaptris.google.cloud.pubsub.MetadataReplyProvider
- getDirection() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubTransformService
- getDriver() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubTransformService
- getLimitExceededBehavior() - Method in class com.adaptris.google.cloud.pubsub.flowcontrol.CustomFlowControlProvider
- getMaxEntries() - Method in class com.adaptris.google.cloud.pubsub.PublisherMap
- getMaxOutstandingElementCount() - Method in class com.adaptris.google.cloud.pubsub.flowcontrol.CustomFlowControlProvider
- getMaxOutstandingRequestBytes() - Method in class com.adaptris.google.cloud.pubsub.flowcontrol.CustomFlowControlProvider
- getMetadataFilter() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubProducer
- getMetadataFilter() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubTransformService
- getMetadataKey() - Method in class com.adaptris.google.cloud.pubsub.MetadataReplyProvider
- getProjectName() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubConnection
- getPublisherCacheLimit() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubProducer
- getReply() - Method in class com.adaptris.google.cloud.pubsub.ConfiguredReplyProvider
- getReplyProvider() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubResponseProducer
- getSubscriptionAdminClient() - Method in class com.adaptris.google.cloud.pubsub.adminclient.SubscriptionAdminClientProvider
- getSubscriptionName() - Method in class com.adaptris.google.cloud.pubsub.ConsumeConfig
- getTopic() - Method in class com.adaptris.google.cloud.pubsub.ConsumeConfig
-
The pubsub topic name.
- getTopic() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubProducer
-
The pubsub topic
- getTopicAdminClient() - Method in class com.adaptris.google.cloud.pubsub.adminclient.TopicAdminClientProvider
- getTopicName() - Method in class com.adaptris.google.cloud.pubsub.ConsumeConfig
- getUsePlaintext() - Method in class com.adaptris.google.cloud.pubsub.channel.CustomChannelProvider
- GoogleCloudPubSubConnection - Class in com.adaptris.google.cloud.pubsub
- GoogleCloudPubSubConnection() - Constructor for class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubConnection
- GoogleCloudPubSubConnection(ChannelProvider) - Constructor for class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubConnection
- GoogleCloudPubSubConnection(ChannelProvider, CredentialsProvider) - Constructor for class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubConnection
- GoogleCloudPubSubConnectionErrorHandler - Class in com.adaptris.google.cloud.pubsub
- GoogleCloudPubSubConnectionErrorHandler() - Constructor for class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubConnectionErrorHandler
- GoogleCloudPubSubProducer - Class in com.adaptris.google.cloud.pubsub
- GoogleCloudPubSubProducer() - Constructor for class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubProducer
- GoogleCloudPubSubPullConsumer - Class in com.adaptris.google.cloud.pubsub
- GoogleCloudPubSubPullConsumer() - Constructor for class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubPullConsumer
- GoogleCloudPubSubResponseProducer - Class in com.adaptris.google.cloud.pubsub
- GoogleCloudPubSubResponseProducer() - Constructor for class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubResponseProducer
- GoogleCloudPubSubResponseProducer(ReplyProvider.AckReply) - Constructor for class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubResponseProducer
- GoogleCloudPubSubTransformService - Class in com.adaptris.google.cloud.pubsub
- GoogleCloudPubSubTransformService() - Constructor for class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubTransformService
- GoogleCloudPubSubTransformService(TransformationDirection) - Constructor for class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubTransformService
- GoogleCloudPubSubTransformService(TransformationDirection, TransformationDriver) - Constructor for class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubTransformService
H
- handleConnectionException() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubConnectionErrorHandler
I
- init() - Method in class com.adaptris.google.cloud.pubsub.adminclient.SubscriptionAdminClientProvider
- init() - Method in class com.adaptris.google.cloud.pubsub.adminclient.TopicAdminClientProvider
- init() - Method in class com.adaptris.google.cloud.pubsub.channel.ChannelProvider
- init() - Method in class com.adaptris.google.cloud.pubsub.credentials.CredentialsProvider
- init() - Method in class com.adaptris.google.cloud.pubsub.credentials.FixedCredentialsProvider
- init() - Method in class com.adaptris.google.cloud.pubsub.flowcontrol.CustomFlowControlProvider
- init() - Method in class com.adaptris.google.cloud.pubsub.flowcontrol.FlowControlProvider
- init() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubConnectionErrorHandler
- init() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubProducer
- init() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubPullConsumer
- initService() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubTransformService
- INTERLOK_TO_PUBLISH_REQUEST - com.adaptris.google.cloud.pubsub.TransformationDirection
-
Interlok Message to Publish Request
L
- log - Variable in class com.adaptris.google.cloud.pubsub.adminclient.AdminClientProvider
- log - Variable in class com.adaptris.google.cloud.pubsub.PublisherMap
M
- MetadataReplyProvider - Class in com.adaptris.google.cloud.pubsub
- MetadataReplyProvider() - Constructor for class com.adaptris.google.cloud.pubsub.MetadataReplyProvider
- MetadataReplyProvider(String) - Constructor for class com.adaptris.google.cloud.pubsub.MetadataReplyProvider
- MetadataReplyProvider(String, ReplyProvider.AckReply) - Constructor for class com.adaptris.google.cloud.pubsub.MetadataReplyProvider
N
- NACK - com.adaptris.google.cloud.pubsub.ReplyProvider.AckReply
- newThreadName() - Method in class com.adaptris.google.cloud.pubsub.ConsumeConfig
- NoCredentialsProvider - Class in com.adaptris.google.cloud.pubsub.credentials
- NoCredentialsProvider() - Constructor for class com.adaptris.google.cloud.pubsub.credentials.NoCredentialsProvider
P
- prepare() - Method in class com.adaptris.google.cloud.pubsub.ConsumeConfig
- prepare() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubProducer
- prepare() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubResponseProducer
- prepare() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubTransformService
- prepareConnection() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubConnection
- PublisherMap - Class in com.adaptris.google.cloud.pubsub
- PublisherMap() - Constructor for class com.adaptris.google.cloud.pubsub.PublisherMap
- PublisherMap(int) - Constructor for class com.adaptris.google.cloud.pubsub.PublisherMap
- PULL_RESPONSE_TO_INTERLOK - com.adaptris.google.cloud.pubsub.TransformationDirection
-
Pull Response to Interlok Message
- PUSH_RESPONSE_TO_INTERLOK - com.adaptris.google.cloud.pubsub.TransformationDirection
-
Push Response to Interlok Message
R
- receiveMessage(PubsubMessage, AckReplyConsumer) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubPullConsumer
- removeEldestEntry(Map.Entry<String, Publisher>) - Method in class com.adaptris.google.cloud.pubsub.PublisherMap
- ReplyProvider - Interface in com.adaptris.google.cloud.pubsub
- ReplyProvider.AckReply - Enum in com.adaptris.google.cloud.pubsub
S
- setAckDeadline(TimeInterval) - Method in class com.adaptris.google.cloud.pubsub.ConsumeConfig
- setAddress(String) - Method in class com.adaptris.google.cloud.pubsub.channel.CustomChannelProvider
- setAutoAcknowledge(Boolean) - Method in class com.adaptris.google.cloud.pubsub.ConsumeConfig
- setChannelProvider(TransportChannelProvider) - Method in class com.adaptris.google.cloud.pubsub.adminclient.AdminClientProvider
- setCreateSubscription(Boolean) - Method in class com.adaptris.google.cloud.pubsub.ConsumeConfig
- setCreateTopic(Boolean) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubProducer
- setCredentials(Credentials) - Method in class com.adaptris.google.cloud.pubsub.credentials.FixedCredentialsProvider
- setCredentialsProvider(CredentialsProvider) - Method in class com.adaptris.google.cloud.pubsub.adminclient.AdminClientProvider
- setDefaultReply(ReplyProvider.AckReply) - Method in class com.adaptris.google.cloud.pubsub.MetadataReplyProvider
- setDirection(TransformationDirection) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubTransformService
- setDriver(TransformationDriver) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubTransformService
- setLimitExceededBehavior(FlowController.LimitExceededBehavior) - Method in class com.adaptris.google.cloud.pubsub.flowcontrol.CustomFlowControlProvider
- setMaxOutstandingElementCount(Long) - Method in class com.adaptris.google.cloud.pubsub.flowcontrol.CustomFlowControlProvider
- setMaxOutstandingRequestBytes(Long) - Method in class com.adaptris.google.cloud.pubsub.flowcontrol.CustomFlowControlProvider
- setMetadataFilter(MetadataFilter) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubProducer
- setMetadataFilter(MetadataFilter) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubTransformService
- setMetadataKey(String) - Method in class com.adaptris.google.cloud.pubsub.MetadataReplyProvider
- setProjectName(String) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubConnection
- setPublisherCacheLimit(Integer) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubProducer
- setReply(ReplyProvider.AckReply) - Method in class com.adaptris.google.cloud.pubsub.ConfiguredReplyProvider
- setReplyProvider(ReplyProvider) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubResponseProducer
- setSubscriptionName(String) - Method in class com.adaptris.google.cloud.pubsub.ConsumeConfig
- setTopic(String) - Method in class com.adaptris.google.cloud.pubsub.ConsumeConfig
-
The pubsub topic name.
- setTopic(String) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubProducer
-
The pubsub topic
- setUsePlaintext(Boolean) - Method in class com.adaptris.google.cloud.pubsub.channel.CustomChannelProvider
- start() - Method in class com.adaptris.google.cloud.pubsub.adminclient.AdminClientProvider
- start() - Method in class com.adaptris.google.cloud.pubsub.channel.ChannelProvider
- start() - Method in class com.adaptris.google.cloud.pubsub.credentials.CredentialsProvider
- start() - Method in class com.adaptris.google.cloud.pubsub.credentials.FixedCredentialsProvider
- start() - Method in class com.adaptris.google.cloud.pubsub.flowcontrol.FlowControlProvider
- start() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubConnectionErrorHandler
- start() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubPullConsumer
- stop() - Method in class com.adaptris.google.cloud.pubsub.adminclient.AdminClientProvider
- stop() - Method in class com.adaptris.google.cloud.pubsub.channel.ChannelProvider
- stop() - Method in class com.adaptris.google.cloud.pubsub.credentials.CredentialsProvider
- stop() - Method in class com.adaptris.google.cloud.pubsub.credentials.FixedCredentialsProvider
- stop() - Method in class com.adaptris.google.cloud.pubsub.flowcontrol.FlowControlProvider
- stop() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubConnectionErrorHandler
- stop() - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubPullConsumer
- SubscriptionAdminClientProvider - Class in com.adaptris.google.cloud.pubsub.adminclient
- SubscriptionAdminClientProvider() - Constructor for class com.adaptris.google.cloud.pubsub.adminclient.SubscriptionAdminClientProvider
T
- TopicAdminClientProvider - Class in com.adaptris.google.cloud.pubsub.adminclient
- TopicAdminClientProvider() - Constructor for class com.adaptris.google.cloud.pubsub.adminclient.TopicAdminClientProvider
- transform(AdaptrisMessage, MetadataFilter) - Method in enum com.adaptris.google.cloud.pubsub.TransformationDirection
- transform(AdaptrisMessage, TransformationDirection, MetadataFilter) - Method in class com.adaptris.google.cloud.pubsub.DefaultGoogleCloudPubSubTransformationDriver
- transform(AdaptrisMessage, TransformationDirection, MetadataFilter) - Method in interface com.adaptris.google.cloud.pubsub.TransformationDriver
-
Perform transformation.
- TransformationDirection - Enum in com.adaptris.google.cloud.pubsub
-
Direction enum; Google Cloud Pub/Sub JSON <-> Interlok Messsage.
- TransformationDriver - Interface in com.adaptris.google.cloud.pubsub
-
Transformation driver.
V
- valueOf(String) - Static method in enum com.adaptris.google.cloud.pubsub.ReplyProvider.AckReply
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.adaptris.google.cloud.pubsub.TransformationDirection
-
Returns the enum constant of this type with the specified name.
- valueOf(String, ReplyProvider.AckReply) - Static method in enum com.adaptris.google.cloud.pubsub.ReplyProvider.AckReply
- values() - Static method in enum com.adaptris.google.cloud.pubsub.ReplyProvider.AckReply
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum com.adaptris.google.cloud.pubsub.TransformationDirection
-
Returns an array containing the constants of this enum type, in the order they are declared.
W
- withTopic(String) - Method in class com.adaptris.google.cloud.pubsub.GoogleCloudPubSubProducer
All Classes All Packages