Private
Public Access
1
0

changed websocket default port && debug RPC

This commit is contained in:
2016-10-21 17:55:19 +02:00
parent 28f42db14a
commit d0779847ca
3 changed files with 21 additions and 10 deletions

View File

@@ -32,7 +32,7 @@ snc_redis:
gos_web_socket: gos_web_socket:
server: server:
host: 0.0.0.0 host: 0.0.0.0
port: 8080 port: 6450
router: router:
resources: resources:
- "@MineSeekerBundle/Resources/config/pubsub/routing.yml" - "@MineSeekerBundle/Resources/config/pubsub/routing.yml"

View File

@@ -4,7 +4,7 @@ import GridControl from './grid/grid-control';
class MineSeeker extends React.Component { class MineSeeker extends React.Component {
/** after rendering */ /** after rendering */
componentDidMount() { componentDidMount() {
var websocket = WS.connect("ws://mine.dev:8080"); var websocket = WS.connect("ws://mine.dev:6450");
/** session is an Autobahn JS WAMP session. */ /** session is an Autobahn JS WAMP session. */
websocket.on("socket/connect", function (session) { websocket.on("socket/connect", function (session) {
@@ -14,14 +14,14 @@ class MineSeeker extends React.Component {
console.log("Received message", payload.msg); console.log("Received message", payload.msg);
}); });
// session.call("sample/sum", {"term1": 2, "term2": 5}).then( session.call("sample/sum", [2, 5]).then(
// function (result) { function (result) {
// console.log("RPC Valid!", result); console.log("RPC Valid!", result);
// }, },
// function (error, desc) { function (error, desc) {
// console.log("RPC Error", error, desc); console.log("RPC Error", error, desc);
// } }
// ); );
session.publish("acme/channel", {msg: "This is a message!"}); session.publish("acme/channel", {msg: "This is a message!"});

View File

@@ -23,6 +23,17 @@ class AcmeRpc implements RpcInterface
return array("result" => array_sum($params)); return array("result" => array_sum($params));
} }
/**
* @param ConnectionInterface $connection
* @param WampRequest $request
* @param $params
* @return number
*/
public function sum(ConnectionInterface $connection, WampRequest $request, $params)
{
return array_sum($params);
}
/** /**
* Name of RPC, use for pubsub router (see step3) * Name of RPC, use for pubsub router (see step3)
* *