Skip to content

Instantly share code, notes, and snippets.

View KasunDon's full-sized avatar

Kasun Don KasunDon

View GitHub Profile
@KasunDon
KasunDon / EmbededPubSub.java
Created July 12, 2018 10:18
EmbededPubSub for Java Integration Test
package com.kasundon.pubsub;
import com.google.api.gax.core.CredentialsProvider;
import com.google.api.gax.core.NoCredentialsProvider;
import com.google.api.gax.grpc.GrpcTransportChannel;
import com.google.api.gax.rpc.AlreadyExistsException;
import com.google.api.gax.rpc.FixedTransportChannelProvider;
import com.google.api.gax.rpc.TransportChannelProvider;
import com.google.cloud.pubsub.v1.MessageReceiver;
import com.google.cloud.pubsub.v1.Publisher;