public class GoogleTransporter extends Transporter
ServiceBroker broker = ServiceBroker.builder().nodeID("node1")
.transporter(new GoogleTransporter("/credentials.json")).build();
Required dependency:| Modifier and Type | Field and Description |
|---|---|
protected int |
ackDeadlineSeconds |
protected com.google.api.gax.batching.BatchingSettings |
batchingSettings |
protected com.google.api.gax.rpc.TransportChannelProvider |
channelProvider |
protected com.google.api.core.ApiClock |
clock |
protected java.util.concurrent.atomic.AtomicBoolean |
connected |
protected com.google.api.gax.core.CredentialsProvider |
credentialsProvider |
protected com.google.api.gax.core.ExecutorProvider |
defaultExecutorProvider |
protected com.google.api.gax.core.ExecutorProvider |
executorProvider |
protected com.google.api.gax.batching.FlowControlSettings |
flowControlSettings |
protected com.google.api.gax.rpc.HeaderProvider |
headerProvider |
protected org.threeten.bp.Duration |
maxAckExtensionPeriod |
protected int |
parallelPullCount |
protected java.lang.String |
projectID |
protected java.util.HashMap<java.lang.String,com.google.cloud.pubsub.v1.Publisher> |
publishers |
protected com.google.api.gax.retrying.RetrySettings |
retrySettings |
protected java.util.HashMap<java.lang.String,com.google.cloud.pubsub.v1.Subscriber> |
subscribers |
protected com.google.cloud.pubsub.v1.SubscriptionAdminClient |
subscriptionAdmin |
protected com.google.cloud.pubsub.v1.TopicAdminClient |
topicAdmin |
protected com.google.api.gax.rpc.TransportChannelProvider |
transportChannelProvider |
checkTimeoutTimer, debug, debugHeartbeats, disconnectChannel, discoverBroadcastChannel, discoverChannel, eventbus, eventChannel, executor, heartbeatChannel, heartbeatInterval, heartbeatTimeout, heartBeatTimer, infoBroadcastChannel, infoChannel, infoScheduled, monitor, namespace, nodeID, nodes, offlineTimeout, PACKET_DISCONNECT, PACKET_DISCOVER, PACKET_EVENT, PACKET_HEARTBEAT, PACKET_INFO, PACKET_PING, PACKET_PONG, PACKET_REQUEST, PACKET_RESPONSE, pingChannel, pongChannel, preferHostname, prefix, registry, requestChannel, responseChannel, scheduler, serializer, serviceInvoker, subscriptionTimeout, uidGenerator, usingJsonSerializerbroker, logger, name| Constructor and Description |
|---|
GoogleTransporter() |
GoogleTransporter(com.google.auth.Credentials credentials) |
GoogleTransporter(java.lang.String credetialsURL) |
GoogleTransporter(io.datatree.Tree credetials) |
| Modifier and Type | Method and Description |
|---|---|
void |
connect() |
protected void |
disconnect() |
protected void |
error(java.lang.Throwable cause)
Any I/O error occurred.
|
int |
getAckDeadlineSeconds() |
com.google.api.gax.batching.BatchingSettings |
getBatchingSettings() |
com.google.api.gax.rpc.TransportChannelProvider |
getChannelProvider() |
com.google.api.core.ApiClock |
getClock() |
com.google.api.gax.core.CredentialsProvider |
getCredentialsProvider() |
com.google.api.gax.core.ExecutorProvider |
getExecutorProvider() |
com.google.api.gax.batching.FlowControlSettings |
getFlowControlSettings() |
com.google.api.gax.rpc.HeaderProvider |
getHeaderProvider() |
org.threeten.bp.Duration |
getMaxAckExtensionPeriod() |
protected com.google.cloud.pubsub.v1.Publisher |
getOrCreatePublisher(java.lang.String channel) |
int |
getParallelPullCount() |
java.lang.String |
getProjectID() |
com.google.api.gax.retrying.RetrySettings |
getRetrySettings() |
com.google.api.gax.rpc.TransportChannelProvider |
getTransportChannelProvider() |
void |
publish(java.lang.String channel,
io.datatree.Tree message) |
protected void |
reconnect(java.lang.Throwable cause) |
void |
setAckDeadlineSeconds(int ackDeadlineSeconds) |
void |
setBatchingSettings(com.google.api.gax.batching.BatchingSettings batchingSettings) |
void |
setChannelProvider(com.google.api.gax.rpc.TransportChannelProvider channelProvider) |
void |
setClock(com.google.api.core.ApiClock clock) |
void |
setCredentialsProvider(com.google.api.gax.core.CredentialsProvider credentialsProvider) |
void |
setExecutorProvider(com.google.api.gax.core.ExecutorProvider executorProvider) |
void |
setFlowControlSettings(com.google.api.gax.batching.FlowControlSettings flowControlSettings) |
void |
setHeaderProvider(com.google.api.gax.rpc.HeaderProvider headerProvider) |
void |
setMaxAckExtensionPeriod(org.threeten.bp.Duration maxAckExtensionPeriod) |
void |
setParallelPullCount(int parallelPullCount) |
void |
setProjectID(java.lang.String projectID) |
void |
setRetrySettings(com.google.api.gax.retrying.RetrySettings retrySettings) |
void |
setTransportChannelProvider(com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider) |
void |
started(ServiceBroker broker)
Initializes transporter instance.
|
void |
stopped()
Closes transporter.
|
io.datatree.Promise |
subscribe(java.lang.String channel) |
broadcastInfoPacket, broadcastNodeConnected, broadcastNodeDisconnected, broadcastNodeUpdated, channel, checkTimeouts, connected, connected, createPingPacket, getAddress, getAllNodeIDs, getCpuUsage, getDescriptor, getHeartbeatInterval, getHeartbeatTimeout, getLastHeartbeatTime, getNamespace, getOfflineTimeout, getPrefix, getSerializer, getSubscriptionTimeout, isDebug, isDebugHeartbeats, isOnline, isPreferHostname, processReceivedMessage, publish, received, sendClosePacket, sendDataPacket, sendDisconnectPacket, sendDiscoverPacket, sendErrorPacket, sendEventPacket, sendHeartbeatPacket, sendInfoPacket, sendPongPacket, sendRequestPacket, setDebug, setDebugHeartbeats, setHeartbeatInterval, setHeartbeatTimeout, setNamespace, setOfflineTimeout, setPreferHostname, setPrefix, setSerializer, setSubscriptionTimeout, subscribe, updateNodeInfogetBroker, getLogger, getNameprotected java.lang.String projectID
protected com.google.api.gax.batching.BatchingSettings batchingSettings
protected com.google.api.gax.rpc.TransportChannelProvider channelProvider
protected com.google.api.gax.core.CredentialsProvider credentialsProvider
protected com.google.api.gax.core.ExecutorProvider executorProvider
protected com.google.api.gax.rpc.HeaderProvider headerProvider
protected com.google.api.gax.retrying.RetrySettings retrySettings
protected org.threeten.bp.Duration maxAckExtensionPeriod
protected int parallelPullCount
protected int ackDeadlineSeconds
protected com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider
protected com.google.api.gax.batching.FlowControlSettings flowControlSettings
protected com.google.api.core.ApiClock clock
protected final java.util.HashMap<java.lang.String,com.google.cloud.pubsub.v1.Publisher> publishers
protected final java.util.HashMap<java.lang.String,com.google.cloud.pubsub.v1.Subscriber> subscribers
protected com.google.cloud.pubsub.v1.TopicAdminClient topicAdmin
protected com.google.cloud.pubsub.v1.SubscriptionAdminClient subscriptionAdmin
protected com.google.api.gax.core.ExecutorProvider defaultExecutorProvider
protected final java.util.concurrent.atomic.AtomicBoolean connected
public GoogleTransporter()
public GoogleTransporter(java.lang.String credetialsURL)
throws java.lang.Exception
java.lang.Exceptionpublic GoogleTransporter(io.datatree.Tree credetials)
throws java.lang.Exception
java.lang.Exceptionpublic GoogleTransporter(com.google.auth.Credentials credentials)
public void started(ServiceBroker broker) throws java.lang.Exception
Transporterstarted in class Transporterbroker - parent ServiceBrokerjava.lang.Exceptionpublic void connect()
connect in class Transporterprotected void disconnect()
protected void reconnect(java.lang.Throwable cause)
protected void error(java.lang.Throwable cause)
Transportererror in class Transportercause - I/O errorpublic void stopped()
stopped in class Transporterpublic io.datatree.Promise subscribe(java.lang.String channel)
subscribe in class Transporterpublic void publish(java.lang.String channel,
io.datatree.Tree message)
publish in class Transporterprotected com.google.cloud.pubsub.v1.Publisher getOrCreatePublisher(java.lang.String channel)
throws java.lang.Exception
java.lang.Exceptionpublic java.lang.String getProjectID()
public void setProjectID(java.lang.String projectID)
public com.google.api.gax.batching.BatchingSettings getBatchingSettings()
public void setBatchingSettings(com.google.api.gax.batching.BatchingSettings batchingSettings)
public com.google.api.gax.rpc.TransportChannelProvider getChannelProvider()
public void setChannelProvider(com.google.api.gax.rpc.TransportChannelProvider channelProvider)
public com.google.api.gax.core.CredentialsProvider getCredentialsProvider()
public void setCredentialsProvider(com.google.api.gax.core.CredentialsProvider credentialsProvider)
public com.google.api.gax.core.ExecutorProvider getExecutorProvider()
public void setExecutorProvider(com.google.api.gax.core.ExecutorProvider executorProvider)
public com.google.api.gax.rpc.HeaderProvider getHeaderProvider()
public void setHeaderProvider(com.google.api.gax.rpc.HeaderProvider headerProvider)
public com.google.api.gax.retrying.RetrySettings getRetrySettings()
public void setRetrySettings(com.google.api.gax.retrying.RetrySettings retrySettings)
public org.threeten.bp.Duration getMaxAckExtensionPeriod()
public void setMaxAckExtensionPeriod(org.threeten.bp.Duration maxAckExtensionPeriod)
public int getParallelPullCount()
public void setParallelPullCount(int parallelPullCount)
public int getAckDeadlineSeconds()
public void setAckDeadlineSeconds(int ackDeadlineSeconds)
public com.google.api.gax.rpc.TransportChannelProvider getTransportChannelProvider()
public void setTransportChannelProvider(com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider)
public com.google.api.gax.batching.FlowControlSettings getFlowControlSettings()
public void setFlowControlSettings(com.google.api.gax.batching.FlowControlSettings flowControlSettings)
public com.google.api.core.ApiClock getClock()
public void setClock(com.google.api.core.ApiClock clock)