Merge pull request #18 from cloudstruct/feature/muxer-fix-unknown-protocol

Fix handling for unknown protocol in muxer

Author: agaffney

muxer/muxer.go

@@ -91,8 +91,9 @@ func (m *Muxer) readLoop() {
 			if recvChan == nil {
 				m.ErrorChan <- fmt.Errorf("received message for unknown protocol ID %d", msg.GetProtocolId())
 			}
-		} else {
-			m.protocolReceivers[msg.GetProtocolId()] <- msg
+		}
+		if recvChan != nil {
+			recvChan <- msg
 		}
 	}
 }