Increase default REMBUS_TIMEOUT

cardo-org · Jun 3, 2024 · 7e75241 · 7e75241
1 parent bd10e72
commit 7e75241
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 2 deletions.
diff --git a/src/Rembus.jl b/src/Rembus.jl
@@ -348,7 +348,7 @@ broker_dir() = CONFIG.db
 
 keystore_dir() = get(ENV, "REMBUS_KEYSTORE", joinpath(broker_dir(), "keystore"))
 
-request_timeout() = parse(Float32, get(ENV, "REMBUS_TIMEOUT", "5"))
+request_timeout() = parse(Float32, get(ENV, "REMBUS_TIMEOUT", "10"))
 
 connect_request_timeout() = parse(Float32, get(ENV, "REMBUS_CONNECT_TIMEOUT", "10"))
 

diff --git a/src/broker.jl b/src/broker.jl
@@ -1788,6 +1788,9 @@ function broker(self, router)
                 @warn "unknow $(typeof(msg)) message $msg "
             end
         end
+    catch e
+        @error "broker: $e"
+        rethrow()
     finally
         for tw in values(router.id_twin)
             ## detach(tw)

diff --git a/src/encode.jl b/src/encode.jl
@@ -254,7 +254,7 @@ function encode_partial(data)
 end
 
 function add_payload(io, payload)
-    if isa(payload, IOBuffer)
+    if isa(payload, Base.GenericIOBuffer)
         pos = position(payload)
         write(io, payload)
         seek(payload, pos)