Examples of receive()

Examples of org.hornetq.core.client.impl.ClientConsumerInternal.receive()

2445
2446
2447
2448
2449
2450
2451
2452
2453
2454
2455
         for (int trans = 0; trans < 2; trans++)
         {

            for (int i = 0; i < NUMBER_OF_MESSAGES; i++)
            {
               ClientMessage msg = consumer.receive(10000);
               Assert.assertNotNull(msg);

               // it will ignore the buffer (not read it) on the first try
               if (trans == 0)
               {
View Full Code Here

Examples of org.javagroups.Channel.receive()

126
127
128
129
130
131
132
133
134
135
136
                }

                Message mes = null;
                try
                {
                    Object obj = javagroups.receive( 0 );
                    if ( obj != null && obj instanceof org.javagroups.Message )
                    {
                        mes = ( Message ) obj;
                        log.info( "Starting new socket node." );
                        new Thread( new LateralJGReceiverConnection( mes, ilcl ) ).start();
View Full Code Here

Examples of org.jboss.blacktie.jatmibroker.core.transport.Receiver.receive()

524
525
526
527
528
529
530
531
532
533
534
    Receiver endpoint = temporaryQueues.get(cd);
    if (endpoint == null) {
      throw new ConnectionException(Connection.TPEBADDESC,
          "Session does not exist: " + cd);
    }
    Message message = endpoint.receive(flags);
    temporaryQueues.remove(cd);
    Buffer buffer = null;
    if (message.type != null && !message.type.equals("")) {
      buffer = tpalloc(message.type, message.subtype, message.len);
      buffer.deserialize(message.data);
View Full Code Here

Examples of org.jboss.example.jms.stateless.bean.StatelessSessionExample.receive()

61
62
63
64
65
66
67
68
69
70
71
                 
      assertEquals(1, num);
         
      log("Queue browse result: " + num);           
     
      String result = bean.receive(queueName);
      log("Received " + result);           
     
      assertEquals("Hello!", result);           
     
      bean.remove();
View Full Code Here

Examples of org.jboss.narayana.blacktie.jatmibroker.core.transport.Receiver.receive()

55
56
57
58
59
60
61
62
63
64
65
    String aString = "Hello from Java Land";
    Receiver endpoint = proxy.createReceiver(1, null);
    serviceFactory.send(endpoint.getReplyTo(), (short) 0, 0,
        aString.getBytes(), aString.getBytes().length, 0, 0, 0,
        "X_OCTET", "");
    Message receive = endpoint.receive(0);

    assertNotNull(receive);
    String string = new String(receive.data).intern();
    String expectedResponse = "BAR SAYS HELLO";
    log.debug("Bar ServiceManager service_request response is " + string);
View Full Code Here

Examples of org.jboss.test.ws.jaxws.samples.dar.generated.reply.DarReplyEndpoint.receive()

81
82
83
84
85
86
87
88
89
90
91
         Relationship[] relationships = new Relationship[1];
         relationships[0] = new RelationshipImpl(asyncRequest.getMessageId());
         requestProps.setRelatesTo(relationships);
         ((BindingProvider)endpoint).getRequestContext().put(JAXWSAConstants.CLIENT_ADDRESSING_PROPERTIES_OUTBOUND, requestProps);
        
         endpoint.receive(darResponse);
         log.info("Response sent.");
      } catch (Exception e) {
         e.printStackTrace();
      }
   }
View Full Code Here

Examples of org.jclouds.sqs.features.MessageApi.receive()

47
48
49
50
51
52
53
54
55
56
57
      MessageApi messageClient = createMock(MessageApi.class);
      ReceiveMessageOptions options = new ReceiveMessageOptions();
      FluentIterable<Message> aMessage = FluentIterable.from(ImmutableSet.of(createMock(Message.class)));
      FluentIterable<Message> noMessages = FluentIterable.from(ImmutableSet.<Message>of());

      expect(messageClient.receive(1, options))
            .andReturn(aMessage)
            .once();
     
      expect(messageClient.receive(1, options))
            .andReturn(noMessages)
View Full Code Here

Examples of org.jgroups.Channel.receive()

179
180
181
182
183
184
185
186
187
188
189
      Object tmp;
      int cnt = -1;
      while (true) {
         try {
            tmp = channel.receive(0);
            if (tmp instanceof ExitEvent) {
               break;
            }
            if (tmp instanceof SetStateEvent) {
               cnt = ((Integer) Util.objectFromByteBuffer(((SetStateEvent) tmp).getArg())).intValue();
View Full Code Here

Examples of org.jgroups.JChannel.receive()

179
180
181
182
183
184
185
186
187
188
189
      Object tmp;
      int cnt = -1;
      while (true) {
         try {
            tmp = channel.receive(0);
            if (tmp instanceof ExitEvent) {
               break;
            }
            if (tmp instanceof SetStateEvent) {
               cnt = ((Integer) Util.objectFromByteBuffer(((SetStateEvent) tmp).getArg())).intValue();
View Full Code Here

Examples of org.jgroups.Receiver.receive()

101
102
103
104
105
106
107
108
109
110
111
                    if (msg.getHeader(MAGIC_HEADER) != null) {
                        if (!(discardOwnMessages && getAddress() != null && msg.getSrc() != null && getAddress().equals(msg.getSrc())))
                            receiver.receive(msg);
                    } else {
                        if (dataReceiver != null && !(dataDiscardOwnMessages && getAddress() != null && msg.getSrc() != null && getAddress().equals(msg.getSrc())))
                            dataReceiver.receive(msg);
                    }
                    break;

                case Event.VIEW_CHANGE:
                    receiver.viewAccepted((View) evt.getArg());
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.