Toggle navigation
Home
org.apache.pulsar.client.api.Message to java.util.List<org.apache.pulsar.client.api.Message>
No. of Instances - 3
No. of Commits - 1
No. of Projects - {'pulsar'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
Update Anonymous class
{ @Override public void completed( Response response){ try { Message msg=getMessageFromHttpResponse(response); future.complete(msg); } catch ( Exception e) { future.completeExceptionally(getApiException(e)); } } @Override public void failed( Throwable throwable){ future.completeExceptionally(getApiException(throwable.getCause())); } }
to
{ @Override public void completed( Response response){ try { future.complete(getMessageFromHttpResponse(response)); } catch ( Exception e) { future.completeExceptionally(getApiException(e)); } } @Override public void failed( Throwable throwable){ future.completeExceptionally(getApiException(throwable.getCause())); } }
Other
new MessageImpl(msgId,properties,data)
to
new MessageImpl(msgId,properties,data)