Skip to content

Commit e188454

Browse files
committed
Small fix
1 parent 9715408 commit e188454

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

android/src/main/java/nl/kega/reactnativerabbitmq/RabbitMqExchange.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ public void publish(String message, String routing_key, ReadableMap message_prop
7373
if (message_properties.hasKey("correlation_id") && message_properties.getType("correlation_id") == ReadableType.String){
7474
properties.correlationId(message_properties.getString("correlation_id"));
7575
}
76-
if (message_properties.hasKey("expiration") && message_properties.getType("correlation_id") == ReadableType.String){
76+
if (message_properties.hasKey("expiration") && message_properties.getType("expiration") == ReadableType.String){
7777
properties.expiration(message_properties.getString("expiration"));
7878
}
7979
if (message_properties.hasKey("message_id") && message_properties.getType("message_id") == ReadableType.String){

0 commit comments

Comments
 (0)