Examples of addReceiver()

Examples of net.alteiar.beans.chat.Message.addReceiver()

117
118
119
120
121
122
123
124
125
126
127
    Runnable sendTextMessage = new Runnable() {
      @Override
      public void run() {
        Message msg = new Message(expectedMessage);
        msg.addReceiver(CampaignClient.getInstance().getCurrentPlayer());
        getChat().talk(msg);
      }
    };

    System.out.println("wait for last message 1");
View Full Code Here

Examples of net.alteiar.beans.chat.Message.addReceiver()

132
133
134
135
136
137
138
139
140
141
142
    sendTextMessage = new Runnable() {
      @Override
      public void run() {
        Message msg = new Message(expectedMessage);
        msg.addReceiver(new Player());
        getChat().talk(msg);
      }
    };

    System.out.println("wait for last message 2");
View Full Code Here

Examples of net.alteiar.beans.chat.Message.addReceiver()

169
170
171
172
173
174
175
176
177
178
179
    Runnable sendTextMessage = new Runnable() {
      @Override
      public void run() {
        Message msg = new Message(expectedMessage);
        msg.addReceiver(new Player());
        getChat().talk(MessageFactory.dmMessage(expectedMessage));
      }
    };

    System.out.println("wait for last message 1");
View Full Code Here

Examples of net.windwards.dnsfrontend.client.Client.addReceiver()

44
45
46
47
48
49
50
51
52
53
54
    @Test
    public void receiveRequest() throws Exception {
        final CountDownLatch latch = new CountDownLatch(1);

        Client client = new Client();
        client.addReceiver(new Recipient() {
            @Override
            public void receive(Request request) {
                latch.countDown();
            }
        });
View Full Code Here

Examples of net.windwards.dnsfrontend.client.Client.addReceiver()

97
98
99
100
101
102
103
104
105
106
107
    @Test
    public void overhearUpdate() throws Exception {
        final CountDownLatch latch = new CountDownLatch(1);

        Client client = new Client();
        client.addReceiver(new Recipient() {
            @Override
            public void receive(Request request) {
                latch.countDown();
            }
        });
View Full Code Here

Examples of org.jboss.as.ejb3.remote.DefaultEjbClientContextService.addReceiver()

292
293
294
295
296
297
298
299
300
301
302
            final LocalEjbReceiver byReferenceLocalEjbReceiver = new LocalEjbReceiver(nodeName, true);
            newControllers.add(context.getServiceTarget().addService(LocalEjbReceiver.BY_REFERENCE_SERVICE_NAME, byReferenceLocalEjbReceiver)
                    .addDependency(DeploymentRepository.SERVICE_NAME, DeploymentRepository.class, byReferenceLocalEjbReceiver.getDeploymentRepository())
                    .install());

            clientContextService.addReceiver(clientContextServiceBuilder, LocalEjbReceiver.BY_VALUE_SERVICE_NAME);
        }

        newControllers.add(clientContextServiceBuilder.install());
    }
View Full Code Here

Examples of org.jboss.as.ejb3.remote.DefaultEjbClientContextService.addReceiver()

324
325
326
327
328
329
330
331
332
333
334
            final LocalEjbReceiver byReferenceLocalEjbReceiver = new LocalEjbReceiver(nodeName, true);
            newControllers.add(context.getServiceTarget().addService(LocalEjbReceiver.BY_REFERENCE_SERVICE_NAME, byReferenceLocalEjbReceiver)
                    .addDependency(DeploymentRepository.SERVICE_NAME, DeploymentRepository.class, byReferenceLocalEjbReceiver.getDeploymentRepository())
                    .install());

            clientContextService.addReceiver(clientContextServiceBuilder, LocalEjbReceiver.BY_VALUE_SERVICE_NAME);
        }

        newControllers.add(clientContextServiceBuilder.install());
    }
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.