本文整理了Java中org.apache.activemq.util.ByteArrayOutputStream.<init>()方法的一些代码示例，展示了ByteArrayOutputStream.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ByteArrayOutputStream.<init>()方法的具体详情如下：
包路径：org.apache.activemq.util.ByteArrayOutputStream
类名称：ByteArrayOutputStream
方法名：<init>

ByteArrayOutputStream.<init>介绍

暂无

代码示例

代码示例来源：origin: apache/activemq

protected ByteArrayOutputStream createByteArrayOutputStream() {
  return new ByteArrayOutputStream(datagramSize);
}

代码示例来源：origin: apache/activemq

@Override
public void beforeMarshall(WireFormat wireFormat) throws IOException {
  // Need to marshal the properties.
  if (marshalledProperties == null && properties != null) {
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    DataOutputStream os = new DataOutputStream(baos);
    MarshallingSupport.marshalPrimitiveMap(properties, os);
    os.close();
    marshalledProperties = baos.toByteSequence();
  }
}

代码示例来源：origin: apache/activemq

public ByteSequence marshal(Object command) throws IOException {
  ByteArrayOutputStream baos = new ByteArrayOutputStream();
  DataOutputStream ds = new DataOutputStream(baos);
  marshal(command, ds);
  ds.close();
  return baos.toByteSequence();
}

代码示例来源：origin: apache/activemq

@Override
public void beforeMarshall(WireFormat wireFormat) throws IOException {
  // Need to marshal the properties.
  if (marshalledProperties == null && properties != null) {
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    DataOutputStream os = new DataOutputStream(baos);
    MarshallingSupport.marshalPrimitiveMap(properties, os);
    os.close();
    marshalledProperties = baos.toByteSequence();
  }
}

代码示例来源：origin: apache/activemq

private void initializeWriting() throws JMSException {
  checkReadOnlyBody();
  if (this.dataOut == null) {
    this.bytesOut = new ByteArrayOutputStream();
    OutputStream os = bytesOut;
    this.dataOut = new DataOutputStream(os);
  }
  restoreOldContent();
}

代码示例来源：origin: apache/activemq

protected void doCompress() throws IOException {
  compressed = true;
  ByteSequence bytes = getContent();
  ByteArrayOutputStream bytesOut = new ByteArrayOutputStream();
  OutputStream os = new DeflaterOutputStream(bytesOut);
  os.write(bytes.data, bytes.offset, bytes.length);
  os.close();
  setContent(bytesOut.toByteSequence());
}

代码示例来源：origin: apache/activemq

private void trace(DataStructure command) {
  try {
    ByteArrayOutputStream baos = new ByteArrayOutputStream(maxTraceDatagramSize);
    DataOutputStream out = new DataOutputStream(baos);
    wireFormat.marshal(brokerId, out);
    wireFormat.marshal(command, out);
    out.close();
    ByteSequence sequence = baos.toByteSequence();
    DatagramPacket datagram = new DatagramPacket(sequence.getData(), sequence.getOffset(), sequence.getLength(), address);
    socket.send(datagram);
  } catch (Throwable e) {
    LOG.debug("Failed to trace: {}", command, e);
  }
}

代码示例来源：origin: apache/activemq

protected byte[] decompress(ByteSequence dataSequence) throws IOException {
  Inflater inflater = new Inflater();
  ByteArrayOutputStream decompressed = new ByteArrayOutputStream();
  try {
    length = ByteSequenceData.readIntBig(dataSequence);
    dataSequence.offset = 0;
    byte[] data = Arrays.copyOfRange(dataSequence.getData(), 4, dataSequence.getLength());
    inflater.setInput(data);
    byte[] buffer = new byte[length];
    int count = inflater.inflate(buffer);
    decompressed.write(buffer, 0, count);
    return decompressed.toByteArray();
  } catch (Exception e) {
    throw new IOException(e);
  } finally {
    inflater.end();
    decompressed.close();
  }
}

代码示例来源：origin: apache/activemq

@Override
public void storeContent() {
  ByteSequence bodyAsBytes = getContent();
  if (bodyAsBytes == null && object != null) {
    try {
      ByteArrayOutputStream bytesOut = new ByteArrayOutputStream();
      OutputStream os = bytesOut;
      ActiveMQConnection connection = getConnection();
      if (connection != null && connection.isUseCompression()) {
        compressed = true;
        os = new DeflaterOutputStream(os);
      }
      DataOutputStream dataOut = new DataOutputStream(os);
      ObjectOutputStream objOut = new ObjectOutputStream(dataOut);
      objOut.writeObject(object);
      objOut.flush();
      objOut.reset();
      objOut.close();
      setContent(bytesOut.toByteSequence());
    } catch (IOException ioe) {
      throw new RuntimeException(ioe.getMessage(), ioe);
    }
  }
}

代码示例来源：origin: apache/activemq

@Override
public void storeContent() {
  try {
    if (getContent() == null && !map.isEmpty()) {
      ByteArrayOutputStream bytesOut = new ByteArrayOutputStream();
      OutputStream os = bytesOut;
      ActiveMQConnection connection = getConnection();
      if (connection != null && connection.isUseCompression()) {
        compressed = true;
        os = new DeflaterOutputStream(os);
      }
      DataOutputStream dataOut = new DataOutputStream(os);
      MarshallingSupport.marshalPrimitiveMap(map, dataOut);
      dataOut.close();
      setContent(bytesOut.toByteSequence());
    }
  } catch (IOException e) {
    throw new RuntimeException(e);
  }
}

