Skip to content

Commit fa0720c

Browse files
pongadpongad
authored
Merge pull request #1598 from pongad/deprecate
move hand written pubsub code to deprecated namespace
2 parents 240e9f1 + 6ba75c1 commit fa0720c

50 files changed

Lines changed: 151 additions & 168 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/PubSubExample.java‎

Lines changed: 11 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -19,19 +19,18 @@
1919
import com.google.cloud.Identity;
2020
import com.google.cloud.Policy;
2121
import com.google.cloud.Role;
22-
import com.google.cloud.pubsub.Message;
23-
import com.google.cloud.pubsub.PubSub;
24-
import com.google.cloud.pubsub.PubSub.MessageProcessor;
25-
import com.google.cloud.pubsub.PubSubOptions;
26-
import com.google.cloud.pubsub.PushConfig;
27-
import com.google.cloud.pubsub.ReceivedMessage;
28-
import com.google.cloud.pubsub.Subscription;
29-
import com.google.cloud.pubsub.SubscriptionId;
30-
import com.google.cloud.pubsub.SubscriptionInfo;
31-
import com.google.cloud.pubsub.Topic;
32-
import com.google.cloud.pubsub.TopicInfo;
22+
import com.google.cloud.pubsub.deprecated.Message;
23+
import com.google.cloud.pubsub.deprecated.PubSub;
24+
import com.google.cloud.pubsub.deprecated.PubSub.MessageProcessor;
25+
import com.google.cloud.pubsub.deprecated.PubSubOptions;
26+
import com.google.cloud.pubsub.deprecated.PushConfig;
27+
import com.google.cloud.pubsub.deprecated.ReceivedMessage;
28+
import com.google.cloud.pubsub.deprecated.Subscription;
29+
import com.google.cloud.pubsub.deprecated.SubscriptionId;
30+
import com.google.cloud.pubsub.deprecated.SubscriptionInfo;
31+
import com.google.cloud.pubsub.deprecated.Topic;
32+
import com.google.cloud.pubsub.deprecated.TopicInfo;
3333
import com.google.common.collect.ImmutableMap;
34-
3534
import java.util.ArrayList;
3635
import java.util.Arrays;
3736
import java.util.HashMap;

‎google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/PubSubSnippets.java‎

Lines changed: 11 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -27,18 +27,17 @@
2727
import com.google.cloud.Page;
2828
import com.google.cloud.Policy;
2929
import com.google.cloud.Role;
30-
import com.google.cloud.pubsub.Message;
31-
import com.google.cloud.pubsub.PubSub;
32-
import com.google.cloud.pubsub.PubSub.ListOption;
33-
import com.google.cloud.pubsub.PubSub.MessageProcessor;
34-
import com.google.cloud.pubsub.PushConfig;
35-
import com.google.cloud.pubsub.ReceivedMessage;
36-
import com.google.cloud.pubsub.Subscription;
37-
import com.google.cloud.pubsub.SubscriptionId;
38-
import com.google.cloud.pubsub.SubscriptionInfo;
39-
import com.google.cloud.pubsub.Topic;
40-
import com.google.cloud.pubsub.TopicInfo;
41-
30+
import com.google.cloud.pubsub.deprecated.Message;
31+
import com.google.cloud.pubsub.deprecated.PubSub;
32+
import com.google.cloud.pubsub.deprecated.PubSub.ListOption;
33+
import com.google.cloud.pubsub.deprecated.PubSub.MessageProcessor;
34+
import com.google.cloud.pubsub.deprecated.PushConfig;
35+
import com.google.cloud.pubsub.deprecated.ReceivedMessage;
36+
import com.google.cloud.pubsub.deprecated.Subscription;
37+
import com.google.cloud.pubsub.deprecated.SubscriptionId;
38+
import com.google.cloud.pubsub.deprecated.SubscriptionInfo;
39+
import com.google.cloud.pubsub.deprecated.Topic;
40+
import com.google.cloud.pubsub.deprecated.TopicInfo;
4241
import java.util.Iterator;
4342
import java.util.LinkedList;
4443
import java.util.List;

