Package org.menacheri.jetclient.event

Examples of org.menacheri.jetclient.event.EventHandler

117
118
119
120
121
122
123
124
125
126
127
      final DatagramChannel datagramChannel = udpClient
          .createDatagramChannel();
      localAddress = udpClient.getLocalAddress(datagramChannel);
      // Add a start event handler to the session which will send the udp
      // connect on server START signal.
      EventHandler startEventHandler = new EventHandler()
      {
        @Override
        public void onEvent(Event event)
        {
          try
View Full Code Here
234
235
236
237
238
239
240
241
242
243
244
    final DatagramChannel datagramChannel = udpClient
        .createDatagramChannel();
    localAddress = datagramChannel.getLocalAddress();
    // Add a start event handler to the session which will send the udp
    // connect on server START signal.
    final EventHandler startEventHandler = new EventHandler()
    {
      @Override
      public void onEvent(Event event)
      {
        try
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
    @Override
    public void applyPolicy(final Session session)
    {
      // Listen for log in success event to be received on the session.
      final CountDownLatch loginSuccessLatch = new CountDownLatch(1);
      final EventHandler loginSuccess = new EventHandler()
      {
        @Override
        public void onEvent(Event event)
        {
          // remove after use
View Full Code Here
18
19
20
21
22
23
24
25
26
27
28
  public void specificEventReceiptOnSpecificEventHandler()
      throws InterruptedException
  {
    EventDispatcher dispatcher = new DefaultEventDispatcher();
    final CountDownLatch latch = new CountDownLatch(1);
    dispatcher.addHandler(new EventHandler()
    {

      @Override
      public void onEvent(Event event)
      {
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
  @Test
  public void eventReceiptOnANYTypeEventHandler() throws InterruptedException
  {
    EventDispatcher dispatcher = new DefaultEventDispatcher();
    final CountDownLatch latch = new CountDownLatch(5);
    dispatcher.addHandler(new EventHandler()
    {

      @Override
      public void onEvent(Event event)
      {
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
  public void nonReceiptOfWrongEventOnSpecificEventHandler()
      throws InterruptedException
  {
    EventDispatcher dispatcher = new DefaultEventDispatcher();
    final CountDownLatch latch = new CountDownLatch(1);
    dispatcher.addHandler(new EventHandler()
    {

      @Override
      public void onEvent(Event event)
      {
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
  public void eventPublishingPerformance() throws InterruptedException
  {
    EventDispatcher dispatcher = new DefaultEventDispatcher();
    int countOfEvents = 5000000;
    final CountDownLatch latch = new CountDownLatch(countOfEvents);
    dispatcher.addHandler(new EventHandler()
    {

      @Override
      public void onEvent(Event event)
      {
View Full Code Here
TOP

Related Classes of org.menacheri.jetclient.event.EventHandler

  • org.menacheri.jetclient.app.impl.SessionFactory
  • org.menacheri.jetclient.communication.ReconnectPolicy$ReconnectNTimes
  • org.menacheri.jetclient.event.impl.EventDispatcherTest
    • Copyright © 2018 www.massapicom. 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.