1234567891011121314151617181920212223242526272829303132 |
- var stompClient = null;
- function connect() {
-
- var socket = new SockJS('http://localhost:8081/amp/websocket');
- stompClient = Stomp.over(socket);
-
- stompClient.connect({}, function (frame) {
- console.log('Connected: ' + frame);
- stompClient.subscribe('/public/transactions', function (msg) {
- var msgJ = JSON.parse(msg.body);
- console.log('/public/transactions', msgJ);
- });
- stompClient.subscribe('/channel/transactions', function (msg) {
- var msgJ = JSON.parse(msg.body);
- console.log('/channel/transactions', msgJ);
- });
- });
-
- }
- function disconnect() {
- if (stompClient !== null) {
- stompClient.disconnect();
- }
- setConnected(false);
- console.log("Disconnected");
- }
- $(document).ready(function() {
- connect();
- });
|