File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
momento-sdk/src/main/java/momento/sdk Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change 1010import momento .sdk .auth .CredentialProvider ;
1111import momento .sdk .config .TopicConfiguration ;
1212import momento .sdk .exceptions .CacheServiceExceptionMapper ;
13+ import momento .sdk .exceptions .ClientSdkException ;
1314import momento .sdk .internal .SubscriptionState ;
1415import momento .sdk .responses .topic .TopicPublishResponse ;
1516import momento .sdk .responses .topic .TopicSubscribeResponse ;
@@ -160,9 +161,9 @@ private CompletableFuture<TopicSubscribeResponse> sendSubscribe(
160161 return new TopicSubscribeResponse .Subscription (subscriptionState );
161162 }
162163 });
163- } catch (Throwable e ) {
164+ } catch (ClientSdkException e ) {
164165 return CompletableFuture .completedFuture (
165- new TopicSubscribeResponse .Error (CacheServiceExceptionMapper . convert ( e ) ));
166+ new TopicSubscribeResponse .Error (e ));
166167 }
167168 }
168169
You can’t perform that action at this time.
0 commit comments