diff --git a/main.go b/main.go
index 1045206..ab0eadc 100644
--- a/main.go
+++ b/main.go
@@ -38,7 +38,7 @@ func handleConnection(con net.Conn, sessions map[string]*session.Session) {
 	}
 
 	var sess *session.Session
-	if(conReq.ConnectPakcet.ClientId != nil) {
+	if conReq.ConnectPakcet.ClientId != nil {
 		sess, exists := sessions[*conReq.ConnectPakcet.ClientId]
 		if exists {
 			sess.ConnecionChannel <- conReq
diff --git a/mqtt/packets/Publish.go b/mqtt/packets/Publish.go
index 63f7a0e..0b4ba38 100644
--- a/mqtt/packets/Publish.go
+++ b/mqtt/packets/Publish.go
@@ -64,7 +64,7 @@ func parsePublishPacket(control controlPacket) (PublishPacket, error) {
 
 func (p PublishPacket) Write(w io.Writer) error {
 	buf := bytes.NewBuffer([]byte{})
-	
+
 	err := types.WriteUTF8String(buf, p.TopicName)
 	if err != nil {
 		return err
@@ -77,7 +77,6 @@ func (p PublishPacket) Write(w io.Writer) error {
 		}
 	}
 
-
 	err = properties.WriteProps(buf, p.Properties.ArrayOf())
 	if err != nil {
 		return err
diff --git a/session/session.go b/session/session.go
index f6ddeb7..a441774 100644
--- a/session/session.go
+++ b/session/session.go
@@ -26,7 +26,7 @@ type Session struct {
 	// Nullable
 	Connection          *Connection
 	SubscriptionChannel chan packets.PublishPacket
-	ConnecionChannel chan ConnectionRequest
+	ConnecionChannel    chan ConnectionRequest
 
 	ExpiryInterval time.Duration // TODO
 	expireTimer    time.Timer    // TODO
@@ -35,7 +35,7 @@ type Session struct {
 }
 
 type ConnectionRequest struct {
-	Connection *Connection
+	Connection    *Connection
 	ConnectPakcet packets.ConnectPacket
 }
 
@@ -89,9 +89,9 @@ func (s *Session) HandlerLoop() {
 		case c := <-s.ConnecionChannel:
 			s.Connect(c)
 		case subMessage := <-s.SubscriptionChannel:
-			subMessage.QOSLevel = 0 
-				subMessage.Dup = false
-				s.Connection.sendPacket(subMessage)
+			subMessage.QOSLevel = 0
+			subMessage.Dup = false
+			s.Connection.sendPacket(subMessage)
 		}
 	}
 	c := <-s.ConnecionChannel