Package org.apache.qpid.amqp_1_0.type

Examples of org.apache.qpid.amqp_1_0.type.Binary

262
263
264
265
266
267
268
269
270
271
272
273
        int read = fis.read(data);

        fis.close();

        Section applicationProperties = new ApplicationProperties(Collections.singletonMap("filename", fileName));
        Section amqpValue = new Data(new Binary(data));
        Message message = new Message(Arrays.asList(applicationProperties, amqpValue));
        Binary deliveryTag = new Binary(md5.digest(fileName.getBytes()));
        message.setDeliveryTag(deliveryTag);
        md5.reset();
        return message;
    }
View Full Code Here
42
43
44
45
46
47
48
49
50
    protected BytesMessageImpl(Header header, MessageAnnotations messageAnnotations, Properties properties, ApplicationProperties appProperties, Data data,
                               Footer footer, SessionImpl session)
    {
        super(header, messageAnnotations, properties, appProperties, footer, session);
        _dataIn = data;
        final Binary dataBuffer = data.getValue();
        _dataAsInput = new DataInputStream(new ByteArrayInputStream(dataBuffer.getArray(),dataBuffer.getArrayOffset(),dataBuffer.getLength()));

    }
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
    private Data getDataSection()
    {
        if(_bytesOut != null)
        {
            return new Data(new Binary(_bytesOut.toByteArray()));
        }
        else
        {
            return _dataIn;
        }
View Full Code Here
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
    public void reset() throws JMSException
    {
        if(_bytesOut != null)
        {
            byte[] data = _bytesOut.toByteArray();
            _dataIn = new Data(new Binary(data));
            _dataAsInput = new DataInputStream(new ByteArrayInputStream(data));
            _dataAsOutput = null;
            _bytesOut = null;
        }
        else
        {

            final Binary dataBuffer = _dataIn.getValue();
            _dataAsInput = new DataInputStream(new ByteArrayInputStream(dataBuffer.getArray(),dataBuffer.getArrayOffset(),dataBuffer.getLength()));

        }
    }
View Full Code Here
322
323
324
325
326
327
328
329
330
331
332
333
334
            {
                return -1;
            }
            throw new MessageFormatException("Cannot convert value of type " + obj.getClass().getName());
        }
        Binary binary = (Binary) obj;
        if(bytes.length >= binary.getLength())
        {
            System.arraycopy(binary.getArray(),binary.getArrayOffset(),bytes,0,binary.getLength());
            return binary.getLength();
        }
        return -1;
    }
View Full Code Here
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
    {
        checkWritable();
       
        if(!_list.isEmpty() && _list.get(_list.size()-1) instanceof byte[])
        {
            Binary oldVal = (Binary) _list.get(_list.size()-1);
            byte[] allBytes = new byte[oldVal.getLength() + size];
            System.arraycopy(oldVal.getArray(),oldVal.getArrayOffset(),allBytes,0,oldVal.getLength());
            System.arraycopy(bytes, offset, allBytes, oldVal.getLength(), size);
            _list.set(_list.size()-1, allBytes);
        }
        else
        {
            byte[] dup = new byte[size];
            System.arraycopy(bytes,offset,dup,0,size);
            _list.add(new Binary(dup));
        }
    }
View Full Code Here
132
133
134
135
136
137
138
139
140
141
142
143
144
    {

        Object o = getCorrelationId();
        if(o instanceof Binary)
        {
            Binary correlationIdBinary = (Binary) o;
            byte[] correlationId = new byte[correlationIdBinary.getLength()];
            correlationIdBinary.asByteBuffer().get(correlationId);
            return correlationId;
        }
        else
        {
            return o == null ? null : o.toString().getBytes();
View Full Code Here
154
155
156
157
158
159
160
161
        }
        else
        {
            byte[] dup = new byte[correlationId.length];
            System.arraycopy(correlationId,0,dup,0,correlationId.length);
            setCorrelationId(new Binary(dup));
        }
    }
View Full Code Here
168
169
170
171
172
173
174
175
176
177
178
179
    public String getJMSCorrelationID() throws JMSException
    {
        Object o = getProperties().getCorrelationId();
        if(o instanceof Binary)
        {
            Binary id = (Binary) o;
            return new String(id.getArray(), id.getArrayOffset(), id.getLength());
        }
        else
        {
            return o == null ? null : o.toString();
        }
View Full Code Here
266
267
268
269
270
271
272
273
274
275
276
277
            if(RAW_LOGGER.isLoggable(Level.FINE))
            {
                ByteBuffer dup = msg.duplicate();
                byte[] data = new byte[dup.remaining()];
                dup.get(data);
                Binary bin = new Binary(data);
                RAW_LOGGER.fine("RECV[" + getRemoteAddress() + "] : " + bin.toString());
            }
            _readBytes += msg.remaining();
            switch(_state)
            {
                case A:
View Full Code Here
TOP

Related Classes of org.apache.qpid.amqp_1_0.type.Binary

  • org.apache.activemq.karaf.itest.ActiveMQAMQPBrokerFeatureTest
  • org.apache.activemq.transport.amqp.AMQ4563Test
  • org.apache.activemq.transport.amqp.AMQ4696Test
  • org.apache.activemq.transport.amqp.AMQ4920Test
  • org.apache.activemq.transport.amqp.AMQ4930ConsumerTask
  • org.apache.activemq.transport.amqp.AmqpTransformerTest
  • org.apache.activemq.transport.amqp.bugs.AMQ4753Test
  • org.apache.activemq.transport.amqp.bugs.AMQ4914Test
  • org.apache.activemq.transport.amqp.JmsClientRequestResponseTest
  • org.apache.activemq.transport.amqp.JMSClientTest
    • 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.