*: fmt

nsqio · Dec 20, 2022 · b14fdaf · b14fdaf
1 parent de49e3e
commit b14fdaf
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 10 deletions.
diff --git a/nsqd/channel.go b/nsqd/channel.go
@@ -363,8 +363,8 @@ func (c *Channel) FinishMessage(clientID int64, id MessageID) error {
 //
 // `timeoutMs` == 0 - requeue a message immediately
 // `timeoutMs`  > 0 - asynchronously wait for the specified timeout
-//     and requeue a message (aka "deferred requeue")
 //
+//	and requeue a message (aka "deferred requeue")
 func (c *Channel) RequeueMessage(clientID int64, id MessageID, timeout time.Duration) error {
 	// remove from inflight first
 	msg, err := c.popInFlightMessage(clientID, id)

diff --git a/nsqd/message.go b/nsqd/message.go
@@ -65,15 +65,15 @@ func (m *Message) WriteTo(w io.Writer) (int64, error) {
 }
 
 // decodeMessage deserializes data (as []byte) and creates a new Message
-// message format:
-// [x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x]...
-// |       (int64)        ||    ||      (hex string encoded in ASCII)           || (binary)
-// |       8-byte         ||    ||                 16-byte                      || N-byte
-// ------------------------------------------------------------------------------------------...
-//   nanosecond timestamp    ^^                   message ID                       message body
-//                        (uint16)
-//                         2-byte
-//                        attempts
+//
+//	[x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x][x]...
+//	|       (int64)        ||    ||      (hex string encoded in ASCII)           || (binary)
+//	|       8-byte         ||    ||                 16-byte                      || N-byte
+//	------------------------------------------------------------------------------------------...
+//	  nanosecond timestamp    ^^                   message ID                       message body
+//	                       (uint16)
+//	                        2-byte
+//	                       attempts
 func decodeMessage(b []byte) (*Message, error) {
 	var msg Message