--- a/src/stomp.nim Sun Apr 04 16:12:19 2021 -0700
+++ b/src/stomp.nim Wed Oct 27 14:36:25 2021 -0700
@@ -50,12 +50,12 @@
##
import
- strutils,
- nativesockets,
- net,
- os,
- times,
- uri
+ std/nativesockets,
+ std/net,
+ std/os,
+ std/strutils,
+ std/times,
+ std/uri
const
VERSION = "0.1.3" ## The current program version.
@@ -130,7 +130,7 @@
c.socket.readline( line, c.timeout )
while not line.is_eol:
- if defined( debug ): printf " <-- %s\n", line
+ if defined( debug ): printf " <-- %s\n", cstring(line)
var header = line.split( ":" )
if header.len < 2: break
response.headers.add( (header[0], header[1]) )
@@ -206,7 +206,7 @@
#
result.frame = line
if defined( debug ):
- printf " <-- %s\n", line
+ printf " <-- %s\n", cstring(line)
# Parse headers and body.
#
@@ -319,7 +319,7 @@
result.options.heartbeat = opt[1].parse_int
else:
discard
- except IndexError, ValueError:
+ except IndexDefect, ValueError:
discard
# Set default STOMP port if otherwise unset.
@@ -763,12 +763,6 @@
proc receive_message( c: StompClient, r: StompResponse ) =
messages.add( r )
- case r.frame:
- of "RECEIPT":
- discard
- of "MESSAGE":
- discard r.payload
- discard r[ "ack" ]
proc seen_heartbeat( c: StompClient, r: StompResponse ) =
heartbeats = heartbeats + 1