ing

gateway/servlet_handlers.go

@@ -1,9 +1,16 @@
 package gateway
 
 import (
+	"fmt"
+
 	"git.loafle.net/commons_go/rpc"
+	"git.loafle.net/commons_go/rpc/protocol"
 )
 
 type ServletHandlers struct {
 	rpc.ServletHandlers
 }
+
+func (sh *ServletHandlers) Invoke(servletCTX rpc.ServletContext, requestCodec protocol.RegistryCodec) (result interface{}, err error) {
+	return nil, fmt.Errorf("RPC Gateway Servlet Handler: Invoke is not implemented")
+}

registry/registry.go

@@ -1,4 +1,4 @@
-package rpc
+package registry
 
 import (
 	"reflect"
@@ -6,27 +6,17 @@ import (
 	"git.loafle.net/commons_go/rpc/protocol"
 )
 
-/**
-
-Network connection
-	Handshake(1..n)
-		Send request
-			HTTP
-
-
-*/
-
 // NewRPCRegistry returns a new RPC registry.
-func NewRegistry() Registry {
+func NewRPCRegistry() RPCRegistry {
 	return &rpcRegistry{
 		services: new(serviceMap),
 	}
 }
 
-type Registry interface {
+type RPCRegistry interface {
+	Invoke(codec protocol.RegistryCodec) (result interface{}, err error)
 	RegisterService(receiver interface{}, name string) error
 	HasMethod(method string) bool
-	Invoke(codec protocol.RegistryCodec) (result interface{}, err error)
 }
 
 // RPCRegistry serves registered RPC services using registered codecs.

registry/service_map.go

@@ -1,4 +1,4 @@
-package rpc
+package registry
 
 import (
 	"fmt"

server/servlet_handlers.go

@@ -6,12 +6,13 @@ import (
 	"git.loafle.net/commons_go/logging"
 	"git.loafle.net/commons_go/rpc"
 	"git.loafle.net/commons_go/rpc/protocol"
+	"git.loafle.net/commons_go/rpc/registry"
 )
 
 type ServletHandlers struct {
 	rpc.ServletHandlers
 
-	RPCRegistry rpc.Registry
+	RPCRegistry registry.RPCRegistry
 }
 
 func (sh *ServletHandlers) Invoke(servletCTX rpc.ServletContext, requestCodec protocol.RegistryCodec) (result interface{}, err error) {

servlet.go

@@ -70,9 +70,9 @@ func (s *rpcServlet) Start(parentCTX cuc.Context, conn interface{}, doneChan cha
 	if err := s.sh.Init(s.ctx); nil != err {
 		logging.Logger().Panic(fmt.Sprintf("Servlet: Initialization of servlet has been failed %v", err))
 	}
+	s.responseQueueChan = make(chan *responseState, s.sh.GetPendingResponses())
 
 	s.stopChan = make(chan struct{})
-	s.responseQueueChan = make(chan *responseState, s.sh.GetPendingResponses())
 
 	s.stopWg.Add(1)
 	go handleServlet(s)

servlet_handlers.go

@@ -30,7 +30,7 @@ func (sh *ServletHandlers) Init(servletCTX ServletContext) error {
 }
 
 func (sh *ServletHandlers) Invoke(servletCTX ServletContext, requestCodec protocol.RegistryCodec) (result interface{}, err error) {
-	return nil, fmt.Errorf("Servlet Handler: Invoke is not implemented")
+	return nil, nil
 }
 
 func (sh *ServletHandlers) Destroy(servletCTX ServletContext) {