A C D E F G H I L M N P R S T V W
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

A C D E F G H I L M N P R S T V W
All Classes All Packages