Examples of addMessageHandler()

Examples of javax.websocket.Session.addMessageHandler()

805
806
807
808
809
810
811
812
813
814
815
                clientEndpointConfig,
                new URI("wss://localhost:" + getPort() +
                        TesterEchoServer.Config.PATH_ASYNC));
        CountDownLatch latch = new CountDownLatch(1);
        BasicText handler = new BasicText(latch);
        wsSession.addMessageHandler(handler);
        wsSession.getBasicRemote().sendText(MESSAGE_STRING_1);

        boolean latchResult = handler.getLatch().await(10, TimeUnit.SECONDS);

        Assert.assertTrue(latchResult);
View Full Code Here

Examples of javax.websocket.Session.addMessageHandler()

98
99
100
101
102
103
104
105
106
107
108
        TesterEndpoint tep =
                (TesterEndpoint) wsSession.getUserProperties().get("endpoint");
        tep.setLatch(latch);
        AsyncHandler<?> handler = new AsyncText(latch);

        wsSession.addMessageHandler(handler);

        Writer w = wsSession.getBasicRemote().getSendWriter();

        for (int i = 0; i < 8; i++) {
            w.write(TEST_MESSAGE_5K);
View Full Code Here

Examples of javax.websocket.Session.addMessageHandler()

83
84
85
86
87
88
89
90
91
92
93
            final Session session = client.connectToServer(new Endpoint() {
                @Override
                public void onOpen(Session session, EndpointConfig EndpointConfig) {

                    try {
                        session.addMessageHandler(new MessageHandler.Whole<String>() {
                            @Override
                            public void onMessage(String message) {
                                System.out.println("### Received: " + message);

                                if (message.equals("Do or do not, there is no try. (from your server)")) {
View Full Code Here

Examples of javax.websocket.Session.addMessageHandler()

137
138
139
140
141
142
143
144
145
146
147
        try {
            final ClientManager client = createClient();
            Session session = client.connectToServer(new Endpoint() {
                @Override
                public void onOpen(Session session, EndpointConfig EndpointConfig) {
                    session.addMessageHandler(new MessageHandler.Whole<String>() {
                        @Override
                        public void onMessage(String message) {
                            System.out.println("### Received: " + message);

                            if (message.equals(MESSAGE + " (from your server)")) {
View Full Code Here

Examples of org.apache.mina.handler.demux.DemuxingIoHandler.addMessageHandler()

173
174
175
176
177
178
179
180
181
182
183
       
        /*
         * Second round. C1 and C3 messages should be handled by handler1. C2
         * messages should be handled by handler2.
         */
        ioHandler.addMessageHandler( I6.class, ( MessageHandler ) mockHandler2.getMock() );
        ioHandler.messageReceived( session, msg[3] );
        ioHandler.messageReceived( session, msg[4] );
        ioHandler.messageReceived( session, msg[5] );
       
        /*
 
View Full Code Here

Examples of org.apache.mina.handler.demux.DemuxingIoHandler.addMessageHandler()

182
183
184
185
186
187
188
189
190
191
192
       
        /*
         * Third round. C1 and C3 messages should be handled by handler3. C2
         * messages should be handled by handler2.
         */
        ioHandler.addMessageHandler( I3.class, ( MessageHandler ) mockHandler3.getMock() );
        ioHandler.messageReceived( session, msg[6] );
        ioHandler.messageReceived( session, msg[7] );
        ioHandler.messageReceived( session, msg[8] );
       
        /*
 
View Full Code Here

Examples of org.apache.mina.handler.demux.DemuxingIoHandler.addMessageHandler()

105
106
107
108
109
110
111
112
113
114
115
        DemuxingIoHandler ioHandler = new DemuxingIoHandler();
       
        /*
         * First round. All messages should be handled by handler1
         */
        ioHandler.addMessageHandler( C1.class, ( MessageHandler ) mockHandler1.getMock() );
        ioHandler.messageReceived( session, msg[0] );
        ioHandler.messageReceived( session, msg[1] );
        ioHandler.messageReceived( session, msg[2] );
       
        /*
 
View Full Code Here

Examples of org.apache.mina.handler.demux.DemuxingIoHandler.addMessageHandler()

114
115
116
117
118
119
120
121
122
123
124
       
        /*
         * Second round. C1 messages should be handled by handler1. C2 and C3
         * messages should be handled by handler2.
         */
        ioHandler.addMessageHandler( C2.class, ( MessageHandler ) mockHandler2.getMock() );
        ioHandler.messageReceived( session, msg[3] );
        ioHandler.messageReceived( session, msg[4] );
        ioHandler.messageReceived( session, msg[5] );
       
        /*
 
View Full Code Here

Examples of org.apache.mina.handler.demux.DemuxingIoHandler.addMessageHandler()

123
124
125
126
127
128
129
130
131
132
133
       
        /*
         * Third round. C1 messages should be handled by handler1, C2 by
         * handler2 and C3 by handler3.
         */
        ioHandler.addMessageHandler( C3.class, ( MessageHandler ) mockHandler3.getMock() );
        ioHandler.messageReceived( session, msg[6] );
        ioHandler.messageReceived( session, msg[7] );
        ioHandler.messageReceived( session, msg[8] );
       
        /*
 
View Full Code Here

Examples of org.apache.mina.handler.demux.DemuxingIoHandler.addMessageHandler()

164
165
166
167
168
169
170
171
172
173
174
        DemuxingIoHandler ioHandler = new DemuxingIoHandler();
       
        /*
         * First round. All messages should be handled by handler1
         */
        ioHandler.addMessageHandler( I4.class, ( MessageHandler ) mockHandler1.getMock() );
        ioHandler.messageReceived( session, msg[0] );
        ioHandler.messageReceived( session, msg[1] );
        ioHandler.messageReceived( session, msg[2] );
       
        /*
 
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.