src/stomp.nim
changeset 10 d63cce6d1a09
parent 9 ad53c6500712
--- 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