代码示例来源：origin: apache/activemq

@Override
public void storeContent() {
  try {
    ByteSequence content = getContent();
    String text = this.text;
    if (content == null && text != null) {
      ByteArrayOutputStream bytesOut = new ByteArrayOutputStream();
      OutputStream os = bytesOut;
      ActiveMQConnection connection = getConnection();
      if (connection != null && connection.isUseCompression()) {
        compressed = true;
        os = new DeflaterOutputStream(os);
      }
      DataOutputStream dataOut = new DataOutputStream(os);
      MarshallingSupport.writeUTF8(dataOut, text);
      dataOut.close();
      setContent(bytesOut.toByteSequence());
    }
  } catch (IOException e) {
    throw new RuntimeException(e);
  }
}

代码示例来源：origin: apache/activemq

@Override
public byte[] doGetMessage(TransactionContext c, MessageId id) throws SQLException, IOException {
  PreparedStatement s = null;
  ResultSet rs = null;
  try {
    s = c.getConnection().prepareStatement(statements.getFindMessageStatement());
    s.setString(1, id.getProducerId().toString());
    s.setLong(2, id.getProducerSequenceId());
    rs = s.executeQuery();
    if (!rs.next()) {
      return null;
    }
    Blob blob = rs.getBlob(1);
    try(InputStream is = blob.getBinaryStream();
      ByteArrayOutputStream os = new ByteArrayOutputStream((int)blob.length())) {
      int ch;
      while ((ch = is.read()) >= 0) {
        os.write(ch);
      }
      return os.toByteArray();
    }
  } finally {
    close(rs);
    close(s);
  }
}

代码示例来源：origin: apache/activemq

@Override
  protected void doCompress() throws IOException {
    compressed = true;
    ByteSequence bytes = getContent();
    if (bytes != null) {
      int length = bytes.getLength();
      ByteArrayOutputStream compressed = new ByteArrayOutputStream();
      compressed.write(new byte[4]);
      Deflater deflater = new Deflater();
      try {
        deflater.setInput(bytes.data);
        deflater.finish();
        byte[] buffer = new byte[1024];
        while (!deflater.finished()) {
          int count = deflater.deflate(buffer);
          compressed.write(buffer, 0, count);
        }

        bytes = compressed.toByteSequence();
        ByteSequenceData.writeIntBig(bytes, length);
        bytes.offset = 0;
        setContent(bytes);
      } finally {
        deflater.end();
        compressed.close();
      }
    }
  }
}

代码示例来源：origin: apache/activemq

public void write(Command command, SocketAddress address) throws IOException {
  synchronized (writeLock) {
    ByteArrayOutputStream largeBuffer = new ByteArrayOutputStream(defaultMarshalBufferSize);
    wireFormat.marshal(command, new DataOutputStream(largeBuffer));
    byte[] data = largeBuffer.toByteArray();

代码示例来源：origin: apache/activemq

private void initializeWriting() throws JMSException {
  checkReadOnlyBody();
  if (this.dataOut == null) {
    this.bytesOut = new ByteArrayOutputStream();
    OutputStream os = bytesOut;
    ActiveMQConnection connection = getConnection();

代码示例来源：origin: apache/nifi

cachedAttributes.put("key2", "value2");
cachedAttributes.put("key3", "value3");
final ByteArrayOutputStream bos = new ByteArrayOutputStream();
attributesSerializer.serialize(cachedAttributes, bos);

代码示例来源：origin: apache/activemq-artemis

EagerActiveMQBytesMessage(int size) {
   this.bytesOut = new org.apache.activemq.util.ByteArrayOutputStream(size);
   OutputStream os = bytesOut;
   this.dataOut = new DataOutputStream(os);
 }
}

代码示例来源：origin: org.apache.activemq/activemq-client

public ByteSequence marshal(Object command) throws IOException {
  ByteArrayOutputStream baos = new ByteArrayOutputStream();
  DataOutputStream ds = new DataOutputStream(baos);
  marshal(command, ds);
  ds.close();
  return baos.toByteSequence();
}

代码示例来源：origin: org.apache.activemq/activemq-client

@Override
public void beforeMarshall(WireFormat wireFormat) throws IOException {
  // Need to marshal the properties.
  if (marshalledProperties == null && properties != null) {
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    DataOutputStream os = new DataOutputStream(baos);
    MarshallingSupport.marshalPrimitiveMap(properties, os);
    os.close();
    marshalledProperties = baos.toByteSequence();
  }
}

代码示例来源：origin: apache/activemq-artemis

private static ByteSequence writeCompressedDefaultType(final ByteSequence contents) throws IOException {
 try (org.apache.activemq.util.ByteArrayOutputStream decompressed = new org.apache.activemq.util.ByteArrayOutputStream();
    OutputStream os = new InflaterOutputStream(decompressed)) {
   os.write(contents.data, contents.offset, contents.getLength());
   return decompressed.toByteSequence();
 } catch (Exception e) {
   throw new IOException(e);
 }
}