services.moleculer.transporter

Class GoogleTransporter

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.transporter.Transporter

services.moleculer.transporter.GoogleTransporter

public class GoogleTransporter
extends Transporter

Google Cloud Pub/Sub Transporter. The Google Cloud Pub/Sub service allows applications to exchange messages reliably, quickly, and asynchronously. Usage:

 ServiceBroker broker = ServiceBroker.builder().nodeID("node1")
 .transporter(new GoogleTransporter("/credentials.json")).build();
 

Required dependency:

// https://mvnrepository.com/artifact/com.google.cloud/google-cloud-pubsub
compile group: 'com.google.cloud', name: 'google-cloud-pubsub', version: '1.96.0'

See Also:

TcpTransporter, RedisTransporter, NatsTransporter, MqttTransporter, JmsTransporter, KafkaTransporter, AmqpTransporter

Field Summary

Fields

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

Fields inherited from class services.moleculer.transporter.Transporter

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, usingJsonSerializer

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Constructor Summary

Constructors

Constructor and Description
GoogleTransporter()
GoogleTransporter(com.google.auth.Credentials credentials)
GoogleTransporter(java.lang.String credetialsURL)
GoogleTransporter(io.datatree.Tree credetials)

Method Summary

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)

Methods inherited from class services.moleculer.transporter.Transporter

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, updateNodeInfo

Methods inherited from class services.moleculer.service.MoleculerComponent

getBroker, getLogger, getName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

projectID

protected java.lang.String projectID

batchingSettings

protected com.google.api.gax.batching.BatchingSettings batchingSettings

channelProvider

protected com.google.api.gax.rpc.TransportChannelProvider channelProvider

credentialsProvider

protected com.google.api.gax.core.CredentialsProvider credentialsProvider

executorProvider

protected com.google.api.gax.core.ExecutorProvider executorProvider

headerProvider

protected com.google.api.gax.rpc.HeaderProvider headerProvider

retrySettings

protected com.google.api.gax.retrying.RetrySettings retrySettings

maxAckExtensionPeriod

protected org.threeten.bp.Duration maxAckExtensionPeriod

parallelPullCount

protected int parallelPullCount

ackDeadlineSeconds

protected int ackDeadlineSeconds

transportChannelProvider

protected com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider

flowControlSettings

protected com.google.api.gax.batching.FlowControlSettings flowControlSettings

clock

protected com.google.api.core.ApiClock clock

publishers

protected final java.util.HashMap<java.lang.String,com.google.cloud.pubsub.v1.Publisher> publishers

subscribers

protected final java.util.HashMap<java.lang.String,com.google.cloud.pubsub.v1.Subscriber> subscribers

topicAdmin

protected com.google.cloud.pubsub.v1.TopicAdminClient topicAdmin

subscriptionAdmin

protected com.google.cloud.pubsub.v1.SubscriptionAdminClient subscriptionAdmin

defaultExecutorProvider

protected com.google.api.gax.core.ExecutorProvider defaultExecutorProvider

connected

protected final java.util.concurrent.atomic.AtomicBoolean connected

Constructor Detail

GoogleTransporter

public GoogleTransporter()

GoogleTransporter

public GoogleTransporter(java.lang.String credetialsURL)
                  throws java.lang.Exception

Throws:

java.lang.Exception

GoogleTransporter

public GoogleTransporter(io.datatree.Tree credetials)
                  throws java.lang.Exception

Throws:

java.lang.Exception

GoogleTransporter

public GoogleTransporter(com.google.auth.Credentials credentials)

Method Detail

started

public void started(ServiceBroker broker)
             throws java.lang.Exception

Description copied from class: Transporter

Initializes transporter instance.

Overrides:

started in class Transporter

Parameters:

broker - parent ServiceBroker

Throws:

java.lang.Exception

connect

public void connect()

Specified by:

connect in class Transporter

disconnect

protected void disconnect()

reconnect

protected void reconnect(java.lang.Throwable cause)

error

protected void error(java.lang.Throwable cause)

Description copied from class: Transporter

Any I/O error occurred. Implementation-specific error handling goes here (reconnection, etc.).

Overrides:

error in class Transporter

Parameters:

cause - I/O error

stopped

public void stopped()

Closes transporter.

Overrides:

stopped in class Transporter

subscribe

public io.datatree.Promise subscribe(java.lang.String channel)

Specified by:

subscribe in class Transporter

publish

public void publish(java.lang.String channel,
                    io.datatree.Tree message)

Specified by:

publish in class Transporter

getOrCreatePublisher

protected com.google.cloud.pubsub.v1.Publisher getOrCreatePublisher(java.lang.String channel)
                                                             throws java.lang.Exception

Throws:

java.lang.Exception

getProjectID

public java.lang.String getProjectID()

setProjectID

public void setProjectID(java.lang.String projectID)

getBatchingSettings

public com.google.api.gax.batching.BatchingSettings getBatchingSettings()

setBatchingSettings

public void setBatchingSettings(com.google.api.gax.batching.BatchingSettings batchingSettings)

getChannelProvider

public com.google.api.gax.rpc.TransportChannelProvider getChannelProvider()

setChannelProvider

public void setChannelProvider(com.google.api.gax.rpc.TransportChannelProvider channelProvider)

getCredentialsProvider

public com.google.api.gax.core.CredentialsProvider getCredentialsProvider()

setCredentialsProvider

public void setCredentialsProvider(com.google.api.gax.core.CredentialsProvider credentialsProvider)

getExecutorProvider

public com.google.api.gax.core.ExecutorProvider getExecutorProvider()

setExecutorProvider

public void setExecutorProvider(com.google.api.gax.core.ExecutorProvider executorProvider)

getHeaderProvider

public com.google.api.gax.rpc.HeaderProvider getHeaderProvider()

setHeaderProvider

public void setHeaderProvider(com.google.api.gax.rpc.HeaderProvider headerProvider)

getRetrySettings

public com.google.api.gax.retrying.RetrySettings getRetrySettings()

setRetrySettings

public void setRetrySettings(com.google.api.gax.retrying.RetrySettings retrySettings)

getMaxAckExtensionPeriod

public org.threeten.bp.Duration getMaxAckExtensionPeriod()

setMaxAckExtensionPeriod

public void setMaxAckExtensionPeriod(org.threeten.bp.Duration maxAckExtensionPeriod)

getParallelPullCount

public int getParallelPullCount()

setParallelPullCount

public void setParallelPullCount(int parallelPullCount)

getAckDeadlineSeconds

public int getAckDeadlineSeconds()

setAckDeadlineSeconds

public void setAckDeadlineSeconds(int ackDeadlineSeconds)

getTransportChannelProvider

public com.google.api.gax.rpc.TransportChannelProvider getTransportChannelProvider()

setTransportChannelProvider

public void setTransportChannelProvider(com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider)

getFlowControlSettings

public com.google.api.gax.batching.FlowControlSettings getFlowControlSettings()

setFlowControlSettings

public void setFlowControlSettings(com.google.api.gax.batching.FlowControlSettings flowControlSettings)

getClock

public com.google.api.core.ApiClock getClock()

setClock

public void setClock(com.google.api.core.ApiClock clock)