Skip to content
This repository was archived by the owner on Sep 26, 2025. It is now read-only.

Commit cbeaaad

Browse files
committed
Add @nullable to argument
References #111
1 parent 3531a1b commit cbeaaad

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/main/java/reactor/rabbitmq/CorrelableOutboundMessage.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818

1919
import com.rabbitmq.client.AMQP;
2020
import org.reactivestreams.Publisher;
21+
import reactor.util.annotation.Nullable;
2122

2223
import java.util.Arrays;
2324

@@ -58,7 +59,7 @@ public CorrelableOutboundMessage(String exchange, String routingKey, byte[] body
5859
* @param body The main body of the message.
5960
* @param correlationMetadata The (unserialized) metadata correlated with this Message.
6061
*/
61-
public CorrelableOutboundMessage(String exchange, String routingKey, AMQP.BasicProperties properties, byte[] body, T correlationMetadata) {
62+
public CorrelableOutboundMessage(String exchange, String routingKey, @Nullable AMQP.BasicProperties properties, byte[] body, T correlationMetadata) {
6263
super(exchange, routingKey, properties, body);
6364
this.correlationMetadata = correlationMetadata;
6465
}

0 commit comments

Comments
 (0)