()
| 27 | ) |
| 28 | |
| 29 | func relay_backend() { |
| 30 | queue := cellnet.NewEventQueue() |
| 31 | |
| 32 | relay_BackendToAgentConnector = peer.NewGenericPeer("tcp.Connector", "backend", relayBackendToAgent_Address, queue) |
| 33 | |
| 34 | proc.BindProcessorHandler(relay_BackendToAgentConnector, "tcp.ltv", func(ev cellnet.Event) { |
| 35 | |
| 36 | if relayEvent, ok := ev.(*relay.RecvMsgEvent); ok { |
| 37 | |
| 38 | log.Debugln("Relay to agent", relayEvent.Message(), relayEvent.PassThroughAsInt64()) |
| 39 | relay.Relay(relay_BackendToAgentConnector, relayEvent.Message(), relayEvent.PassThroughAsInt64()) |
| 40 | |
| 41 | } |
| 42 | |
| 43 | }) |
| 44 | |
| 45 | relay_BackendToAgentConnector.Start() |
| 46 | |
| 47 | queue.StartLoop() |
| 48 | } |
| 49 | |
| 50 | func relay_agent() { |
| 51 |
no test coverage detected