‎google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/SubscriptionSnippets.java‎

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -25,13 +25,12 @@
2525
import com.google.cloud.Identity;
2626
import com.google.cloud.Policy;
2727
import com.google.cloud.Role;
28-
import com.google.cloud.pubsub.Message;
29-
import com.google.cloud.pubsub.PubSub.MessageConsumer;
30-
import com.google.cloud.pubsub.PubSub.MessageProcessor;
31-
import com.google.cloud.pubsub.PushConfig;
32-
import com.google.cloud.pubsub.ReceivedMessage;
33-
import com.google.cloud.pubsub.Subscription;
34-
28+
import com.google.cloud.pubsub.deprecated.Message;
29+
import com.google.cloud.pubsub.deprecated.PubSub.MessageConsumer;
30+
import com.google.cloud.pubsub.deprecated.PubSub.MessageProcessor;
31+
import com.google.cloud.pubsub.deprecated.PushConfig;
32+
import com.google.cloud.pubsub.deprecated.ReceivedMessage;
33+
import com.google.cloud.pubsub.deprecated.Subscription;
3534
import java.util.Iterator;
3635
import java.util.LinkedList;
3736
import java.util.List;

‎google-cloud-examples/src/main/java/com/google/cloud/examples/pubsub/snippets/TopicSnippets.java‎

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -27,11 +27,10 @@
2727
import com.google.cloud.Page;
2828
import com.google.cloud.Policy;
2929
import com.google.cloud.Role;
30-
import com.google.cloud.pubsub.Message;
31-
import com.google.cloud.pubsub.PubSub.ListOption;
32-
import com.google.cloud.pubsub.SubscriptionId;
33-
import com.google.cloud.pubsub.Topic;
34-
30+
import com.google.cloud.pubsub.deprecated.Message;
31+
import com.google.cloud.pubsub.deprecated.PubSub.ListOption;
32+
import com.google.cloud.pubsub.deprecated.SubscriptionId;
33+
import com.google.cloud.pubsub.deprecated.Topic;
3534
import java.util.Iterator;
3635
import java.util.LinkedList;
3736
import java.util.List;

‎google-cloud-examples/src/test/java/com/google/cloud/examples/pubsub/snippets/ITPubSubSnippets.java‎

Lines changed: 13 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -25,29 +25,27 @@
2525
import com.google.cloud.Page;
2626
import com.google.cloud.Policy;
2727
import com.google.cloud.Role;
28-
import com.google.cloud.pubsub.PubSub;
29-
import com.google.cloud.pubsub.PubSubOptions;
30-
import com.google.cloud.pubsub.ReceivedMessage;
31-
import com.google.cloud.pubsub.Subscription;
32-
import com.google.cloud.pubsub.SubscriptionId;
33-
import com.google.cloud.pubsub.SubscriptionInfo;
34-
import com.google.cloud.pubsub.Topic;
35-
import com.google.cloud.pubsub.TopicInfo;
28+
import com.google.cloud.pubsub.deprecated.PubSub;
29+
import com.google.cloud.pubsub.deprecated.PubSubOptions;
30+
import com.google.cloud.pubsub.deprecated.ReceivedMessage;
31+
import com.google.cloud.pubsub.deprecated.Subscription;
32+
import com.google.cloud.pubsub.deprecated.SubscriptionId;
33+
import com.google.cloud.pubsub.deprecated.SubscriptionInfo;
34+
import com.google.cloud.pubsub.deprecated.Topic;
35+
import com.google.cloud.pubsub.deprecated.TopicInfo;
3636
import com.google.common.collect.Iterators;
3737
import com.google.common.collect.Sets;
38-
39-
import org.junit.AfterClass;
40-
import org.junit.BeforeClass;
41-
import org.junit.Rule;
42-
import org.junit.Test;
43-
import org.junit.rules.Timeout;
44-
4538
import java.util.HashSet;
4639
import java.util.Iterator;
4740
import java.util.List;
4841
import java.util.Set;
4942
import java.util.UUID;
5043
import java.util.concurrent.ExecutionException;
44+
import org.junit.AfterClass;
45+
import org.junit.BeforeClass;
46+
import org.junit.Rule;
47+
import org.junit.Test;
48+
import org.junit.rules.Timeout;
5149

