Examples of MockMessage


Examples of jetbrains.communicator.mock.MockMessage

    assertEquals("Only one message should be queued", 1,
        myDispatcher.getPendingMessages(myUser).length);
  }

  public void testUserDeleted() throws Exception {
    MockMessage failedMessage = new MockMessage(false);
    myDispatcher.performDispatch(myUser, failedMessage);

    getBroadcaster().fireEvent(new UserEvent.Removed(myUser));
    assertEquals("Queue should be cleared when user is deleted", 0,
        myDispatcher.getPendingMessages(myUser).length);
View Full Code Here

Examples of jetbrains.communicator.mock.MockMessage

        myDispatcher.getPendingMessages(myUser).length);
  }

  public void testSuccessfulSendingOfPendingEvent() throws Exception {
    myUser.setOnline(true);
    MockMessage failedMessage = new MockMessage(false);
    myDispatcher.performDispatch(myUser, failedMessage);

    failedMessage.setSendSuccessful(true);
    myDispatcher.performDispatch(myUser, failedMessage);

    assertEquals("If sent successful, remove from pending queue", 0,
        myDispatcher.getPendingMessages(myUser).length);
  }
View Full Code Here

Examples of jetbrains.communicator.mock.MockMessage

    assertEquals("If sent successful, remove from pending queue", 0,
        myDispatcher.getPendingMessages(myUser).length);
  }

  public void testRemoveMessageFromQueue() throws Exception {
    MockMessage message1 = new MockMessage();
    MockMessage message2 = new MockMessage();
    MockMessage message3 = new MockMessage();
    myDispatcher.addPendingMessage(myUser, message1);
    myDispatcher.addPendingMessage(myUser, message2);
    myDispatcher.addPendingMessage(myUser, message3);

    myDispatcher.removePendingMessage(myUser, 0);
View Full Code Here

Examples of jetbrains.communicator.mock.MockMessage

  }

  public void testIconBlinkingStatus() throws Exception {
    assertFalse(hasMessagesWhichRequireIconBlinking());

    MockMessage message = new MockMessage();
    myDispatcher.addPendingMessage(myUser, message);

    assertEquals(1, myDispatcher.getPendingMessages(myUser).length);
    assertTrue("Should blink to inform user about urgent event",
        hasMessagesWhichRequireIconBlinking());
View Full Code Here

Examples of jetbrains.communicator.mock.MockMessage

  private boolean hasMessagesWhichRequireIconBlinking() {
    return myDispatcher.getBlinkingIcon() != null;
  }

  public void testAddPendingMessage() throws Exception {
    MockMessage message = new MockMessage();
    myDispatcher.addPendingMessage(myUser, message);

    assertEquals(1, myDispatcher.getPendingMessages(myUser).length);
    assertSame(message, myDispatcher.getPendingMessages(myUser)[0]);
View Full Code Here

Examples of jetbrains.communicator.mock.MockMessage

  public void testTransportEvent() throws Exception {

    MockTransport mockTransport = new MockTransport();

    MockMessage localMessage = new MockMessage();
    MockMessage localMessage1 = new MockMessage();
    myIdeFacade.setReturnedMessage(localMessage);
    getBroadcaster().fireEvent(new TransportEvent(mockTransport, "user"){});

    myIdeFacade.setReturnedMessage(localMessage1);
    getBroadcaster().fireEvent(new TransportEvent(mockTransport, "user"){});
View Full Code Here

Examples of jetbrains.communicator.mock.MockMessage

  }

  public void testSendMessageEvent() throws Exception {
    MockTransport mockTransport = new MockTransport();

    MockMessage localMessage = new MockMessage();
    MockMessage localMessage1 = new MockMessage();
    myIdeFacade.setReturnedMessage(localMessage);
    getBroadcaster().fireEvent(new SendMessageEvent("text", myUser));

    myIdeFacade.setReturnedMessage(localMessage1);
    getBroadcaster().fireEvent(new SendMessageEvent("text", myUser));
View Full Code Here

Examples of jetbrains.communicator.mock.MockMessage

    assertSame(localMessage, history[0]);
    assertSame(localMessage1, history[1]);
  }

  public void testPersistency() throws Exception {
    myDispatcher.addPendingMessage(myUser, new MockMessage());
    assertEquals("Should have no problems with nulls", 1, myDispatcher.getPendingMessages(myUser).length);

    // test persistency
    LocalMessageDispatcherImpl localMessageDispatcher = createLocalMessageDispatcher();
    assertEquals(1, localMessageDispatcher.getPendingMessages(myUser).length);
View Full Code Here

Examples of jetbrains.communicator.mock.MockMessage

  }

  public void testHistory() throws Exception {
    assertEquals(0, myDispatcher.getHistory(myUser, null).length);

    MockMessage message = new MockMessage();
    myDispatcher.addPendingMessage(myUser, message);

    assertEquals(1, myDispatcher.getPendingMessages(myUser).length);
    assertEquals(0, myDispatcher.getHistory(myUser, null).length);

    myDispatcher.sendNow(myUser, message);

    assertEquals(0, myDispatcher.getPendingMessages(myUser).length);
    assertEquals(1, myDispatcher.getHistory(myUser, null).length);

    MockMessage message2 = new MockMessage();
    myDispatcher.sendNow(myUser, message2);

    LocalMessage[] history = myDispatcher.getHistory(myUser, null);
    assertEquals(2, history.length);
    assertSame(message, history[0]);
View Full Code Here

Examples of jetbrains.communicator.mock.MockMessage

    assertSame(message, history[0]);
    assertSame(message2, history[1]);
  }

  public void testHistoryWithDate() throws Exception {
    MockMessage message = new MockMessage();
    myDispatcher.sendNow(myUser, message);

    Thread.sleep(10);
    assertEquals(1, myDispatcher.getHistory(myUser, a_moment_ago()).length);
    assertEquals("Do not expect old history", 0, myDispatcher.getHistory(myUser, new Date()).length);
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.