diff --git a/lib/protobuf/nats/jnats.rb b/lib/protobuf/nats/jnats.rb index 78b1116..58bd04b 100644 --- a/lib/protobuf/nats/jnats.rb +++ b/lib/protobuf/nats/jnats.rb @@ -87,7 +87,7 @@ def close end def flush(timeout_sec = 0.5) - connection.flush(timeout_sec * 1000) + connection.flush(timeout_sec * 1000) end def next_message(sub, timeout_sec)