|
56 | 56 | import com.obs.services.model.select.SelectObjectResult; |
57 | 57 | import com.obs.services.model.ObjectTagResult; |
58 | 58 | import com.obs.services.model.ObjectTaggingRequest; |
| 59 | +import com.obs.services.model.symlink.GetSymlinkRequest; |
| 60 | +import com.obs.services.model.symlink.GetSymlinkResult; |
| 61 | +import com.obs.services.model.symlink.PutSymlinkRequest; |
59 | 62 |
|
60 | 63 | public abstract class AbstractObjectClient extends AbstractBucketAdvanceClient { |
61 | 64 | @Override |
@@ -279,7 +282,7 @@ public PutObjectResult putObject(String bucketName, String objectKey, InputStrea |
279 | 282 | public PutObjectResult putObject(final PutObjectRequest request) throws ObsException { |
280 | 283 |
|
281 | 284 | ServiceUtils.assertParameterNotNull(request, "PutObjectRequest is null"); |
282 | | - ServiceUtils.assertParameterNotNull2(request.getObjectKey(), "objectKey is null"); |
| 285 | + ServiceUtils.assertParameterNotNull(request.getObjectKey(), "objectKey is null"); |
283 | 286 |
|
284 | 287 | return this.doActionWithResult("putObject", request.getBucketName(), |
285 | 288 | new ActionCallbackWithResult<PutObjectResult>() { |
@@ -380,7 +383,7 @@ void authTypeNegotiate(String bucketName) throws ServiceException { |
380 | 383 | public ObsObject getObject(final GetObjectRequest request) throws ObsException { |
381 | 384 |
|
382 | 385 | ServiceUtils.assertParameterNotNull(request, "GetObjectRequest is null"); |
383 | | - ServiceUtils.assertParameterNotNull2(request.getObjectKey(), "objectKey is null"); |
| 386 | + ServiceUtils.assertParameterNotNull(request.getObjectKey(), "objectKey is null"); |
384 | 387 | return this.doActionWithResult("getObject", request.getBucketName(), new ActionCallbackWithResult<ObsObject>() { |
385 | 388 |
|
386 | 389 | @Override |
@@ -837,4 +840,34 @@ public RestoreObjectResult action() throws ServiceException { |
837 | 840 | } |
838 | 841 | }); |
839 | 842 | } |
| 843 | + |
| 844 | + @Override |
| 845 | + public HeaderResponse putSymlink(PutSymlinkRequest request) throws ObsException { |
| 846 | + ServiceUtils.assertParameterNotNull(request, "PutSymlinkRequest is null"); |
| 847 | + ServiceUtils.assertParameterNotNull(request.getBucketName(), "bucketName is null"); |
| 848 | + ServiceUtils.assertParameterNotNull(request.getObjectKey(), "objectKey is null"); |
| 849 | + return this.doActionWithResult("putSymlink", request.getBucketName(), |
| 850 | + new ActionCallbackWithResult<HeaderResponse>() { |
| 851 | + |
| 852 | + @Override |
| 853 | + public HeaderResponse action() throws ServiceException { |
| 854 | + return AbstractObjectClient.this.putSymlinkImpl(request); |
| 855 | + } |
| 856 | + }); |
| 857 | + } |
| 858 | + |
| 859 | + @Override |
| 860 | + public GetSymlinkResult getSymlink(GetSymlinkRequest request) throws ObsException { |
| 861 | + ServiceUtils.assertParameterNotNull(request, "GetSymlinkRequest is null"); |
| 862 | + ServiceUtils.assertParameterNotNull(request.getBucketName(), "bucketName is null"); |
| 863 | + ServiceUtils.assertParameterNotNull(request.getObjectKey(), "objectKey is null"); |
| 864 | + return this.doActionWithResult("getSymlink", request.getBucketName(), |
| 865 | + new ActionCallbackWithResult<GetSymlinkResult>() { |
| 866 | + |
| 867 | + @Override |
| 868 | + public GetSymlinkResult action() throws ServiceException { |
| 869 | + return AbstractObjectClient.this.getSymlinkImpl(request); |
| 870 | + } |
| 871 | + }); |
| 872 | + } |
840 | 873 | } |
0 commit comments