Skip to content

Commit 6abe0e4

Browse files
committed
check for null
1 parent caf7009 commit 6abe0e4

File tree

1 file changed

+1
-1
lines changed
  • sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms

1 file changed

+1
-1
lines changed

sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1153,7 +1153,7 @@ private <T, MethodArgT, MethodResultT> T proxyMethod(
11531153
new Class[] {proxyInterface},
11541154
(proxy, method, args) -> {
11551155
Object result = method.invoke(target, args);
1156-
if (method.getName().equals(methodName)) {
1156+
if (method.getName().equals(methodName) && result != null) {
11571157
result = resultTransformer.apply((MethodArgT) result);
11581158
}
11591159
return result;

0 commit comments

Comments
 (0)