5250
public class ITPubSubSnippets {
5351

‎google-cloud-examples/src/test/java/com/google/cloud/examples/pubsub/snippets/ITSubscriptionSnippets.java‎

Lines changed: 11 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -25,22 +25,20 @@
2525
import com.google.cloud.Identity;
2626
import com.google.cloud.Policy;
2727
import com.google.cloud.Role;
28-
import com.google.cloud.pubsub.Message;
29-
import com.google.cloud.pubsub.PubSub;
30-
import com.google.cloud.pubsub.PubSubOptions;
31-
import com.google.cloud.pubsub.ReceivedMessage;
32-
import com.google.cloud.pubsub.Subscription;
33-
import com.google.cloud.pubsub.SubscriptionInfo;
34-
import com.google.cloud.pubsub.Topic;
35-
import com.google.cloud.pubsub.TopicInfo;
36-
37-
import org.junit.AfterClass;
38-
import org.junit.BeforeClass;
39-
import org.junit.Test;
40-
28+
import com.google.cloud.pubsub.deprecated.Message;
29+
import com.google.cloud.pubsub.deprecated.PubSub;
30+
import com.google.cloud.pubsub.deprecated.PubSubOptions;
31+
import com.google.cloud.pubsub.deprecated.ReceivedMessage;
32+
import com.google.cloud.pubsub.deprecated.Subscription;
33+
import com.google.cloud.pubsub.deprecated.SubscriptionInfo;
34+
import com.google.cloud.pubsub.deprecated.Topic;
35+
import com.google.cloud.pubsub.deprecated.TopicInfo;
4136
import java.util.Iterator;
4237
import java.util.UUID;
4338
import java.util.concurrent.ExecutionException;
39+
import org.junit.AfterClass;
40+
import org.junit.BeforeClass;
41+
import org.junit.Test;
4442

4543
public class ITSubscriptionSnippets {
4644

‎google-cloud-examples/src/test/java/com/google/cloud/examples/pubsub/snippets/ITTopicSnippets.java‎

Lines changed: 8 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -25,21 +25,19 @@
2525
import com.google.cloud.Page;
2626
import com.google.cloud.Policy;
2727
import com.google.cloud.Role;
28-
import com.google.cloud.pubsub.PubSub;
29-
import com.google.cloud.pubsub.PubSubOptions;
30-
import com.google.cloud.pubsub.SubscriptionId;
31-
import com.google.cloud.pubsub.SubscriptionInfo;
32-
import com.google.cloud.pubsub.Topic;
33-
import com.google.cloud.pubsub.TopicInfo;
28+
import com.google.cloud.pubsub.deprecated.PubSub;
29+
import com.google.cloud.pubsub.deprecated.PubSubOptions;
30+
import com.google.cloud.pubsub.deprecated.SubscriptionId;
31+
import com.google.cloud.pubsub.deprecated.SubscriptionInfo;
32+
import com.google.cloud.pubsub.deprecated.Topic;
33+
import com.google.cloud.pubsub.deprecated.TopicInfo;
3434
import com.google.common.collect.Iterators;
35-
35+
import java.util.UUID;
36+
import java.util.concurrent.ExecutionException;
3637
import org.junit.AfterClass;
3738
import org.junit.BeforeClass;
3839
import org.junit.Test;
3940

40-
import java.util.UUID;
41-
import java.util.concurrent.ExecutionException;
42-
4341
public class ITTopicSnippets {
4442

4543
private static final String TOPIC = "it-topic-snippets-topic-" + UUID.randomUUID().toString();

google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/AckDeadlineRenewer.java renamed to google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/deprecated/AckDeadlineRenewer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* limitations under the License.
1515
*/
1616

17-
package com.google.cloud.pubsub;
17+
package com.google.cloud.pubsub.deprecated;
1818

1919
import com.google.cloud.Clock;
2020
import com.google.cloud.GrpcServiceOptions.ExecutorFactory;

google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/Message.java renamed to google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/deprecated/Message.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* limitations under the License.
1515
*/
1616

17-
package com.google.cloud.pubsub;
17+
package com.google.cloud.pubsub.deprecated;
1818

1919
import static com.google.common.base.Preconditions.checkNotNull;
2020

google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/MessageConsumerImpl.java renamed to google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/deprecated/MessageConsumerImpl.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -14,13 +14,13 @@
1414
* limitations under the License.
1515
*/
1616

17-
package com.google.cloud.pubsub;
17+
package com.google.cloud.pubsub.deprecated;
1818

1919
import static com.google.common.base.MoreObjects.firstNonNull;
2020

2121
import com.google.cloud.GrpcServiceOptions.ExecutorFactory;
22-
import com.google.cloud.pubsub.PubSub.MessageConsumer;
23-
import com.google.cloud.pubsub.PubSub.MessageProcessor;
22+
import com.google.cloud.pubsub.deprecated.PubSub.MessageConsumer;
23+
import com.google.cloud.pubsub.deprecated.PubSub.MessageProcessor;
2424
import com.google.cloud.pubsub.spi.PubSubRpc;
2525
import com.google.cloud.pubsub.spi.PubSubRpc.PullCallback;
2626
import com.google.cloud.pubsub.spi.PubSubRpc.PullFuture;

0 commit comments

Comments
 (0)