Skip to content

Commit

Permalink
feat: implement getNotification inside StorageRpcTestBase class and f…
Browse files Browse the repository at this point in the history
…ix the builds checks
  • Loading branch information
athakor committed Jun 18, 2020
1 parent 1947152 commit 300c604
Show file tree
Hide file tree
Showing 4 changed files with 18 additions and 3 deletions.
Expand Up @@ -280,6 +280,11 @@ public Notification createNotification(String bucket, Notification notification)
throw new UnsupportedOperationException("Not implemented yet");
}

@Override
public Notification getNotification(String bucket, String notification) {
throw new UnsupportedOperationException("Not implemented yet");
}

@Override
public Bucket lockRetentionPolicy(Bucket bucket, Map<Option, ?> options) {
throw new UnsupportedOperationException("Not implemented yet");
Expand Down
Expand Up @@ -57,7 +57,6 @@
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.Iterables;
import com.google.common.io.BaseEncoding;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.MalformedURLException;
Expand Down Expand Up @@ -2558,6 +2557,6 @@ private void compareBucketsNotification(Notification value) {
assertEquals(EVENT_TYPES, value.getEventTypes());
assertEquals(OBJECT_NAME_PREFIX, value.getObjectNamePrefix());
assertEquals(PAYLOAD_FORMAT.name(), value.getPayloadFormat());
assertEquals(TOPIC.toString(), value.getTopic());
assertEquals(TOPIC, value.getTopic());
}
}
Expand Up @@ -577,6 +577,17 @@ public Notification call() {
};
}

@Test
public void testGetNotification() {
rpc =
new Callable<Notification>() {
@Override
public Notification call() {
return STORAGE_RPC.getNotification("bucket", "notification");
}
};
}

@Test
public void testLockRetentionPolicy() {
rpc =
Expand Down
2 changes: 1 addition & 1 deletion pom.xml
Expand Up @@ -83,7 +83,7 @@
<dependency>
<groupId>com.google.cloud</groupId>
<artifactId>google-cloud-pubsub</artifactId>
<version>1.105.0</version>
<version>1.106.0</version>
<scope>test</scope>
</dependency>
<dependency>
Expand Down

0 comments on commit 300c604

Please sign in to comment.