Examples of handleMessage()

Examples of com.aelitis.azureus.core.messenger.browser.listeners.BrowserMessageListener.handleMessage()

196
197
198
199
200
201
202
203
204
205
206
    if (listener == null) {
      context.debug("No listener registered with ID " + listenerId);
    } else {
      new AEThread2("dispatch for " + listenerId, true) {
        public void run() {
          listener.handleMessage(message);
          message.complete(true, true, null);
        }
      }.start();
    }
  }
View Full Code Here

Examples of com.corundumstudio.socketio.messages.BaseMessage.handleMessage()

150
151
152
153
154
155
156
157
158
159
160
    @Override
    public void writeRequested(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
        Object msg = e.getMessage();
        if (msg instanceof BaseMessage) {
            BaseMessage message = (BaseMessage) msg;
            message.handleMessage(this, ctx.getChannel());
        } else {
            ctx.sendDownstream(e);
        }
    }
View Full Code Here

Examples of com.dianping.cat.message.spi.core.TcpSocketReceiver.DecodeMessageTask.handleMessage()

28
29
30
31
32
33
34
35
36
37
38
    queue.add(buf);

    MockHandler handler = new MockHandler();
    DecodeMessageTask task = new TcpSocketReceiver().new DecodeMessageTask(0, queue, new MockCodec(), handler);

    task.handleMessage();

    handler.assertEqual(builder.build());

    TcpSocketReceiver receiver = lookup(TcpSocketReceiver.class);
   
View Full Code Here

Examples of com.linkedin.helix.manager.zk.DefaultControllerMessageHandlerFactory.DefaultControllerMessageHandler.handleMessage()

66
67
68
69
70
71
72
73
74
75
76
    Map<String, String> resultMap = new HashMap<String, String>();
    message = new Message(MessageType.NO_OP, "3");
    DefaultControllerMessageHandler defaultHandler = new DefaultControllerMessageHandler(message, context);
    try
    {
      defaultHandler.handleMessage();
    } catch (HelixException e)
    {
      exceptionCaught = true;
    }
    catch (InterruptedException e)
View Full Code Here

Examples of com.linkedin.helix.messaging.handling.MessageHandler.handleMessage()

114
115
116
117
118
119
120
121
122
123
124
    msg.setTgtSessionId("*");
    msg.setCorrelationId(corrId);
   
    MessageHandler aHandler = svc.createHandler(msg, changeContext);
    Map<String, String> resultMap = new HashMap<String, String>();
    aHandler.handleMessage();
   
    AssertJUnit.assertTrue(callback.isDone());
    AssertJUnit.assertTrue(callback._repliedMessageId.contains(msg.getMsgId()));
  }
}
View Full Code Here

Examples of com.music.web.websocket.GameHandler.handleMessage()

146
147
148
149
150
151
152
153
154
155
156
        GameMessage startMsg = new GameMessage();
        startMsg.setAction(GameAction.START);
        startMsg.setGameId(game.getId());

        WebSocketSession session = getSession("1");
        handler.handleMessage(session, getTextMessage(startMsg));

        GameEvent responseNewPiece = mapper.readValue(messages.get("1").removeLast().getPayload().toString(), GameEvent.class);
        GameEvent responseGameStarted = mapper.readValue(messages.get("1").removeLast().getPayload().toString(), GameEvent.class);
        Assert.assertEquals(GameEventType.GAME_STARTED, responseGameStarted.getType());
View Full Code Here

Examples of com.zanox.rabbiteasy.consumer.MessageConsumer.handleMessage()

67
68
69
70
71
72
73
74
75
76
77
        MessageConsumer consumerOne = (MessageConsumer)consumers.get(0).getConsumer();
        MessageConsumer consumerTwo = (MessageConsumer)consumers.get(1).getConsumer();

        consumerOne.handleMessage(new Message());
        consumerOne.handleMessage(new Message());
        consumerTwo.handleMessage(new Message());
        consumerTwo.handleMessage(new Message());
        consumerTwo.handleMessage(new Message());

        Assert.assertEquals(2, TestConsumer.countOne);
        Assert.assertEquals(3, TestConsumer.countTwo);
View Full Code Here

Examples of de.fhkn.in.uce.plugininterface.mediator.HandleMessage.handleMessage()

61
62
63
64
65
66
67
68
69
70
71
        this.checkForRequiredTravTechAttribute(connectionRequestMessage);
        final NATTraversalTechniqueAttribute usedTravTech = connectionRequestMessage
                .getAttribute(NATTraversalTechniqueAttribute.class);
        final HandleMessage connectionRequestHandler = this.messageHandlerRegistry
                .getConnectionRequestHandlerByEncoding(usedTravTech.getEncoded());
        connectionRequestHandler.handleMessage(connectionRequestMessage, controlConnection);
        if (connectionRequestMessage.isMethod(STUNMessageMethod.CONNECTION_REQUEST)
                && connectionRequestMessage.isSuccessResponse()) {
            // remove only connection requests from list where a response was
            // seen
            this.connectionRequests.removeConnectionRequest(new String(connectionRequestMessage.getHeader()
View Full Code Here

Examples of javax.xml.ws.handler.Handler.handleMessage()

310
311
312
313
314
315
316
317
318
319
320
                Handler handler = (Handler) handlers.get(i);
               
                if (log.isDebugEnabled()) {
                    log.debug("Invoking handleMessage on: " + handler.getClass().getName());
                }
                handler.handleMessage(currentMC);
            }
        } else { // IN case
            for (; i >= end; i--) {
                switchContext(direction, i);
                Handler handler = (Handler) handlers.get(i);
View Full Code Here

Examples of javax.xml.ws.handler.soap.SOAPHandler.handleMessage()

26
27
28
29
30
31
32
33
34
35
36
        }
        else if (handler instanceof SOAPHandler)
        {
            SOAPHandler sh = (SOAPHandler) handler;

            sh.handleMessage(soapContext);
        }
        else
        {
            handler.handleMessage(soapContext);
        }
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.