Examples of writeUTF()

Examples of org.codehaus.activemq.message.ActiveMQBytesMessage.writeUTF()

215
216
217
218
219
220
221
222
223
224
225
  }
  public void testReadUTF() {
    ActiveMQBytesMessage msg = new ActiveMQBytesMessage();
    try {
      String str = "this is a test";
      msg.writeUTF(str);
      msg.reset();
      assertTrue(msg.readUTF().equals(str));
    } catch (JMSException jmsEx) {
      jmsEx.printStackTrace();
      assertTrue(false);
View Full Code Here

Examples of org.elasticsearch.common.io.stream.BytesStreamOutput.writeUTF()

42
43
44
45
46
47
48
49
50
51
52
        out.writeVInt(2);
        out.writeLong(-3);
        out.writeVLong(4);
        out.writeFloat(1.1f);
        out.writeDouble(2.2);
        out.writeUTF("hello");
        out.writeUTF("goodbye");

        BytesStreamInput in = new BytesStreamInput(out.copiedByteArray());
        assertThat(in.readBoolean(), equalTo(false));
        assertThat(in.readByte(), equalTo((byte) 1));
View Full Code Here

Examples of org.elasticsearch.common.io.stream.HandlesStreamOutput.writeUTF()

37
38
39
40
41
42
43
44
45
46
47
    @Test public void testSharedUTFHandles() throws Exception {
        BytesStreamOutput bytesOut = new BytesStreamOutput();
        HandlesStreamOutput out = new HandlesStreamOutput(bytesOut, 5);
        String lowerThresholdValue = "test";
        String higherThresholdValue = "something that is higher than 5";
        out.writeUTF(lowerThresholdValue);
        out.writeUTF(higherThresholdValue);
        out.writeInt(1);
        out.writeUTF("else");
        out.writeUTF(higherThresholdValue);
        out.writeUTF(lowerThresholdValue);
View Full Code Here

Examples of org.exist.storage.io.VariableByteOutputStream.writeUTF()

120
121
122
123
124
125
126
127
128
129
130
        final Capture<String> strCapture = new Capture<String>();

        //write expectations
        mockOs.writeByte(captureByte(byteCapture));
        mockOs.writeInt(captureInt(intCapture));
        mockOs.writeUTF(capture(strCapture));

        replay(mockOs);

        symbolTable.localNameSymbols.write(mockOs);
View Full Code Here

Examples of org.hornetq.api.core.HornetQBuffer.writeUTF()

224
225
226
227
228
229
230
231
232
233
234
      String str1 = RandomUtil.randomString();
      String str2 = RandomUtil.randomString();
      Double d1 = RandomUtil.randomDouble();
      float f1 = RandomUtil.randomFloat();

      dynamic.writeUTF(str1);
      dynamic.writeString(str2);
      dynamic.writeDouble(d1);
      dynamic.writeFloat(f1);

      LargeMessageControllerImpl readBuffer = splitBuffer(3, dynamic.toByteBuffer().array());
View Full Code Here

Examples of org.jboss.as.protocol.ByteDataOutput.writeUTF()

280
281
282
283
284
285
286
287
288
289
290
        protected void sendRequest(final int protocolVersion, final OutputStream outputStream) throws IOException {
            ByteDataOutput output = null;
            try {
                output = new SimpleByteDataOutput(outputStream);
                output.write(DomainControllerProtocol.PARAM_HOST_ID);
                output.writeUTF(name);
                output.writeByte(DomainControllerProtocol.PARAM_HOST_CONTROLLER_HOST);
                final byte[] address = localManagementAddress.getAddress();
                output.writeInt(address.length);
                output.write(address);
                output.writeByte(DomainControllerProtocol.PARAM_HOST_CONTROLLER_PORT);
View Full Code Here

Examples of org.jboss.as.protocol.mgmt.FlushableDataOutput.writeUTF()

331
332
333
334
335
336
337
338
339
340
341
            // This is an error
            output.writeByte(DomainControllerProtocol.PARAM_ERROR);
            // send error code
            output.writeByte(errorCode);
            // error message
            output.writeUTF(message);
            // response end
            output.writeByte(ManagementProtocol.RESPONSE_END);
            output.close();
        } finally {
            StreamUtils.safeClose(output);
View Full Code Here

Examples of org.jboss.invocation.MarshalledValueOutputStream.writeUTF()

274
275
276
277
278
279
280
281
282
283
284
      ByteArrayOutputStream bos = new ByteArrayOutputStream();
      ObjectOutputStream oos = new MarshalledValueOutputStream(bos);

      // Extract fqn and write it out in fixed format
      if(fqn == null) fqn = "NULL"; // can't write null. tis can be commit.
      oos.writeUTF(fqn);
      // Serialize the rest of MethodCall object
      oos.writeObject(o);
      if (log_.isTraceEnabled()) {
         log_.trace("send");
         log_.trace(getColumnDump(bos.toByteArray()));
View Full Code Here

Examples of org.jboss.jms.message.JBossBytesMessage.writeUTF()

80
81
82
83
84
85
86
87
88
89
90
      m.writeDouble(randDouble().doubleValue());
      m.writeFloat(randFloat().floatValue());
      m.writeInt(randInt().intValue());
      m.writeLong(randLong().longValue());     
      m.writeShort(randShort().shortValue());
      m.writeUTF(randString(1000));

      return m;     
   }
  
}
View Full Code Here

Examples of org.jboss.marshalling.Marshaller.writeUTF()

286
287
288
289
290
291
292
293
294
295
296
            marshaller.writeByte(ServerManagerProtocol.RETURN_SERVER_COUNT);
            marshaller.writeInt(serverStatuses.size());
            for (Map.Entry<ServerIdentity, ServerStatus> entry : serverStatuses.entrySet()) {
                marshaller.writeByte(ServerManagerProtocol.RETURN_SERVER_NAME);
                marshaller.writeUTF(entry.getKey().getServerName());
                marshaller.writeByte(ServerManagerProtocol.RETURN_SERVER_GROUP_NAME);
                marshaller.writeUTF(entry.getKey().getServerGroupName());
                marshaller.writeByte(ServerManagerProtocol.RETURN_SERVER_STATUS);
                marshaller.writeObject(entry.getValue());
            }
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.